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.BaseHadoopStepStats extends FlowStepStats implements Serializable

Serialized Fields

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

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

Serialized Fields

idCache

Map<K,V> idCache

Package cascading.tap.hadoop

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

Class cascading.tap.hadoop.DistCacheTap extends DecoratorTap<Void,JobConf,RecordReader,OutputCollector> 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

Class cascading.tuple.hadoop.util.CoGroupingPartitioner extends HasherPartitioner implements Serializable

Class cascading.tuple.hadoop.util.GroupingPartitioner extends HasherPartitioner implements Serializable

Class cascading.tuple.hadoop.util.GroupingSortingPartitioner extends HasherPartitioner implements Serializable

Class cascading.tuple.hadoop.util.HasherPartitioner extends TupleHasher implements Serializable

Serialized Fields

comparators

Comparator<T>[] comparators