Class Summary |
FakeResolvingDecoder |
Avro uses a ResolvingDecoder which resolves two schemas and converts records
written by one to the other, and validates the input. |
GoraInputFormat<K,T extends Persistent> |
InputFormat to fetch the input from Gora data stores. |
GoraInputSplit |
InputSplit using PartitionQuery s. |
GoraMapper<K1,V1 extends Persistent,K2,V2> |
Base class for Gora based Mapper s. |
GoraMapReduceUtils |
MapReduce related utilities for Gora |
GoraMapReduceUtils.HelperInputFormat<K,V> |
|
GoraOutputFormat<K,T extends Persistent> |
OutputFormat for Hadoop jobs that want to store the job outputs
to a Gora store. |
GoraRecordCounter |
|
GoraRecordReader<K,T extends Persistent> |
An adapter for Result to Hadoop RecordReader. |
GoraRecordWriter<K,T> |
Hadoop record writer that flushes the Gora datastore regularly. |
GoraReducer<K1,V1,K2,V2 extends Persistent> |
Base class for Gora based Reducer s. |
NullOutputCommitter |
An OutputCommitter that does nothing. |
PersistentDeserializer |
Hadoop deserializer using PersistentDatumReader
with BinaryDecoder . |
PersistentNonReusingSerialization |
|
PersistentSerialization |
|
PersistentSerializer |
Hadoop serializer using PersistentDatumWriter
with BinaryEncoder . |
StringComparator |
|
StringSerialization |
|