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