public class ComputeExpLookupTable
extends java.lang.Object
Constructor and Description |
---|
ComputeExpLookupTable() |
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>>> |
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>>> |
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
|
public static org.apache.spark.api.java.JavaPairRDD<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>> 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)
Returns a Pair RDD of the form
public static org.apache.spark.api.java.JavaPairRDD<java.lang.Integer,java.lang.Iterable<scala.Tuple2<java.lang.Integer,java.math.BigInteger>>> 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)
Returns a Pair RDD of the form