Package | Description |
---|---|
org.apache.pirk.responder.wideskies.spark | |
org.apache.pirk.responder.wideskies.spark.streaming |
Modifier and Type | Method and Description |
---|---|
static org.apache.spark.api.java.JavaPairRDD<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>> |
ComputeExpLookupTable.computeExpTable(org.apache.spark.api.java.JavaSparkContext sc,
org.apache.hadoop.fs.FileSystem fs,
BroadcastVars bVars,
Query query,
java.lang.String queryInputFile,
java.lang.String outputDirExp)
Method to create the distributed modular exponentiation lookup table in hdfs for a given Query
|
static org.apache.spark.api.java.JavaPairRDD<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>> |
ComputeExpLookupTable.computeExpTable(org.apache.spark.api.java.JavaSparkContext sc,
org.apache.hadoop.fs.FileSystem fs,
BroadcastVars bVars,
Query query,
java.lang.String queryInputFile,
java.lang.String outputDirExp,
boolean useModExpJoin)
Method to create the distributed modular exponentiation lookup table in hdfs for a given Query
|
Constructor and Description |
---|
EncColMultGroupedMapper(BroadcastVars bbVarsIn) |
EncColMultReducer(BroadcastVars bbVarsIn) |
EncRowCalc(Accumulators accumIn,
BroadcastVars bvIn) |
EncRowCalcPrecomputedCache(Accumulators accumIn,
BroadcastVars bvIn) |
ExpKeyFilenameMap(BroadcastVars bbVarsIn) |
ExpTableGenerator(BroadcastVars bbVarsIn) |
FilterData(Accumulators accumIn,
BroadcastVars bbVarsIn) |
HashSelectorsAndPartitionData(BroadcastVars bvIn) |
Constructor and Description |
---|
FinalResponseFunction(Accumulators accumIn,
BroadcastVars bbVarsIn) |