Modifier and Type | Class and Description |
---|---|
class |
AccumuloQuery<K,T extends PersistentBase> |
Constructor and Description |
---|
AccumuloResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.accumulo.core.client.Scanner scanner) |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
AccumuloStore.newQuery() |
Modifier and Type | Method and Description |
---|---|
long |
AccumuloStore.deleteByQuery(Query<K,T> query) |
Result<K,T> |
AccumuloStore.execute(Query<K,T> query) |
List<PartitionQuery<K,T>> |
AccumuloStore.getPartitions(Query<K,T> query) |
Modifier and Type | Class and Description |
---|---|
class |
AvroQuery<K,T extends PersistentBase>
A simple Query implementation for Avro.
|
Constructor and Description |
---|
DataFileAvroResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.avro.file.DataFileReader<T> reader) |
DataFileAvroResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.avro.file.DataFileReader<T> reader,
org.apache.avro.file.SeekableInput in,
long start,
long length) |
Modifier and Type | Method and Description |
---|---|
long |
AvroStore.deleteByQuery(Query<K,T> query) |
protected Result<K,T> |
DataFileAvroStore.executeQuery(Query<K,T> query) |
protected Result<K,T> |
AvroStore.executeQuery(Query<K,T> query)
Executes a normal Query reading the whole data.
|
Modifier and Type | Class and Description |
---|---|
class |
CassandraQuery<K,T extends PersistentBase> |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
CassandraQuery.getQuery() |
Modifier and Type | Method and Description |
---|---|
void |
CassandraQuery.setQuery(Query<K,T> query) |
Constructor and Description |
---|
CassandraResult(DataStore<K,T> dataStore,
Query<K,T> query) |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
CassandraStore.newQuery() |
Modifier and Type | Method and Description |
---|---|
long |
CassandraStore.deleteByQuery(Query<K,T> query) |
Result<K,T> |
CassandraStore.execute(Query<K,T> query)
When executing Gora Queries in Cassandra we query the Cassandra keyspace by families.
|
Map<String,List<String>> |
CassandraClient.getFamilyMap(Query<K,T> query)
Select the families that contain at least one column mapped to a query field.
|
List<PartitionQuery<K,T>> |
CassandraStore.getPartitions(Query<K,T> query) |
Map<String,String> |
CassandraClient.getReverseMap(Query<K,T> query)
Select the field names according to the column names, which format
if fully qualified: "family:column"
|
Modifier and Type | Class and Description |
---|---|
class |
HBaseQuery<K,T extends PersistentBase>
HBase specific implementation of the
Query interface. |
Constructor and Description |
---|
HBaseGetResult(HBaseStore<K,T> dataStore,
Query<K,T> query,
org.apache.hadoop.hbase.client.Result result) |
HBaseResult(HBaseStore<K,T> dataStore,
Query<K,T> query) |
HBaseScannerResult(HBaseStore<K,T> dataStore,
Query<K,T> query,
org.apache.hadoop.hbase.client.ResultScanner scanner) |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
HBaseStore.newQuery() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.client.ResultScanner |
HBaseStore.createScanner(Query<K,T> query) |
long |
HBaseStore.deleteByQuery(Query<K,T> query) |
Result<K,T> |
HBaseStore.execute(Query<K,T> query) |
List<PartitionQuery<K,T>> |
HBaseStore.getPartitions(Query<K,T> query) |
Modifier and Type | Field and Description |
---|---|
protected Query<K,T> |
GoraRecordReader.query |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
GoraInputFormat.getQuery(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
static <K1,V1 extends Persistent,K2,V2> |
GoraMapper.initMapperJob(org.apache.hadoop.mapreduce.Job job,
Query<K1,V1> query,
DataStore<K1,V1> dataStore,
Class<K2> outKeyClass,
Class<V2> outValueClass,
Class<? extends GoraMapper> mapperClass,
boolean reuseObjects)
Initializes the Mapper, and sets input parameters for the job
|
static <K1,V1 extends Persistent,K2,V2> |
GoraMapper.initMapperJob(org.apache.hadoop.mapreduce.Job job,
Query<K1,V1> query,
DataStore<K1,V1> dataStore,
Class<K2> outKeyClass,
Class<V2> outValueClass,
Class<? extends GoraMapper> mapperClass,
Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass,
boolean reuseObjects)
Initializes the Mapper, and sets input parameters for the job
|
static <K1,V1 extends Persistent> |
GoraInputFormat.setInput(org.apache.hadoop.mapreduce.Job job,
Query<K1,V1> query,
boolean reuseObjects)
Sets the input parameters for the job
|
static <K1,V1 extends Persistent> |
GoraInputFormat.setInput(org.apache.hadoop.mapreduce.Job job,
Query<K1,V1> query,
DataStore<K1,V1> dataStore,
boolean reuseObjects)
Sets the input parameters for the job
|
static <K,T extends Persistent> |
GoraInputFormat.setQuery(org.apache.hadoop.mapreduce.Job job,
Query<K,T> query) |
Constructor and Description |
---|
GoraRecordReader(Query<K,T> query,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Class and Description |
---|---|
static class |
MemStore.MemQuery<K,T extends PersistentBase> |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
MemStore.newQuery() |
Modifier and Type | Method and Description |
---|---|
long |
MemStore.deleteByQuery(Query<K,T> query) |
Result<K,T> |
MemStore.execute(Query<K,T> query) |
List<PartitionQuery<K,T>> |
MemStore.getPartitions(Query<K,T> query) |
Constructor and Description |
---|
MemStore.MemResult(DataStore<K,T> dataStore,
Query<K,T> query,
NavigableMap<K,T> map) |
Modifier and Type | Class and Description |
---|---|
class |
MongoDBQuery<K,T extends PersistentBase>
MongoDB specific implementation of the
Query interface. |
Modifier and Type | Method and Description |
---|---|
static com.mongodb.DBObject |
MongoDBQuery.toDBQuery(Query<?,?> query)
Compute the query itself.
|
Constructor and Description |
---|
MongoDBResult(DataStore<K,T> dataStore,
Query<K,T> query) |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
MongoStore.newQuery()
Create a new
Query to query the datastore. |
Modifier and Type | Method and Description |
---|---|
long |
MongoStore.deleteByQuery(Query<K,T> query) |
Result<K,T> |
MongoStore.execute(Query<K,T> query)
Execute the query and return the result.
|
List<PartitionQuery<K,T>> |
MongoStore.getPartitions(Query<K,T> query)
Partitions the given query and returns a list of PartitionQuerys, which
will execute on local data.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PartitionQuery<K,T extends Persistent>
PartitionQuery divides the results of the Query to multi partitions, so that
queries can be run locally on the nodes that hold the data.
|
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
Result.getQuery()
Returns the Query object for this Result.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSplitPartitionQuery<K,T extends PersistentBase>
Keeps a
FileSplit to represent the partition boundaries. |
class |
PartitionQueryImpl<K,T extends PersistentBase>
Implementation for
PartitionQuery . |
class |
QueryBase<K,T extends PersistentBase>
Base class for Query implementations.
|
Modifier and Type | Field and Description |
---|---|
protected Query<K,T> |
PartitionQueryImpl.baseQuery |
protected Query<K,T> |
ResultBase.query |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
PartitionQueryImpl.getBaseQuery() |
Query<K,T> |
ResultBase.getQuery() |
Constructor and Description |
---|
FileSplitPartitionQuery(Query<K,T> baseQuery,
org.apache.hadoop.mapreduce.lib.input.FileSplit split) |
PartitionQueryImpl(Query<K,T> baseQuery,
K startKey,
K endKey,
String... locations) |
PartitionQueryImpl(Query<K,T> baseQuery,
String... locations) |
ResultBase(DataStore<K,T> dataStore,
Query<K,T> query) |
Modifier and Type | Class and Description |
---|---|
class |
PartitionWSQueryImpl<K,T extends Persistent>
Webservices implementation for
PartitionQuery . |
class |
QueryWSBase<K,T extends Persistent>
Base class for Query implementations.
|
Modifier and Type | Field and Description |
---|---|
protected Query<K,T> |
PartitionWSQueryImpl.baseQuery
Base query
|
protected Query<K,T> |
ResultWSBase.query
Query for obtaining this result
|
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
PartitionWSQueryImpl.getBaseQuery()
Gets the base query to be used
|
Query<K,T> |
ResultWSBase.getQuery() |
Constructor and Description |
---|
PartitionWSQueryImpl(Query<K,T> baseQuery,
K startKey,
K endKey,
String... locations)
Constructor
|
PartitionWSQueryImpl(Query<K,T> baseQuery,
String... locations)
Constructor
|
ResultWSBase(DataStore<K,T> dataStore,
Query<K,T> query)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
SolrQuery<K,T extends PersistentBase> |
Constructor and Description |
---|
SolrResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.solr.client.solrj.SolrServer server,
int resultsSize) |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
SolrStore.newQuery() |
Modifier and Type | Method and Description |
---|---|
long |
SolrStore.deleteByQuery(Query<K,T> query) |
Result<K,T> |
SolrStore.execute(Query<K,T> query) |
List<PartitionQuery<K,T>> |
SolrStore.getPartitions(Query<K,T> query) |
Modifier and Type | Method and Description |
---|---|
Query<K,T> |
DataStore.newQuery()
Constructs and returns a new Query.
|
Modifier and Type | Method and Description |
---|---|
long |
DataStore.deleteByQuery(Query<K,T> query)
Deletes all the objects matching the query.
|
Result<K,T> |
DataStore.execute(Query<K,T> query)
Executes the given query and returns the results.
|
List<PartitionQuery<K,T>> |
DataStore.getPartitions(Query<K,T> query)
Partitions the given query and returns a list of
PartitionQuery s,
which will execute on local data. |
Modifier and Type | Method and Description |
---|---|
Result<K,T> |
FileBackedDataStoreBase.execute(Query<K,T> query) |
protected abstract Result<K,T> |
FileBackedDataStoreBase.executeQuery(Query<K,T> query)
Executes a normal Query reading the whole data.
|
List<PartitionQuery<K,T>> |
FileBackedDataStoreBase.getPartitions(Query<K,T> query) |
Modifier and Type | Method and Description |
---|---|
Result<K,T> |
WSBackedDataStoreBase.execute(Query<K,T> query) |
protected abstract Result<K,T> |
WSBackedDataStoreBase.executeQuery(Query<K,T> query)
Executes a normal Query reading the whole data.
|
Copyright © 2010-2015 The Apache Software Foundation. All Rights Reserved.