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