hudsonb
val x = object : AbstractFunction1<Tuple2<String,PortableDataStream>, Boolean>() { override fun apply(tuple: Tuple2<String,PortableDataStream>?): Boolean { return true } }