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