- All Implemented Interfaces:
- java.io.Serializable, org.apache.spark.api.java.function.PairFunction<org.apache.hadoop.io.MapWritable,java.lang.Integer,java.util.List<java.math.BigInteger>>
public class HashSelectorsAndPartitionData
extends java.lang.Object
implements org.apache.spark.api.java.function.PairFunction<org.apache.hadoop.io.MapWritable,java.lang.Integer,java.util.List<java.math.BigInteger>>
Function to extract the selector by queryType from each dataElement, perform a keyed hash of the selector, extract the partitions of the dataElement, and
output <hash(selector), dataPartitions>
- See Also:
- Serialized Form