Serialized Form

Package cascading.flow.hadoop

Class cascading.flow.hadoop.HadoopFlowStep extends BaseFlowStep<JobConf> implements Serializable

Serialized Fields

mapperTraps

Map<K,V> mapperTraps

Field mapperTraps

reducerTraps

Map<K,V> reducerTraps

Field reducerTraps

Class cascading.flow.hadoop.MapReduceFlowStep extends HadoopFlowStep implements Serializable

Serialized Fields

jobConf

JobConf jobConf

Field jobConf

Package cascading.flow.hadoop.planner

Class cascading.flow.hadoop.planner.HadoopStepGraph extends FlowStepGraph<JobConf> implements Serializable

Package cascading.scheme.hadoop

Class cascading.scheme.hadoop.SequenceFile extends Scheme<JobConf,RecordReader,OutputCollector,Object[],Void> implements Serializable

Class cascading.scheme.hadoop.TextDelimited extends TextLine implements Serializable

Serialized Fields

delimitedParser

DelimitedParser delimitedParser

Field delimitedParser

skipHeader

boolean skipHeader

Field skipHeader

writeHeader

boolean writeHeader

Class cascading.scheme.hadoop.TextLine extends Scheme<JobConf,RecordReader,OutputCollector,Object[],Object[]> implements Serializable

serialVersionUID: 1L

Serialized Fields

sinkCompression

TextLine.Compress sinkCompression

Field sinkCompression

charsetName

String charsetName

Class cascading.scheme.hadoop.WritableSequenceFile extends SequenceFile implements Serializable

Serialized Fields

keyType

Class<T> keyType

valueType

Class<T> valueType

Package cascading.stats.hadoop

Class cascading.stats.hadoop.HadoopStepStats extends FlowStepStats implements Serializable

Serialized Fields

idCache

Map<K,V> idCache

numMapTasks

int numMapTasks

Field numMapTasks

numReduceTasks

int numReduceTasks

Field numReducerTasks

cachedCounters

Counters cachedCounters

Fields counters

timeouts

int timeouts

Fields timeouts

taskStats

Map<K,V> taskStats

Field taskStats

Package cascading.tap.hadoop

Class cascading.tap.hadoop.Dfs extends Hfs implements Serializable

Class cascading.tap.hadoop.GlobHfs extends MultiSourceTap<Hfs,JobConf,RecordReader> implements Serializable

Serialized Fields

pathPattern

String pathPattern

Field pathPattern

pathFilter

PathFilter pathFilter

Field pathFilter

Class cascading.tap.hadoop.Hfs extends Tap<JobConf,RecordReader,OutputCollector> implements Serializable

Serialized Fields

stringPath

String stringPath

Field stringPath

Class cascading.tap.hadoop.Lfs extends Hfs implements Serializable

Class cascading.tap.hadoop.PartitionTap extends BasePartitionTap<JobConf,RecordReader,OutputCollector> implements Serializable

Class cascading.tap.hadoop.TemplateTap extends BaseTemplateTap<JobConf,OutputCollector> implements Serializable

Package cascading.tap.hadoop.util

Class cascading.tap.hadoop.util.TempHfs extends Hfs implements Serializable

Serialized Fields

name

String name

Field name

schemeClass

Class<T> schemeClass

Field schemeClass

Package cascading.tuple.hadoop.collect

Class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap extends SpillableTupleMap implements Serializable

Serialized Fields

flowProcess

FlowProcess<Config> flowProcess

spillStrategy

Spillable.SpillStrategy spillStrategy

tupleCollectionFactory

TupleCollectionFactory<Config> tupleCollectionFactory

Package cascading.tuple.hadoop.util

Class cascading.tuple.hadoop.util.BytesComparator extends Object implements Serializable