Modifier and Type | Class and Description |
---|---|
class |
HectorUtils<K,T extends Persistent>
This class it not thread safe.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Filter<K,T extends Persistent>
Defines filtering (possibly including modification) of rows.
|
Modifier and Type | Class and Description |
---|---|
class |
GoraMapper<K1,V1 extends Persistent,K2,V2>
Base class for Gora based
Mapper s. |
class |
GoraOutputFormat<K,T extends Persistent>
OutputFormat for Hadoop jobs that want to store the job outputs
to a Gora store. |
class |
GoraReducer<K1,V1,K2,V2 extends Persistent>
Base class for Gora based
Reducer s. |
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 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,
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,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,
Class<? extends DataStore<K1,V1>> dataStoreClass,
Class<K1> inKeyClass,
Class<V1> inValueClass,
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,
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,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
|
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
|
static <K,T extends Persistent> |
GoraInputFormat.setQuery(org.apache.hadoop.mapreduce.Job job,
Query<K,T> query) |
Modifier and Type | Method and Description |
---|---|
Persistent |
PersistentDeserializer.deserialize(Persistent persistent) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.io.serializer.Deserializer<Persistent> |
PersistentSerialization.getDeserializer(Class<Persistent> c) |
org.apache.hadoop.io.serializer.Serializer<Persistent> |
PersistentSerialization.getSerializer(Class<Persistent> c) |
Modifier and Type | Method and Description |
---|---|
Persistent |
PersistentDeserializer.deserialize(Persistent persistent) |
void |
PersistentSerializer.serialize(Persistent persistent)
Do the serialization of the
Persistent object |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.io.serializer.Deserializer<Persistent> |
PersistentSerialization.getDeserializer(Class<Persistent> c) |
org.apache.hadoop.io.serializer.Serializer<Persistent> |
PersistentSerialization.getSerializer(Class<Persistent> c) |
Constructor and Description |
---|
GoraRecordWriter(DataStore<K,Persistent> store,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
PersistentDeserializer(Class<? extends Persistent> c,
boolean reuseObjects) |
Modifier and Type | Method and Description |
---|---|
Persistent |
Persistent.newInstance()
Constructs a new instance of the object by using appropriate builder.
|
Modifier and Type | Class and Description |
---|---|
class |
BeanFactoryImpl<K,T extends Persistent>
A default implementation of the
BeanFactory interface. |
Modifier and Type | Class and Description |
---|---|
class |
PersistentBase
Base classs implementing common functionality for Persistent classes.
|
Modifier and Type | Class and Description |
---|---|
class |
BeanFactoryWSImpl<K,T extends Persistent>
A default implementation of the
BeanFactory interface. |
Modifier and Type | Class and Description |
---|---|
class |
PersistentWSBase
Base classs implementing common functionality for Web services
backed persistent classes.
|
Modifier and Type | Method and Description |
---|---|
Persistent |
PersistentWSBase.clone() |
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.
|
interface |
Query<K,T extends Persistent>
A query to a data store to retrieve objects.
|
interface |
Result<K,T extends Persistent>
A result to a
Query . |
Modifier and Type | Class and Description |
---|---|
class |
ResultBase<K,T extends Persistent>
Base class for
Result implementations. |
Modifier and Type | Field and Description |
---|---|
protected T |
ResultBase.persistent |
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.
|
class |
ResultWSBase<K,T extends Persistent>
Base class for
Result implementations. |
Modifier and Type | Field and Description |
---|---|
protected T |
ResultWSBase.persistent
Persistent object
|
Modifier and Type | Interface and Description |
---|---|
interface |
DataStore<K,T extends Persistent>
DataStore handles actual object persistence.
|
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 <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 . |
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 | 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 <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 . |
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 | Class and Description |
---|---|
class |
MetricDatum |
static class |
MetricDatum.Tombstone |
class |
Pageview |
static class |
Pageview.Tombstone |
Modifier and Type | Method and Description |
---|---|
static <T extends Persistent> |
ReflectionUtils.classBuilder(Class<T> clazz) |
static <T extends Persistent> |
AvroUtils.deepClonePersistent(T persistent) |
Modifier and Type | Method and Description |
---|---|
static String[] |
AvroUtils.getPersistentFieldNames(Persistent persistent)
Return the field names from a persistent object
|
Modifier and Type | Method and Description |
---|---|
static org.apache.avro.Schema |
AvroUtils.getSchema(Class<? extends Persistent> clazz)
Returns the schema of the class
|
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.