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