Package | Description |
---|---|
org.apache.pirk.query.wideskies | |
org.apache.pirk.responder.wideskies.common | |
org.apache.pirk.responder.wideskies.spark | |
org.apache.pirk.schema.query |
Modifier and Type | Method and Description |
---|---|
QuerySchema |
QueryInfo.getQuerySchema() |
Modifier and Type | Method and Description |
---|---|
void |
QueryInfo.addQuerySchema(QuerySchema qSchemaIn) |
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.getSelectorByQueryType(org.apache.hadoop.io.MapWritable dataMap,
QuerySchema qSchema,
DataSchema dSchema)
Pulls the correct selector from the MapWritable data element given the queryType
|
static java.lang.String |
QueryUtils.getSelectorByQueryTypeJSON(QuerySchema qSchema,
org.json.simple.JSONObject dataMap)
Pulls the correct selector from the JSONObject data element given the queryType
|
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 |
---|---|
static scala.Tuple2<java.lang.Integer,java.util.List<java.math.BigInteger>> |
HashSelectorAndPartitionData.hashSelectorAndFormPartitions(org.json.simple.JSONObject json,
QueryInfo queryInfo,
QuerySchema qSchema) |
static scala.Tuple2<java.lang.Integer,BytesArrayWritable> |
HashSelectorAndPartitionData.hashSelectorAndFormPartitions(org.apache.hadoop.io.MapWritable dataElement,
QuerySchema qSchema,
DataSchema dSchema,
QueryInfo queryInfo) |
static scala.Tuple2<java.lang.Integer,java.util.List<java.math.BigInteger>> |
HashSelectorAndPartitionData.hashSelectorAndFormPartitionsBigInteger(org.apache.hadoop.io.MapWritable dataElement,
QuerySchema qSchema,
DataSchema dSchema,
QueryInfo queryInfo) |
Modifier and Type | Method and Description |
---|---|
QuerySchema |
BroadcastVars.getQuerySchema() |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastVars.setQuerySchema(QuerySchema qSchemaIn) |
Modifier and Type | Method and Description |
---|---|
static QuerySchema |
QuerySchemaRegistry.get(java.lang.String schemaName)
Returns the query schema with the given name.
|
QuerySchema |
QuerySchemaLoader.loadSchema(java.io.InputStream stream)
Returns the query schema as defined in XML format on the given stream.
|
static QuerySchema |
QuerySchemaRegistry.put(QuerySchema schema)
Adds the given query schema to the registry.
|
Modifier and Type | Method and Description |
---|---|
static QuerySchema |
QuerySchemaRegistry.put(QuerySchema schema)
Adds the given query schema to the registry.
|