public class FilterData
extends java.lang.Object
implements org.apache.spark.api.java.function.Function<org.apache.hadoop.io.MapWritable,java.lang.Boolean>
Constructor and Description |
---|
FilterData(Accumulators accumIn,
BroadcastVars bbVarsIn) |
Modifier and Type | Method and Description |
---|---|
java.lang.Boolean |
call(org.apache.hadoop.io.MapWritable dataElement) |
public FilterData(Accumulators accumIn, BroadcastVars bbVarsIn)