public class EncRowCalc
extends java.lang.Object
implements org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.List<java.math.BigInteger>>>,java.lang.Long,java.math.BigInteger>
For each row (as indicated by key = hash(selector)), iterates over each dataElement and calculates the column values.
Emits <colNum, colVal>
Constructor and Description |
---|
EncRowCalc(Accumulators accumIn,
BroadcastVars bvIn) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
call(scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.List<java.math.BigInteger>>> hashDocTuple) |
public EncRowCalc(Accumulators accumIn, BroadcastVars bvIn)
public java.lang.Iterable<scala.Tuple2<java.lang.Long,java.math.BigInteger>> call(scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.List<java.math.BigInteger>>> hashDocTuple) throws java.lang.Exception
call
in interface org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<java.lang.Integer,java.lang.Iterable<java.util.List<java.math.BigInteger>>>,java.lang.Long,java.math.BigInteger>
java.lang.Exception