Modifier and Type | Method and Description |
---|---|
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.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
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
DataSchema |
BroadcastVars.getDataSchema() |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastVars.setDataSchema(DataSchema dSchemaIn) |
Modifier and Type | Method and Description |
---|---|
static DataSchema |
DataSchemaRegistry.get(java.lang.String schemaName)
Returns the data schema with the given name.
|
DataSchema |
DataSchemaLoader.loadSchema(java.io.InputStream stream)
Returns the data schema as defined in XML format on the given stream.
|
static DataSchema |
DataSchemaRegistry.put(DataSchema schema)
Adds the given data schema to the registry.
|
Modifier and Type | Method and Description |
---|---|
static DataSchema |
DataSchemaRegistry.put(DataSchema schema)
Adds the given data schema to the registry.
|
Modifier and Type | Method and Description |
---|---|
boolean |
StopListFilter.filterDataElement(org.apache.hadoop.io.MapWritable dataElement,
DataSchema dSchema) |
boolean |
DataFilter.filterDataElement(org.apache.hadoop.io.MapWritable dataElement,
DataSchema dSchema)
Filter the data element
|
Modifier and Type | Method and Description |
---|---|
static boolean |
QueryParserUtils.checkRangeQuery(boolean inclusive,
java.lang.String field,
java.lang.String query,
java.lang.String value,
DataSchema dataSchema)
Method to handle ranges queries
|
static boolean |
QueryParserUtils.checkRecord(java.lang.String uriQuery,
java.util.Map<java.lang.String,java.lang.Object> doc,
DataSchema dataSchema) |
static boolean |
QueryParserUtils.checkRecord(java.lang.String uriQuery,
org.apache.hadoop.io.MapWritable doc,
DataSchema dataSchema)
Given a URI query string, checks to see if the given document satisfies the query
|
static boolean |
QueryParserUtils.checkRecordWritableArrayWritable(java.lang.String uriQuery,
org.apache.hadoop.io.MapWritable doc,
DataSchema dataSchema) |
static java.util.Map<java.lang.String,java.lang.Object> |
StringUtils.jsonStringToMap(java.lang.String jsonString,
DataSchema dataSchema)
Method to take an input json string and output a Map
|
static org.apache.hadoop.io.MapWritable |
StringUtils.jsonStringToMapWritableWithArrayWritable(java.lang.String jsonString,
DataSchema dataSchema)
Method to take an input json string and output a MapWritable with arrays as WritableArrayWritable objects
|
static org.apache.hadoop.io.MapWritable |
StringUtils.jsonStringToMapWritableWithWritableArrayWritable(java.lang.String jsonString,
DataSchema dataSchema)
Method to take an input json string and output a MapWritable with arrays as WritableArrayWritable objects
|