This project has retired. For details please refer to its Attic page.

Uses of Interface
org.apache.gora.query.Query

Packages that use Query

org.apache.gora.accumulo.query
org.apache.gora.accumulo.store
org.apache.gora.avro.query
org.apache.gora.avro.store
org.apache.gora.cassandra.query
org.apache.gora.cassandra.store
org.apache.gora.examples.mapreduce
org.apache.gora.hbase.query
org.apache.gora.hbase.store
org.apache.gora.mapreduce
org.apache.gora.memory.store
org.apache.gora.query
org.apache.gora.query.impl
org.apache.gora.sql.query
org.apache.gora.sql.store
org.apache.gora.store
org.apache.gora.store.impl

Uses of Query in org.apache.gora.accumulo.query

Classes in org.apache.gora.accumulo.query that implement Query

class

AccumuloQuery<K,T extends Persistent>

Constructors in org.apache.gora.accumulo.query with parameters of type Query

AccumuloResult(DataStore<K,T> dataStore, Query<K,T> query, org.apache.accumulo.core.client.Scanner scanner)

Uses of Query in org.apache.gora.accumulo.store

Methods in org.apache.gora.accumulo.store that return Query

Query<K,T>

AccumuloStore.newQuery()

Methods in org.apache.gora.accumulo.store with parameters of type Query

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)

Uses of Query in org.apache.gora.avro.query

Classes in org.apache.gora.avro.query that implement Query

class

AvroQuery<K,T extends Persistent> A simple Query implementation for Avro.

Constructors in org.apache.gora.avro.query with parameters of type Query

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)

Uses of Query in org.apache.gora.avro.store

Methods in org.apache.gora.avro.store with parameters of type Query

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.

Uses of Query in org.apache.gora.cassandra.query

Classes in org.apache.gora.cassandra.query that implement Query

class

CassandraQuery<K,T extends Persistent>

Methods in org.apache.gora.cassandra.query that return Query

Query<K,T>

CassandraQuery.getQuery()

Methods in org.apache.gora.cassandra.query with parameters of type Query

void	CassandraQuery.setQuery(Query<K,T> query)

Constructors in org.apache.gora.cassandra.query with parameters of type Query

CassandraResult(DataStore<K,T> dataStore, Query<K,T> query)

Uses of Query in org.apache.gora.cassandra.store

Methods in org.apache.gora.cassandra.store that return Query

Query<K,T>

CassandraStore.newQuery()

Methods in org.apache.gora.cassandra.store with parameters of type Query

long	CassandraStore.deleteByQuery(Query<K,T> query)
Result<K,T>	CassandraStore.execute(Query<K,T> query)
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"

Uses of Query in org.apache.gora.examples.mapreduce

Methods in org.apache.gora.examples.mapreduce that return Query

Query<K,T>

QueryCounter.getQuery(DataStore<K,T> dataStore) Returns the Query to count the results of.

Methods in org.apache.gora.examples.mapreduce with parameters of type Query

long	QueryCounter.countQuery(DataStore<K,T> dataStore, Query<K,T> query) Returns the number of results to the Query
org.apache.hadoop.mapreduce.Job	QueryCounter.createJob(DataStore<K,T> dataStore, Query<K,T> query) Creates and returns the Job for submitting to Hadoop mapreduce.
org.apache.hadoop.mapreduce.Job	WordCount.createJob(DataStore<String,WebPage> inStore, Query<String,WebPage> query, DataStore<String,TokenDatum> outStore) Creates and returns the Job for submitting to Hadoop mapreduce.

Uses of Query in org.apache.gora.hbase.query

Classes in org.apache.gora.hbase.query that implement Query

class

HBaseQuery<K,T extends Persistent> HBase specific implementation of the Query interface.

Constructors in org.apache.gora.hbase.query with parameters of type Query

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)

Uses of Query in org.apache.gora.hbase.store

Methods in org.apache.gora.hbase.store that return Query

Query<K,T>

HBaseStore.newQuery()

Methods in org.apache.gora.hbase.store with parameters of type Query

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)

Uses of Query in org.apache.gora.mapreduce

Fields in org.apache.gora.mapreduce declared as Query

protected Query<K,T>

GoraRecordReader.query

Methods in org.apache.gora.mapreduce that return Query

Query<K,T>

GoraInputFormat.getQuery(org.apache.hadoop.conf.Configuration conf)

Methods in org.apache.gora.mapreduce with parameters of type Query

static <K1,V1 extends Persistent,K2,V2> void	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> void	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> void	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> void	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> void	GoraInputFormat.setQuery(org.apache.hadoop.mapreduce.Job job, Query<K,T> query)

Constructors in org.apache.gora.mapreduce with parameters of type Query

GoraRecordReader(Query<K,T> query, org.apache.hadoop.mapreduce.TaskAttemptContext context)

Uses of Query in org.apache.gora.memory.store

Classes in org.apache.gora.memory.store that implement Query

static class

MemStore.MemQuery<K,T extends Persistent>

Methods in org.apache.gora.memory.store that return Query

Query<K,T>

MemStore.newQuery()

Methods in org.apache.gora.memory.store with parameters of type Query

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)

Constructors in org.apache.gora.memory.store with parameters of type Query

MemStore.MemResult(DataStore<K,T> dataStore, Query<K,T> query, NavigableMap<K,T> map)

Uses of Query in org.apache.gora.query

Subinterfaces of Query in org.apache.gora.query

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.

Methods in org.apache.gora.query that return Query

Query<K,T>

Result.getQuery() Returns the Query object for this Result.

Uses of Query in org.apache.gora.query.impl

Classes in org.apache.gora.query.impl that implement Query

class	FileSplitPartitionQuery<K,T extends Persistent> Keeps a FileSplit to represent the partition boundaries.
class	PartitionQueryImpl<K,T extends Persistent> Implementation for PartitionQuery.
class	QueryBase<K,T extends Persistent> Base class for Query implementations.

Fields in org.apache.gora.query.impl declared as Query

protected Query<K,T>	PartitionQueryImpl.baseQuery
protected Query<K,T>	ResultBase.query

Methods in org.apache.gora.query.impl that return Query

Query<K,T>	PartitionQueryImpl.getBaseQuery()
Query<K,T>	ResultBase.getQuery()

Constructors in org.apache.gora.query.impl with parameters of type Query

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)

Uses of Query in org.apache.gora.sql.query

Classes in org.apache.gora.sql.query that implement Query

class

SqlQuery<K,T extends Persistent> Query implementation covering SQL queries

Constructors in org.apache.gora.sql.query with parameters of type Query

SqlResult(DataStore<K,T> dataStore, Query<K,T> query, ResultSet resultSet, PreparedStatement statement)

Uses of Query in org.apache.gora.sql.store

Methods in org.apache.gora.sql.store that return Query

Query<K,T>

SqlStore.newQuery()

Methods in org.apache.gora.sql.store with parameters of type Query

long	SqlStore.deleteByQuery(Query<K,T> query)
Result<K,T>	SqlStore.execute(Query<K,T> query)
List<PartitionQuery<K,T>>	SqlStore.getPartitions(Query<K,T> query)

Uses of Query in org.apache.gora.store

Methods in org.apache.gora.store that return Query

Query<K,T>

DataStore.newQuery() Constructs and returns a new Query.

Methods in org.apache.gora.store with parameters of type Query

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 PartitionQuerys, which will execute on local data.

Uses of Query in org.apache.gora.store.impl

Methods in org.apache.gora.store.impl with parameters of type Query

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)