- RCODE - Static variable in class org.apache.pirk.test.utils.Inputs
-
- read(InputStream, Class<T>) - Method in class org.apache.pirk.serialization.JavaSerializer
-
Read an object from the given stream of the given type.
- read(InputStream, Class<T>) - Method in class org.apache.pirk.serialization.JsonSerializer
-
Read a JSON string from the given input stream and returns the Object representation.
- read(InputStream, Class<T>) - Method in class org.apache.pirk.serialization.SerializationService
-
- read(String, AbstractCollection<String>, FileIOUtils.Callable<String>) - Static method in class org.apache.pirk.utils.FileIOUtils
-
- readData() - Method in class org.apache.pirk.responder.wideskies.spark.ComputeResponse
-
Method to read in the data from an allowed input format, filter, and return a RDD of MapWritable data elements
- readData() - Method in class org.apache.pirk.responder.wideskies.spark.streaming.ComputeStreamingResponse
-
Method to read in the data from an allowed input format, filter, and return a RDD of MapWritable data elements
- readDataES() - Method in class org.apache.pirk.responder.wideskies.spark.ComputeResponse
-
Method to read in the data from elasticsearch, filter, and return a RDD of MapWritable data elements
- readDataES() - Method in class org.apache.pirk.responder.wideskies.spark.streaming.ComputeStreamingResponse
-
Method to read in the data from elasticsearch, filter, and return a RDD of MapWritable data elements
- readFile(FileSystem, String) - Static method in class org.apache.pirk.utils.HDFS
-
- readFile(FileSystem, Path) - Static method in class org.apache.pirk.utils.HDFS
-
- readFileHashSet(FileSystem, Path) - Static method in class org.apache.pirk.utils.HDFS
-
- readResultsFile(File) - Static method in class org.apache.pirk.test.utils.TestUtils
-
Converts the result file into an ArrayList of QueryResponseJSON objects
- readToArrayList(String) - Static method in class org.apache.pirk.utils.FileIOUtils
-
- readToArrayList(String, FileIOUtils.Callable<String>) - Static method in class org.apache.pirk.utils.FileIOUtils
-
- readToHashSet(String) - Static method in class org.apache.pirk.utils.FileIOUtils
-
- readToHashSet(String, FileIOUtils.Callable<String>) - Static method in class org.apache.pirk.utils.FileIOUtils
-
- recall(String, Class<T>) - Method in class org.apache.pirk.serialization.HadoopFileSystemStore
-
Retrieves the object stored at the given path name in HDFS.
- recall(Path, Class<T>) - Method in class org.apache.pirk.serialization.HadoopFileSystemStore
-
Retrieves the object stored at the given path in HDFS.
- recall(String, Class<T>) - Method in class org.apache.pirk.serialization.LocalFileSystemStore
-
Returns the object stored in the local file system at the given path.
- recall(File, Class<T>) - Method in class org.apache.pirk.serialization.LocalFileSystemStore
-
Returns the object stored in the local file system at the given file location.
- reduce(LongWritable, Iterable<Text>, Reducer<LongWritable, Text, LongWritable, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.ColumnMultReducer
-
- reduce(Text, Iterable<Text>, Reducer<Text, Text, Text, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.ExpTableReducer
-
- reduce(LongWritable, Iterable<Text>, Reducer<LongWritable, Text, LongWritable, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.FinalResponseReducer
-
- reduce(IntWritable, Iterable<BytesArrayWritable>, Reducer<IntWritable, BytesArrayWritable, LongWritable, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.RowCalcReducer
-
- reloadConfiguration() - Static method in class org.apache.pirk.encryption.ModPowAbstraction
-
- resetAll() - Method in class org.apache.pirk.responder.wideskies.spark.Accumulators
-
- Responder - Class in org.apache.pirk.responder.wideskies.standalone
-
Class to perform stand alone responder functionalities
- Responder(Query) - Constructor for class org.apache.pirk.responder.wideskies.standalone.Responder
-
- ResponderCLI - Class in org.apache.pirk.responder.wideskies
-
Class for parsing the command line options for the ResponderDriver
- ResponderCLI(String[]) - Constructor for class org.apache.pirk.responder.wideskies.ResponderCLI
-
Create and parse allowable options
- ResponderDriver - Class in org.apache.pirk.responder.wideskies
-
Driver class for the responder
- ResponderDriver() - Constructor for class org.apache.pirk.responder.wideskies.ResponderDriver
-
- ResponderPlugin - Interface in org.apache.pirk.responder.wideskies.spi
-
Interface which launches a responder
- ResponderProps - Class in org.apache.pirk.responder.wideskies
-
Properties constants and validation for the Responder
- ResponderProps() - Constructor for class org.apache.pirk.responder.wideskies.ResponderProps
-
- ResponderService - Class in org.apache.pirk.responder.wideskies
-
- Response - Class in org.apache.pirk.response.wideskies
-
Class to hold the encrypted response elements for the PIR query
- Response(QueryInfo) - Constructor for class org.apache.pirk.response.wideskies.Response
-
- RowCalcReducer - Class in org.apache.pirk.responder.wideskies.mapreduce
-
Reducer class to calculate the encrypted rows of the encrypted query
- RowCalcReducer() - Constructor for class org.apache.pirk.responder.wideskies.mapreduce.RowCalcReducer
-
- run(String[]) - Method in class org.apache.pirk.responder.wideskies.mapreduce.ComputeResponseTool
-
- run() - Method in class org.apache.pirk.responder.wideskies.mapreduce.MapReduceResponder
-
- run() - Method in class org.apache.pirk.responder.wideskies.spark.SparkResponder
-
- run() - Method in class org.apache.pirk.responder.wideskies.spark.streaming.SparkStreamingResponder
-
- run() - Method in interface org.apache.pirk.responder.wideskies.spi.ResponderPlugin
-
This method launches your framework responder.
- run() - Method in class org.apache.pirk.responder.wideskies.standalone.StandaloneResponder
-
- run() - Method in class org.apache.pirk.responder.wideskies.storm.StormResponder
-
- run(String) - Method in class org.apache.pirk.test.distributed.DistributedTestCLI
-
Determine if the argument was provided, which determines if a test should or should not be run
- run(String, String) - Method in class org.apache.pirk.test.distributed.DistributedTestCLI
-
Determine if the argument was provided for the selected option, which determines if a test should or should not be run
- runPirkTopology() - Static method in class org.apache.pirk.responder.wideskies.storm.PirkTopology
-
- runTests() - Method in class org.apache.pirk.wideskies.standalone.StandaloneTest
-