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

Uses of Interface
org.apache.gora.store.DataStore

Packages that use DataStore

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
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
org.apache.gora.tutorial.log

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

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

AccumuloQuery(DataStore<K,T> dataStore)

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

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

Classes in org.apache.gora.accumulo.store that implement DataStore

class

AccumuloStore<K,T extends Persistent>

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

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

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 DataStore in org.apache.gora.avro.store

Classes in org.apache.gora.avro.store that implement DataStore

class	AvroStore<K,T extends Persistent> An adapter DataStore for binary-compatible Avro serializations.
class	DataFileAvroStore<K,T extends Persistent> DataFileAvroStore is file based store which uses Avro's DataFile{Writer,Reader}'s as a backend.

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

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

CassandraQuery(DataStore<K,T> dataStore)

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

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

Classes in org.apache.gora.cassandra.store that implement DataStore

class

CassandraStore<K,T extends Persistent>

Uses of DataStore in org.apache.gora.examples

Methods in org.apache.gora.examples with parameters of type DataStore

static void

WebPageDataCreator.createWebPageData(DataStore<String,WebPage> dataStore)

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

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

long	QueryCounter.countQuery(DataStore<K,T> dataStore) Returns the number of results to the Query obtained by the QueryCounter.getQuery(DataStore) method.
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.
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.
Query<K,T>	QueryCounter.getQuery(DataStore<K,T> dataStore) Returns the Query to count the results of.
int	WordCount.wordCount(DataStore<String,WebPage> inStore, DataStore<String,TokenDatum> outStore)
int	WordCount.wordCount(DataStore<String,WebPage> inStore, DataStore<String,TokenDatum> outStore)

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

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

HBaseQuery(DataStore<K,T> dataStore)

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

Classes in org.apache.gora.hbase.store that implement DataStore

class

HBaseStore<K,T extends Persistent> DataStore for HBase.

Uses of DataStore in org.apache.gora.mapreduce

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

static <K1,V1 extends Persistent,K2,V2> void	GoraMapper.initMapperJob(org.apache.hadoop.mapreduce.Job job, 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, 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,K2,V2 extends Persistent> void	GoraReducer.initReducerJob(org.apache.hadoop.mapreduce.Job job, DataStore<K2,V2> dataStore, Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass) Initializes the Reducer, and sets output parameters for the job.
static <K1,V1,K2,V2 extends Persistent> void	GoraReducer.initReducerJob(org.apache.hadoop.mapreduce.Job job, DataStore<K2,V2> dataStore, Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass, boolean reuseObjects) Initializes the Reducer, and sets output 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,V extends Persistent> void	GoraOutputFormat.setOutput(org.apache.hadoop.mapreduce.Job job, DataStore<K,V> dataStore, boolean reuseObjects) Sets the output parameters for the job

Method parameters in org.apache.gora.mapreduce with type arguments of type DataStore

static <K1,V1 extends Persistent,K2,V2> void	GoraMapper.initMapperJob(org.apache.hadoop.mapreduce.Job job, Class<? extends DataStore<K1,V1>> dataStoreClass, Class<K1> inKeyClass, Class<V1> inValueClass, 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, Class<? extends DataStore<K1,V1>> dataStoreClass, Class<K1> inKeyClass, Class<V1> inValueClass, 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,K2,V2 extends Persistent> void	GoraReducer.initReducerJob(org.apache.hadoop.mapreduce.Job job, Class<? extends DataStore<K2,V2>> dataStoreClass, Class<K2> keyClass, Class<V2> persistentClass, Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass, boolean reuseObjects) Initializes the Reducer, and sets output parameters for the job.
static <K1,V1 extends Persistent> void	GoraInputFormat.setInput(org.apache.hadoop.mapreduce.Job job, Class<? extends DataStore<K1,V1>> dataStoreClass, Class<K1> inKeyClass, Class<V1> inValueClass, boolean reuseObjects) Sets the input parameters for the job
static <K,V extends Persistent> void	GoraOutputFormat.setOutput(org.apache.hadoop.mapreduce.Job job, Class<? extends DataStore> dataStoreClass, Class<K> keyClass, Class<V> persistentClass, boolean reuseObjects) Sets the output parameters for the job

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

GoraRecordWriter(DataStore<K,Persistent> store, org.apache.hadoop.mapreduce.TaskAttemptContext context)

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

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

class

MemStore<K,T extends Persistent> Memory based DataStore implementation for tests.

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

MemStore.MemQuery(DataStore<K,T> dataStore)

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

Uses of DataStore in org.apache.gora.query

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

DataStore<K,T>	Result.getDataStore() Returns the DataStore, that this Result is associated with.
DataStore<K,T>	Query.getDataStore() Returns the DataStore, that this Query is associated with.

Methods in org.apache.gora.query with parameters of type DataStore

void	Query.setDataStore(DataStore<K,T> dataStore) Sets the dataStore of this query.

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

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

protected DataStore<K,T>	ResultBase.dataStore
protected DataStore<K,T>	QueryBase.dataStore

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

DataStore<K,T>	ResultBase.getDataStore()
DataStore<K,T>	QueryBase.getDataStore()
DataStore<K,T>	PartitionQueryImpl.getDataStore()

Methods in org.apache.gora.query.impl with parameters of type DataStore

void	QueryBase.setDataStore(DataStore<K,T> dataStore)

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

QueryBase(DataStore<K,T> dataStore)

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

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

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

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

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

Classes in org.apache.gora.sql.store that implement DataStore

class

SqlStore<K,T extends Persistent> A DataStore implementation for RDBMS with a SQL interface.

Uses of DataStore in org.apache.gora.store

Subinterfaces of DataStore in org.apache.gora.store

interface

FileBackedDataStore<K,T extends Persistent> FileBackedDataStore supplies necessary interfaces to set input and output paths for data stored which are file based.

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

static <D extends DataStore<K,T>,K,T extends Persistent> D	DataStoreFactory.createDataStore(Class<D> dataStoreClass, Class<K> keyClass, Class<T> persistent, org.apache.hadoop.conf.Configuration conf) Instantiate a new DataStore.
static <D extends DataStore<K,T>,K,T extends Persistent> D	DataStoreFactory.createDataStore(Class<D> dataStoreClass, Class<K> keyClass, Class<T> persistent, org.apache.hadoop.conf.Configuration conf, Properties properties) Instantiate a new DataStore.
static <D extends DataStore<K,T>,K,T extends Persistent> D	DataStoreFactory.createDataStore(Class<D> dataStoreClass, Class<K> keyClass, Class<T> persistent, org.apache.hadoop.conf.Configuration conf, Properties properties, String schemaName) Instantiate a new DataStore.
static <D extends DataStore<K,T>,K,T extends Persistent> D	DataStoreFactory.createDataStore(Class<D> dataStoreClass, Class<K> keyClass, Class<T> persistent, org.apache.hadoop.conf.Configuration conf, String schemaName) Instantiate a new DataStore.
static <D extends DataStore<K,T>,K,T extends Persistent> D	DataStoreFactory.getDataStore(Class<D> dataStoreClass, Class<K> keyClass, Class<T> persistentClass, org.apache.hadoop.conf.Configuration conf) Instantiate a new DataStore.
static <D extends DataStore<K,T>,K,T extends Persistent> void	DataStoreFactory.setDefaultSchemaName(Properties properties, Class<D> dataStoreClass, String schemaName) Sets the default schema name to be used by the datastore of the given class

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

static <K,T extends Persistent> DataStore<K,T>	DataStoreFactory.getDataStore(Class<K> keyClass, Class<T> persistent, org.apache.hadoop.conf.Configuration conf) Instantiate the default DataStore.
static <K,T extends Persistent> DataStore<K,T>	DataStoreFactory.getDataStore(String dataStoreClass, Class<K> keyClass, Class<T> persistentClass, org.apache.hadoop.conf.Configuration conf) Instantiate a new DataStore.
static <K,T extends Persistent> DataStore<K,T>	DataStoreFactory.getDataStore(String dataStoreClass, String keyClass, String persistentClass, org.apache.hadoop.conf.Configuration conf) Instantiate a new DataStore.

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

static boolean	DataStoreFactory.findBooleanProperty(Properties properties, DataStore<?,?> store, String baseKey, String defaultValue)
static String	DataStoreFactory.findProperty(Properties properties, DataStore<?,?> store, String baseKey, String defaultValue) Tries to find a property with the given baseKey.
static String	DataStoreFactory.findPropertyOrDie(Properties properties, DataStore<?,?> store, String baseKey) Tries to find a property with the given baseKey.
static boolean	DataStoreFactory.getAutoCreateSchema(Properties properties, DataStore<?,?> store)
static String	DataStoreFactory.getDefaultSchemaName(Properties properties, DataStore<?,?> store) Gets the default schema name of a given store class
static String	DataStoreFactory.getInputPath(Properties properties, DataStore<?,?> store) Returns the input path as read from the properties for file-backed data stores.
static String	DataStoreFactory.getMappingFile(Properties properties, DataStore<?,?> store, String defaultValue)
static String	DataStoreFactory.getOutputPath(Properties properties, DataStore<?,?> store) Returns the output path as read from the properties for file-backed data stores.

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

Classes in org.apache.gora.store.impl that implement DataStore

class	DataStoreBase<K,T extends Persistent> A Base class for DataStores.
class	FileBackedDataStoreBase<K,T extends Persistent> Base implementations for FileBackedDataStore methods.

Uses of DataStore in org.apache.gora.tutorial.log

Methods in org.apache.gora.tutorial.log with parameters of type DataStore

org.apache.hadoop.mapreduce.Job	LogAnalytics.createJob(DataStore<Long,Pageview> inStore, DataStore<String,MetricDatum> outStore, int numReducer) Creates and returns the Job for submitting to Hadoop mapreduce.
org.apache.hadoop.mapreduce.Job	LogAnalytics.createJob(DataStore<Long,Pageview> inStore, DataStore<String,MetricDatum> outStore, int numReducer) Creates and returns the Job for submitting to Hadoop mapreduce.