Antero Duarte
10/01/2018, 2:05 PM// Declaration
private val fileFilter = object : AbstractFunction1<Tuple2<String, PortableDataStream>, Any>() {
override fun apply(tuple: Tuple2<String, PortableDataStream>?): Any {
return true
}
}
// Call
sc.binaryFiles(path, 1).filter(fileFilter)