Serialized Form

Package datafu.hourglass.jobs

Class datafu.hourglass.jobs.MaxInputDataExceededException extends java.lang.Throwable implements Serializable

Package datafu.hourglass.mapreduce

Class datafu.hourglass.mapreduce.CollapsingCombiner extends ObjectReducer implements Serializable

Serialized Fields

_accumulator

Accumulator<In,Out> _accumulator

_reusePreviousOutput

boolean _reusePreviousOutput

_schemas

PartitionCollapsingSchemas _schemas

_beginTime

long _beginTime

_endTime

long _endTime

Class datafu.hourglass.mapreduce.CollapsingMapper extends ObjectMapper implements Serializable

Serialized Fields

_reusePreviousOutput

boolean _reusePreviousOutput

_schemas

PartitionCollapsingSchemas _schemas

_mapper

Mapper<In,OutKey,OutVal> _mapper

Class datafu.hourglass.mapreduce.CollapsingReducer extends ObjectReducer implements Serializable

Serialized Fields

_beginTime

long _beginTime

_endTime

long _endTime

_newAccumulator

Accumulator<In,Out> _newAccumulator

_oldAccumulator

Accumulator<In,Out> _oldAccumulator

_merger

Merger<T> _merger

_oldMerger

Merger<T> _oldMerger

_reusePreviousOutput

boolean _reusePreviousOutput

_schemas

PartitionCollapsingSchemas _schemas

Class datafu.hourglass.mapreduce.PartitioningCombiner extends ObjectReducer implements Serializable

Serialized Fields

accumulator

Accumulator<In,Out> accumulator

Class datafu.hourglass.mapreduce.PartitioningMapper extends ObjectMapper implements Serializable

Serialized Fields

_mapper

Mapper<In,OutKey,OutVal> _mapper

_schemas

PartitionPreservingSchemas _schemas

Class datafu.hourglass.mapreduce.PartitioningReducer extends ObjectReducer implements Serializable

Serialized Fields

_schemas

PartitionPreservingSchemas _schemas

accumulator

Accumulator<In,Out> accumulator

Package datafu.hourglass.model

Package datafu.hourglass.schemas

Class datafu.hourglass.schemas.PartitionCollapsingSchemas extends java.lang.Object implements Serializable

Serialized Fields

_outputSchemaName

java.lang.String _outputSchemaName

_outputSchemaNamespace

java.lang.String _outputSchemaNamespace

conf

java.util.Map<K,V> conf

_inputSchemas

java.util.Map<K,V> _inputSchemas

Class datafu.hourglass.schemas.PartitionPreservingSchemas extends java.lang.Object implements Serializable

Serialized Fields

_outputSchemaName

java.lang.String _outputSchemaName

_outputSchemaNamespace

java.lang.String _outputSchemaNamespace

conf

java.util.Map<K,V> conf

_inputSchemas

java.util.Map<K,V> _inputSchemas