Modifier and Type | Method and Description |
---|---|
java.math.BigInteger |
Paillier.encrypt(java.math.BigInteger m)
Returns the encrypted value of
m using a generated random value. |
java.math.BigInteger |
Paillier.encrypt(java.math.BigInteger m,
java.math.BigInteger r)
Returns the ciphertext of a message using the given random value.
|
Modifier and Type | Method and Description |
---|---|
void |
PartitionUtilsTest.testPaddedPartitions() |
void |
PartitionUtilsTest.testPartitionBits() |
Modifier and Type | Method and Description |
---|---|
java.util.Properties |
EncryptionPropertiesBuilder.build() |
static Querier |
QuerierFactory.createQuerier(java.util.UUID queryIdentifier,
java.util.List<java.lang.String> selectors,
java.util.Properties properties)
Generates a
Querier containing the encrypted query. |
static void |
QuerierDriver.main(java.lang.String... args) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<QueryResponseJSON>> |
DecryptResponse.decrypt() |
java.util.Map<java.lang.String,java.util.List<QueryResponseJSON>> |
DecryptResponse.decrypt(int numThreads)
Method to decrypt the response elements and reconstructs the data elements
|
Modifier and Type | Method and Description |
---|---|
Querier |
EncryptQuery.encrypt()
Encrypts the query described by the query information using Paillier encryption.
|
Querier |
EncryptQuery.encrypt(int numThreads)
Encrypts the query described by the query information using Paillier encryption using the given number of threads.
|
Modifier and Type | Method and Description |
---|---|
static java.util.List<java.math.BigInteger> |
QueryUtils.embeddedSelectorToPartitions(java.lang.String selector,
java.lang.String type,
DataPartitioner partitioner)
Method to convert the given selector into the extracted BigInteger partitions
|
static QueryResponseJSON |
QueryUtils.extractQueryResponseJSON(QueryInfo queryInfo,
QuerySchema qSchema,
java.util.List<java.math.BigInteger> parts)
Method to convert the given BigInteger raw data element partitions to a QueryResponseJSON object based upon the given queryType
|
static java.lang.String |
QueryUtils.getEmbeddedSelector(java.lang.String selector,
java.lang.String type,
DataPartitioner partitioner)
Method get the embedded selector from a given selector
|
static java.lang.String |
QueryUtils.getEmbeddedSelectorFromPartitions(java.util.List<java.math.BigInteger> parts,
int partsIndex,
java.lang.String type,
java.lang.Object partitioner)
Reconstructs the String version of the embedded selector from its partitions
|
static java.util.List<java.math.BigInteger> |
QueryUtils.partitionDataElement(org.apache.hadoop.io.MapWritable dataMap,
QuerySchema qSchema,
DataSchema dSchema,
boolean embedSelector)
Method to convert the given data element given by the MapWritable data element into the extracted BigInteger partitions based upon the given queryType
|
static java.util.List<java.math.BigInteger> |
QueryUtils.partitionDataElement(QuerySchema qSchema,
org.json.simple.JSONObject jsonData,
boolean embedSelector)
Method to convert the given data element given by the JSONObject data element into the extracted BigInteger partitions based upon the given queryType
|
Modifier and Type | Method and Description |
---|---|
ResponderPlugin |
ResponderService.getResponder(java.lang.String platformName) |
Modifier and Type | Method and Description |
---|---|
void |
MapReduceResponder.run() |
Constructor and Description |
---|
ComputeResponseTool() |
Modifier and Type | Method and Description |
---|---|
void |
ComputeResponse.performQuery()
Method to read in data from an allowed input source/format and perform the query
|
void |
ComputeResponse.performQuery(org.apache.spark.api.java.JavaRDD<org.apache.hadoop.io.MapWritable> inputRDD)
Method to perform the query given an input RDD of MapWritables
|
org.apache.spark.api.java.JavaRDD<org.apache.hadoop.io.MapWritable> |
ComputeResponse.readData()
Method to read in the data from an allowed input format, filter, and return a RDD of MapWritable data elements
|
org.apache.spark.api.java.JavaRDD<org.apache.hadoop.io.MapWritable> |
ComputeResponse.readDataES()
Method to read in the data from elasticsearch, filter, and return a RDD of MapWritable data elements
|
void |
SparkResponder.run() |
Constructor and Description |
---|
ComputeResponse(org.apache.hadoop.fs.FileSystem fileSys) |
Modifier and Type | Method and Description |
---|---|
void |
ComputeStreamingResponse.performQuery()
Method to read in data from an allowed input source/format and perform the query
|
org.apache.spark.streaming.api.java.JavaDStream<org.apache.hadoop.io.MapWritable> |
ComputeStreamingResponse.readData()
Method to read in the data from an allowed input format, filter, and return a RDD of MapWritable data elements
|
void |
SparkStreamingResponder.run() |
Constructor and Description |
---|
ComputeStreamingResponse(org.apache.hadoop.fs.FileSystem fileSys) |
Modifier and Type | Method and Description |
---|---|
void |
ResponderPlugin.run()
This method launches your framework responder.
|
Modifier and Type | Method and Description |
---|---|
void |
StormResponder.run() |
static void |
PirkTopology.runPirkTopology() |
Modifier and Type | Method and Description |
---|---|
DataPartitioner |
DataSchema.getPartitionerForElement(java.lang.String elementName)
Returns the partitioner instance for the given element name.
|
DataPartitioner |
DataSchema.getPartitionerInstance(java.lang.String partitionerTypeName)
Returns the partitioner corresponding to the given partitioner class name.
|
static void |
DataSchemaLoader.initialize()
Initializes the static
DataSchemaRegistry with a list of available data schema names. |
static void |
DataSchemaLoader.initialize(boolean hdfs,
org.apache.hadoop.fs.FileSystem fs)
Initializes the static
DataSchemaRegistry with a list of available data schema names. |
DataSchema |
DataSchemaLoader.loadSchema(java.io.InputStream stream)
Returns the data schema as defined in XML format on the given stream.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<java.math.BigInteger> |
PrimitiveTypePartitioner.arrayToPartitions(java.util.List<?> elementList,
java.lang.String type)
Create partitions for an array of the same type of elements - used when a data value field is an array and we wish to encode these into the return value
|
java.util.List<java.math.BigInteger> |
ISO8601DatePartitioner.arrayToPartitions(java.util.List<?> elementList,
java.lang.String type) |
java.util.List<java.math.BigInteger> |
DataPartitioner.arrayToPartitions(java.util.List<?> elementList,
java.lang.String type)
Creates partitions for an array of the same type of elements - used when a data value field is an array and we wish to encode these into the return value.
|
java.lang.Object |
PrimitiveTypePartitioner.fromPartitions(java.util.List<java.math.BigInteger> parts,
int partsIndex,
java.lang.String type)
Reconstructs the object from the partitions
|
java.lang.Object |
ISO8601DatePartitioner.fromPartitions(java.util.List<java.math.BigInteger> parts,
int partsIndex,
java.lang.String type) |
java.lang.Object |
DataPartitioner.fromPartitions(java.util.List<java.math.BigInteger> parts,
int partsIndex,
java.lang.String type)
Method to reconstruct an Object given a List of its BigInteger partition elements and its type identifier.
|
int |
PrimitiveTypePartitioner.getBits(java.lang.String type)
Get the bit size of the allowed primitive java types
|
int |
DataPartitioner.getBits(java.lang.String type)
Returns the number of bits of an object with the given type.
|
int |
PrimitiveTypePartitioner.getNumPartitions(java.lang.String type)
Method to get the number of 8-bit partitions given the element type
|
int |
ISO8601DatePartitioner.getNumPartitions(java.lang.String type) |
int |
DataPartitioner.getNumPartitions(java.lang.String type)
Method to get the number of partitions of the data object given the type.
|
java.util.List<java.math.BigInteger> |
PrimitiveTypePartitioner.getPaddedPartitions(java.lang.String type)
Method to get an empty set of partitions by data type - used for padding return array values
|
java.util.List<java.math.BigInteger> |
ISO8601DatePartitioner.getPaddedPartitions(java.lang.String type) |
java.util.List<java.math.BigInteger> |
DataPartitioner.getPaddedPartitions(java.lang.String type)
Method to get an empty set of partitions by data type - used for padding return array values.
|
static java.util.List<java.math.BigInteger> |
PrimitiveTypePartitioner.partitionBits(java.math.BigInteger value,
int partitionSize,
java.math.BigInteger mask)
Splits the given BigInteger into partitions given by the partitionSize.
|
java.util.List<java.math.BigInteger> |
PrimitiveTypePartitioner.toPartitions(java.lang.Object obj,
java.lang.String type)
Partitions an object to a List of BigInteger values, currently represents an 8-bit partitioning
|
java.util.List<java.math.BigInteger> |
ISO8601DatePartitioner.toPartitions(java.lang.Object object,
java.lang.String type) |
java.util.List<java.math.BigInteger> |
DataPartitioner.toPartitions(java.lang.Object object,
java.lang.String type)
Method to partition the given Object into a List of BigInteger partition elements given its type identifier.
|
Modifier and Type | Method and Description |
---|---|
static void |
QuerySchemaLoader.initialize()
Initializes the static
QuerySchemaRegistry with a list of query schema names. |
static void |
QuerySchemaLoader.initialize(boolean hdfs,
org.apache.hadoop.fs.FileSystem fs)
Initializes the static
QuerySchemaRegistry with a list of available query schema names. |
QuerySchema |
QuerySchemaLoader.loadSchema(java.io.InputStream stream)
Returns the query schema as defined in XML format on the given stream.
|
Modifier and Type | Method and Description |
---|---|
static DataFilter |
FilterFactory.getFilter(java.lang.String filterName,
java.util.Set<java.lang.String> filteredElementNames) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
Inputs.createStopList(org.apache.hadoop.fs.FileSystem fs,
boolean hdfs)
Creates stoplist file
|
static java.util.List<QueryResponseJSON> |
StandaloneQuery.performStandaloneQuery(java.util.List<org.json.simple.JSONObject> dataElements,
java.lang.String queryType,
java.util.List<java.lang.String> selectors,
int numThreads,
boolean testFalsePositive) |