- SELECTOR - Static variable in class org.apache.pirk.schema.response.QueryResponseJSON
-
- SerializationService - Class in org.apache.pirk.serialization
-
- SerializationService() - Constructor for class org.apache.pirk.serialization.SerializationService
-
- SerializationTest - Class in org.apache.pirk.serialization
-
- SerializationTest() - Constructor for class org.apache.pirk.serialization.SerializationTest
-
- setCSVOutput(String, String, String) - Static method in class org.apache.pirk.utils.CSVOutputUtils
-
- setCSVOutput(String, String, String, String) - Static method in class org.apache.pirk.utils.CSVOutputUtils
-
- setCSVOutput(Text, String, String, String) - Static method in class org.apache.pirk.utils.CSVOutputUtils
-
- setCSVOutput(Text, String, String, String, String) - Static method in class org.apache.pirk.utils.CSVOutputUtils
-
- setDataSchema(DataSchema) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setExpDir(String) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setExpFileBasedLookup(Map<Integer, String>) - Method in class org.apache.pirk.query.wideskies.Query
-
- setFullCSVLine(int, String, String, String) - Static method in class org.apache.pirk.utils.CSVOutputUtils
-
Used for testing
- setFullCSVLine(int, String, String, String, String) - Static method in class org.apache.pirk.utils.CSVOutputUtils
-
Used for testing
- setFullCSVLine(String, String, String, String) - Static method in class org.apache.pirk.utils.CSVOutputUtils
-
Used for testing
- setGeneralQueryResponseFields(QueryInfo) - Method in class org.apache.pirk.schema.response.QueryResponseJSON
-
Method to set the common query response fields
- setLimitHitsPerSelector(Boolean) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setMapping(String, Object) - Method in class org.apache.pirk.schema.response.QueryResponseJSON
-
Add a pair to the response object; checks the data schema if this QueryResponseJSON object was instantiated with schema checking (with a
QueryInfo object)
- setMaxBatches(Integer) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setMaxHitsPerSelector(Integer) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setOutput(String) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setProperty(String, String) - Static method in class org.apache.pirk.utils.SystemConfiguration
-
Sets the property to the given value.
- setQuery(Query) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setQueryInfo(QueryInfo) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setQuerySchema(QuerySchema) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- setResponseElements() - Method in class org.apache.pirk.responder.wideskies.standalone.Responder
-
- setResponseElements(TreeMap<Integer, BigInteger>) - Method in class org.apache.pirk.response.wideskies.Response
-
- setSelector(Object) - Method in class org.apache.pirk.schema.response.QueryResponseJSON
-
- setUp() - Method in class org.apache.pirk.benchmark.PaillierBenchmark.PaillierBenchmarkState
-
This sets up the state for the two separate benchmarks
- setup() - Static method in class org.apache.pirk.general.PaillierTest
-
- setup() - Static method in class org.apache.pirk.general.QueryParserUtilsTest
-
- setup(Mapper<LongWritable, Text, LongWritable, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.ColumnMultMapper
-
- setup(Reducer<LongWritable, Text, LongWritable, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.ColumnMultReducer
-
- setup(Mapper<LongWritable, Text, Text, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.ExpTableMapper
-
- setup(Reducer<Text, Text, Text, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.ExpTableReducer
-
- setup(Reducer<LongWritable, Text, LongWritable, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.FinalResponseReducer
-
- setup(Mapper<Text, MapWritable, IntWritable, BytesArrayWritable>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.HashSelectorsAndPartitionDataMapper
-
- setup(Reducer<IntWritable, BytesArrayWritable, LongWritable, Text>.Context) - Method in class org.apache.pirk.responder.wideskies.mapreduce.RowCalcReducer
-
- setUp() - Static method in class org.apache.pirk.serialization.SerializationTest
-
- setup() - Static method in class org.apache.pirk.wideskies.standalone.StandaloneTest
-
- setUseLocalCache(Boolean) - Method in class org.apache.pirk.responder.wideskies.spark.BroadcastVars
-
- SHORT - Static variable in class org.apache.pirk.schema.data.partitioner.PrimitiveTypePartitioner
-
- size() - Method in class org.apache.pirk.inputformat.hadoop.BytesArrayWritable
-
Returns the number of elements in the underlying array
- size() - Method in class org.apache.pirk.inputformat.hadoop.TextArrayWritable
-
Returns the number of elements in the underlying array
- sleep(long) - Method in class org.apache.pirk.storm.SystemTime
-
- SparkResponder - Class in org.apache.pirk.responder.wideskies.spark
-
Class to launch spark responder
- SparkResponder() - Constructor for class org.apache.pirk.responder.wideskies.spark.SparkResponder
-
- SparkStreamingResponder - Class in org.apache.pirk.responder.wideskies.spark.streaming
-
Class to launch stand alone responder
- SparkStreamingResponder() - Constructor for class org.apache.pirk.responder.wideskies.spark.streaming.SparkStreamingResponder
-
- SRCIP - Static variable in class org.apache.pirk.test.utils.Inputs
-
- StandaloneQuery - Class in org.apache.pirk.test.utils
-
- StandaloneQuery() - Constructor for class org.apache.pirk.test.utils.StandaloneQuery
-
- StandaloneResponder - Class in org.apache.pirk.responder.wideskies.standalone
-
Class to launch stand alone responder
- StandaloneResponder() - Constructor for class org.apache.pirk.responder.wideskies.standalone.StandaloneResponder
-
- StandaloneTest - Class in org.apache.pirk.wideskies.standalone
-
Functional test suite for stand alone testing - non Spark applications
- StandaloneTest() - Constructor for class org.apache.pirk.wideskies.standalone.StandaloneTest
-
- start() - Method in class org.apache.pirk.responder.wideskies.spark.streaming.ComputeStreamingResponse
-
Method to start the computation
- STOPGRACEFULLY - Static variable in class org.apache.pirk.responder.wideskies.ResponderProps
-
- STOPLISTFILE - Static variable in class org.apache.pirk.responder.wideskies.ResponderProps
-
- StopListFilter - Class in org.apache.pirk.schema.query.filter
-
Filter class to filter data elements based upon a stoplist applied to specified field elements
- StopListFilter(Set<String>, Set<String>) - Constructor for class org.apache.pirk.schema.query.filter.StopListFilter
-
- StopListUtils - Class in org.apache.pirk.utils
-
Utilities for stop listing data items/elements
- StopListUtils() - Constructor for class org.apache.pirk.utils.StopListUtils
-
- Storable - Interface in org.apache.pirk.serialization
-
Marker interface for objects that can be stored in a storage service.
- store(String, Storable) - Method in class org.apache.pirk.serialization.HadoopFileSystemStore
-
Store the given object into the HDFS file system at the given path name.
- store(Path, Storable) - Method in class org.apache.pirk.serialization.HadoopFileSystemStore
-
Store the given object at into the HDFS file system at the given path.
- store(String, Storable) - Method in class org.apache.pirk.serialization.LocalFileSystemStore
-
Stores the given object at the given path.
- store(File, Storable) - Method in class org.apache.pirk.serialization.LocalFileSystemStore
-
Stores the given object at the given file location.
- StormConstants - Class in org.apache.pirk.responder.wideskies.storm
-
- StormConstants() - Constructor for class org.apache.pirk.responder.wideskies.storm.StormConstants
-
- StormResponder - Class in org.apache.pirk.responder.wideskies.storm
-
Class to launch Storm responder
- StormResponder() - Constructor for class org.apache.pirk.responder.wideskies.storm.StormResponder
-
- StormUtils - Class in org.apache.pirk.responder.wideskies.storm
-
Utils class for the Storm implementation of Wideskies
- StormUtils() - Constructor for class org.apache.pirk.responder.wideskies.storm.StormUtils
-
- STRING - Static variable in class org.apache.pirk.schema.data.partitioner.PrimitiveTypePartitioner
-
- StringUtils - Class in org.apache.pirk.utils
-
Pirk-specific string utilities
- StringUtils() - Constructor for class org.apache.pirk.utils.StringUtils
-
- stripWildcard(String) - Static method in class org.apache.pirk.utils.EpochDateParser
-
- SystemConfiguration - Class in org.apache.pirk.utils
-
Manages system properties.
- SystemConfiguration() - Constructor for class org.apache.pirk.utils.SystemConfiguration
-
- SystemTime - Class in org.apache.pirk.storm
-
- SystemTime() - Constructor for class org.apache.pirk.storm.SystemTime
-