java.math.BigInteger p
java.math.BigInteger q
java.math.BigInteger N
java.math.BigInteger NSquared
java.math.BigInteger lambdaN
java.math.BigInteger w
int bitLength
QueryInfo queryInfo
java.util.SortedMap<K,V> queryElements
java.util.Map<K,V> expTable
java.util.Map<K,V> expFileBasedLookup
java.math.BigInteger N
java.math.BigInteger NSquared
java.util.UUID identifier
int numSelectors
java.lang.String queryType
int hashBitSize
java.lang.String hashKey
int numBitsPerDataElement
int dataPartitionBitSize
int numPartitionsPerDataElement
boolean useExpLookupTable
boolean useHDFSExpLookupTable
boolean embedSelector
QuerySchema qSchema
org.apache.spark.Accumulator<T> numRecordsReceived
org.apache.spark.Accumulator<T> numRecordsFiltered
org.apache.spark.Accumulator<T> numRecordsAfterFilter
org.apache.spark.Accumulator<T> numHashes
org.apache.spark.Accumulator<T> numColumns
org.apache.spark.Accumulator<T> numBatches
org.apache.spark.broadcast.Broadcast<T> query
org.apache.spark.broadcast.Broadcast<T> queryInfo
org.apache.spark.broadcast.Broadcast<T> dataSchema
org.apache.spark.broadcast.Broadcast<T> querySchema
org.apache.spark.broadcast.Broadcast<T> useLocalCache
org.apache.spark.broadcast.Broadcast<T> limitHitsPerSelector
org.apache.spark.broadcast.Broadcast<T> maxHitsPerSelector
org.apache.spark.broadcast.Broadcast<T> expDir
org.apache.spark.broadcast.Broadcast<T> output
org.apache.spark.broadcast.Broadcast<T> maxBatches
Query query
Query query
Accumulators accum
Query query
QueryInfo queryInfo
boolean useLocalCache
boolean limitHitsPerSelector
int maxHitsPerSelector
Accumulators accum
Query query
boolean limitHitsPerSelector
int maxHitsPerSelector
java.util.HashMap<K,V> expTable
java.lang.String expOutDir
Query query
java.math.BigInteger NSquared
int maxValue
Accumulators accum
DataSchema dSchema
java.lang.Object filter
QueryInfo queryInfo
QuerySchema qSchema
DataSchema dSchema
BroadcastVars bVars
Accumulators accum
org.apache.storm.task.OutputCollector outputCollector
java.math.BigInteger nSquared
long numFlushSignals
java.lang.Long totalFlushSignals
java.util.Map<K,V> resultsMap
org.apache.storm.task.OutputCollector outputCollector
java.lang.Boolean limitHitsPerSelector
java.lang.Long maxHitsPerSelector
java.lang.Long totalEndSigs
int rowDivisions
java.lang.Boolean saltColumns
java.lang.Boolean splitPartitions
java.util.Random rand
java.util.Map<K,V> hitsByRow
java.util.Map<K,V> colIndexByRow
java.util.List<E> matrixElements
java.util.List<E> dataArray
int numEndSigs
boolean buffering
java.util.List<E> bufferedValues
org.apache.storm.task.OutputCollector outputCollector
Response response
java.lang.String outputFile
boolean hdfs
java.lang.Integer flushCounter
java.util.List<E> tuplesToAck
java.lang.Integer totalFlushSigs
LocalFileSystemStore localStore
HadoopFileSystemStore hadoopStore
java.util.Map<K,V> resultsMap
java.math.BigInteger nSquared
QuerySchema qSchema
boolean embedSelector
boolean splitPartitions
org.json.simple.JSONObject json
QueryInfo queryInfo
boolean initialized
QuerySchema qSchema
org.apache.storm.Config conf
QueryInfo queryInfo
java.util.TreeMap<K,V> responseElements
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
java.lang.String schemaName
java.util.Map<K,V> typeMap
java.util.Map<K,V> partitionerTypeMap
java.util.Set<E> arrayElements
PrimitiveTypePartitioner ptp
java.lang.String schemaName
java.lang.String dataSchemaName
java.lang.String selectorName
java.util.List<E> elementNames
java.lang.String filterTypeName
DataFilter filter
java.util.Set<E> filteredElementNames
int dataElementSize
java.util.HashMap<K,V> additionalFields
java.util.Set<E> filterSet
java.util.Set<E> stopList
org.json.simple.JSONObject jsonObj
DataSchema dSchema
QueryInfo queryInfo