public class ComputeEncryptedRow
extends java.lang.Object
Constructor and Description |
---|
ComputeEncryptedRow() |
Modifier and Type | Method and Description |
---|---|
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
computeEncRow(java.math.BigInteger part,
Query query,
int rowIndex,
int colIndex) |
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
computeEncRow(BytesArrayWritable dataPartitions,
Query query,
int rowIndex,
int colIndex)
Method to compute the encrypted row elements for a query from extracted data partitions in the form of BytesArrayWritable
|
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
computeEncRow(java.lang.Iterable<BytesArrayWritable> dataPartitionsIter,
Query query,
int rowIndex,
boolean limitHitsPerSelector,
int maxHitsPerSelector,
boolean useCache)
Method to compute the encrypted row elements for a query from extracted data partitions in the form of Iterable
|
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
computeEncRow(java.util.List<java.math.BigInteger> dataPartitions,
Query query,
int rowIndex,
int colIndex)
Method to compute the encrypted row elements for a query from extracted data partitions in the form of ArrayList<
|
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
computeEncRowBI(java.lang.Iterable<java.util.List<java.math.BigInteger>> dataPartitionsIter,
Query query,
int rowIndex,
boolean limitHitsPerSelector,
int maxHitsPerSelector,
boolean useCache)
Method to compute the encrypted row elements for a query from extracted data partitions in the form of Iterable
* * * * |
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
computeEncRowCacheInput(java.lang.Iterable<java.util.List<java.math.BigInteger>> dataPartitionsIter,
java.util.HashMap<java.lang.Integer,java.math.BigInteger> cache,
int rowIndex,
boolean limitHitsPerSelector,
int maxHitsPerSelector)
Method to compute the encrypted row elements for a query from extracted data partitions in the form of Iterable
|
static void |
loadCacheFromHDFS(org.apache.hadoop.fs.FileSystem fs,
java.lang.String hdfsFileName,
Query query)
Populate the cache based on the pre-generated exp table in hdfs
|
public static void loadCacheFromHDFS(org.apache.hadoop.fs.FileSystem fs, java.lang.String hdfsFileName, Query query) throws java.io.IOException
java.io.IOException
public static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> computeEncRow(java.lang.Iterable<BytesArrayWritable> dataPartitionsIter, Query query, int rowIndex, boolean limitHitsPerSelector, int maxHitsPerSelector, boolean useCache) throws java.io.IOException
For each row (as indicated by key = hash(selector)), iterates over the dataPartitions and calculates the column values.
Optionally uses a static LRU cache for the modular exponentiation
Emits Tuple2<<colNum, colVal>>
java.io.IOException
public static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> computeEncRowBI(java.lang.Iterable<java.util.List<java.math.BigInteger>> dataPartitionsIter, Query query, int rowIndex, boolean limitHitsPerSelector, int maxHitsPerSelector, boolean useCache) throws java.io.IOException
* * * *
For each row (as indicated by key = hash(selector)), iterates over the dataPartitions and calculates the column values.
Optionally uses a static LRU cache for the modular exponentiation
Emits Tuple2<<colNum, colVal>>
java.io.IOException
public static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> computeEncRowCacheInput(java.lang.Iterable<java.util.List<java.math.BigInteger>> dataPartitionsIter, java.util.HashMap<java.lang.Integer,java.math.BigInteger> cache, int rowIndex, boolean limitHitsPerSelector, int maxHitsPerSelector) throws java.io.IOException
For each row (as indicated by key = hash(selector)), iterates over the dataPartitions and calculates the column values.
Emits Tuple2<<colNum, colVal>>
java.io.IOException
public static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> computeEncRow(BytesArrayWritable dataPartitions, Query query, int rowIndex, int colIndex) throws java.io.IOException
For each row (as indicated by key = hash(selector)), iterates over the dataPartitions and calculates the column values.
Uses a static LRU cache for the modular exponentiation
Caller is responsible for keeping track of the colIndex and the the maxHitsPerSelector values
Emits Tuple2<<colNum, colVal>>
java.io.IOException
public static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> computeEncRow(java.util.List<java.math.BigInteger> dataPartitions, Query query, int rowIndex, int colIndex) throws java.io.IOException
For each row (as indicated by key = hash(selector)), iterates over the dataPartitions and calculates the column values.
Uses a static LRU cache for the modular exponentiation
Caller is responsible for keeping track of the colIndex and the the maxHitsPerSelector values
Emits Tuple2<<colNum, colVal>>
java.io.IOException
public static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> computeEncRow(java.math.BigInteger part, Query query, int rowIndex, int colIndex) throws java.io.IOException
java.io.IOException