Constructor and Description |
---|
AccumuloQuery(DataStore<K,T> dataStore) |
AccumuloResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.accumulo.core.client.Scanner scanner) |
Modifier and Type | Class and Description |
---|---|
class |
AccumuloStore<K,T extends PersistentBase> |
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 | Class and Description |
---|---|
class |
AvroStore<K,T extends PersistentBase>
An adapter DataStore for binary-compatible Avro serializations.
|
class |
DataFileAvroStore<K,T extends PersistentBase>
DataFileAvroStore is file based store which uses Avro's
DataFile{Writer,Reader}'s as a backend.
|
Constructor and Description |
---|
CassandraQuery(DataStore<K,T> dataStore) |
CassandraResult(DataStore<K,T> dataStore,
Query<K,T> query) |
Modifier and Type | Class and Description |
---|---|
class |
CassandraStore<K,T extends PersistentBase>
CassandraStore is the primary class
responsible for directing Gora CRUD operations into Cassandra. |
Constructor and Description |
---|
HBaseQuery(DataStore<K,T> dataStore) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseStore<K,T extends PersistentBase>
DataStore for HBase.
|
Modifier and Type | Method and Description |
---|---|
static <K1,V1 extends Persistent,K2,V2> |
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> |
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,K2,V2 extends Persistent> |
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> |
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> |
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> |
GoraOutputFormat.setOutput(org.apache.hadoop.mapreduce.Job job,
DataStore<K,V> dataStore,
boolean reuseObjects)
Sets the output parameters for the job
|
Modifier and Type | Method and Description |
---|---|
static <K1,V1 extends Persistent,K2,V2> |
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> |
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> |
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> |
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> |
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
|
Constructor and Description |
---|
GoraRecordWriter(DataStore<K,Persistent> store,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Class and Description |
---|---|
class |
MemStore<K,T extends PersistentBase>
Memory based
DataStore implementation for tests. |
Constructor and Description |
---|
MemStore.MemQuery(DataStore<K,T> dataStore) |
MemStore.MemResult(DataStore<K,T> dataStore,
Query<K,T> query,
NavigableMap<K,T> map) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Query.setDataStore(DataStore<K,T> dataStore)
Sets the dataStore of this query.
|
Modifier and Type | Field and Description |
---|---|
protected DataStore<K,T> |
ResultBase.dataStore |
Modifier and Type | Method and Description |
---|---|
DataStore<K,T> |
ResultBase.getDataStore() |
DataStore<K,T> |
QueryBase.getDataStore() |
DataStore<K,T> |
PartitionQueryImpl.getDataStore() |
Modifier and Type | Method and Description |
---|---|
void |
QueryBase.setDataStore(DataStore<K,T> dataStore) |
Constructor and Description |
---|
QueryBase(DataStore<K,T> dataStore) |
ResultBase(DataStore<K,T> dataStore,
Query<K,T> query) |
Modifier and Type | Field and Description |
---|---|
protected DataStore<K,T> |
ResultWSBase.dataStore
Data store used
|
protected DataStore<K,T> |
QueryWSBase.dataStore
Data store used for this query
|
Modifier and Type | Method and Description |
---|---|
DataStore<K,T> |
ResultWSBase.getDataStore() |
DataStore<K,T> |
QueryWSBase.getDataStore() |
DataStore<K,T> |
PartitionWSQueryImpl.getDataStore() |
Modifier and Type | Method and Description |
---|---|
void |
QueryWSBase.setDataStore(DataStore<K,T> dataStore) |
Constructor and Description |
---|
QueryWSBase(DataStore<K,T> dataStore)
Constructor
|
ResultWSBase(DataStore<K,T> dataStore,
Query<K,T> query)
Constructor
|
Constructor and Description |
---|
SolrQuery(DataStore<K,T> dataStore) |
SolrResult(DataStore<K,T> dataStore,
Query<K,T> query,
org.apache.solr.client.solrj.SolrServer server,
int resultsSize) |
Modifier and Type | Class and Description |
---|---|
class |
SolrStore<K,T extends PersistentBase> |
Modifier and Type | Interface and Description |
---|---|
interface |
FileBackedDataStore<K,T extends Persistent>
FileBackedDataStore supplies necessary interfaces to set input
and output paths for data stored which are file based.
|
interface |
WebServiceBackedDataStore<K,T extends Persistent>
FileBackedDataStore supplies necessary interfaces to set input
and output paths for data stored which are file based.
|
Modifier and Type | Method and Description |
---|---|
static <D extends DataStore<K,T>,K,T extends Persistent> |
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> |
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> |
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> |
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> |
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> |
DataStoreFactory.setDefaultSchemaName(Properties properties,
Class<D> dataStoreClass,
String schemaName)
Sets the default schema name to be used by the datastore of the given class
|
Modifier and Type | Method and Description |
---|---|
static <K,T extends Persistent> |
DataStoreFactory.getDataStore(Class<K> keyClass,
Class<T> persistent,
org.apache.hadoop.conf.Configuration conf)
Instantiate the default
DataStore . |
static <K,T extends Persistent> |
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> |
DataStoreFactory.getDataStore(String dataStoreClass,
String keyClass,
String persistentClass,
org.apache.hadoop.conf.Configuration conf)
Instantiate a new
DataStore . |
Modifier and Type | Method and Description |
---|---|
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)
Looks for the
gora-<classname>-mapping.xml as a resource
on the classpath. |
static String |
DataStoreFactory.getOutputPath(Properties properties,
DataStore<?,?> store)
Returns the output path as read from the properties for file-backed data stores.
|
Modifier and Type | Class and Description |
---|---|
class |
DataStoreBase<K,T extends PersistentBase>
A Base class for Avro persistent
DataStore s. |
class |
FileBackedDataStoreBase<K,T extends PersistentBase>
Base implementations for
FileBackedDataStore methods. |
Modifier and Type | Class and Description |
---|---|
class |
WSBackedDataStoreBase<K,T extends Persistent>
Base implementations for
WebServiceBackedDataStore methods. |
class |
WSDataStoreBase<K,T extends Persistent>
A Base class for persistent objects
DataStore s. |
Modifier and Type | Method and Description |
---|---|
static <D extends DataStore<K,T>,K,T extends Persistent> |
WSDataStoreFactory.createDataStore(Class<D> dataStoreClass,
Class<K> keyClass,
Class<T> persistent,
Object auth)
Instantiate a new
DataStore . |
static <D extends DataStore<K,T>,K,T extends Persistent> |
WSDataStoreFactory.createDataStore(Class<D> dataStoreClass,
Class<K> keyClass,
Class<T> persistent,
Object auth,
Properties properties)
Instantiate a new
DataStore . |
static <D extends DataStore<K,T>,K,T extends Persistent> |
WSDataStoreFactory.createDataStore(Class<D> dataStoreClass,
Class<K> keyClass,
Class<T> persistent,
Object auth,
Properties properties,
String schemaName)
Instantiate a new
DataStore . |
static <D extends DataStore<K,T>,K,T extends Persistent> |
WSDataStoreFactory.createDataStore(Class<D> dataStoreClass,
Class<K> keyClass,
Class<T> persistent,
Object auth,
String schemaName)
Instantiate a new
DataStore . |
static <D extends DataStore<K,T>,K,T extends Persistent> |
WSDataStoreFactory.getDataStore(Class<D> dataStoreClass,
Class<K> keyClass,
Class<T> persistentClass,
Object auth)
Instantiate a new
DataStore . |
static <D extends DataStore<K,T>,K,T extends Persistent> |
WSDataStoreFactory.setDefaultSchemaName(Properties properties,
Class<D> dataStoreClass,
String schemaName)
Sets the default schema name to be used by the datastore of the given class
|
Modifier and Type | Method and Description |
---|---|
static <K,T extends Persistent> |
WSDataStoreFactory.getDataStore(Class<K> keyClass,
Class<T> persistent,
Object auth)
Instantiate the default
DataStore . |
static <K,T extends Persistent> |
WSDataStoreFactory.getDataStore(String dataStoreClass,
Class<K> keyClass,
Class<T> persistentClass,
Object auth)
Instantiate a new
DataStore . |
static <K,T extends Persistent> |
WSDataStoreFactory.getDataStore(String dataStoreClass,
String keyClass,
String persistentClass,
Object auth)
Instantiate a new
DataStore . |
Modifier and Type | Method and Description |
---|---|
static boolean |
WSDataStoreFactory.findBooleanProperty(Properties properties,
DataStore<?,?> store,
String baseKey,
String defaultValue) |
static String |
WSDataStoreFactory.findProperty(Properties properties,
DataStore<?,?> store,
String baseKey,
String defaultValue)
Tries to find a property with the given baseKey.
|
static String |
WSDataStoreFactory.findPropertyOrDie(Properties properties,
DataStore<?,?> store,
String baseKey)
Tries to find a property with the given baseKey.
|
static boolean |
WSDataStoreFactory.getAutoCreateSchema(Properties properties,
DataStore<?,?> store) |
static String |
WSDataStoreFactory.getDefaultSchemaName(Properties properties,
DataStore<?,?> store)
Gets the default schema name of a given store class
|
static String |
WSDataStoreFactory.getInputPath(Properties properties,
DataStore<?,?> store)
Returns the input path as read from the properties for file-backed data stores.
|
static String |
WSDataStoreFactory.getMappingFile(Properties properties,
DataStore<?,?> store,
String defaultValue) |
static String |
WSDataStoreFactory.getOutputPath(Properties properties,
DataStore<?,?> store)
Returns the output path as read from the properties for file-backed data stores.
|
Modifier and Type | Method and Description |
---|---|
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. |
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.