Package | Description |
---|---|
org.apache.pirk.responder.wideskies.common | |
org.apache.pirk.responder.wideskies.mapreduce |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple2<java.lang.Integer,BytesArrayWritable> |
HashSelectorAndPartitionData.hashSelectorAndFormPartitions(org.apache.hadoop.io.MapWritable dataElement,
QuerySchema qSchema,
DataSchema dSchema,
QueryInfo queryInfo) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
ComputeEncryptedRow.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
|
Modifier and Type | Method and Description |
---|---|
static java.util.List<scala.Tuple2<java.lang.Long,java.math.BigInteger>> |
ComputeEncryptedRow.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
|
Modifier and Type | Method and Description |
---|---|
void |
RowCalcReducer.reduce(org.apache.hadoop.io.IntWritable rowIndex,
java.lang.Iterable<BytesArrayWritable> dataElementPartitions,
org.apache.hadoop.mapreduce.Reducer.Context ctx) |