|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Package cascading.flow.hadoop |
---|
Class cascading.flow.hadoop.HadoopFlowStep extends BaseFlowStep<JobConf> implements Serializable |
---|
Serialized Fields |
---|
Map<K,V> mapperTraps
Map<K,V> reducerTraps
Class cascading.flow.hadoop.MapReduceFlowStep extends HadoopFlowStep implements Serializable |
---|
Serialized Fields |
---|
JobConf 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
boolean skipHeader
boolean writeHeader
Class cascading.scheme.hadoop.TextLine extends Scheme<JobConf,RecordReader,OutputCollector,Object[],Object[]> implements Serializable |
---|
serialVersionUID: 1L
Serialized Fields |
---|
TextLine.Compress sinkCompression
String charsetName
Class cascading.scheme.hadoop.WritableSequenceFile extends SequenceFile implements Serializable |
---|
Serialized Fields |
---|
Class<T> keyType
Class<T> valueType
Package cascading.stats.hadoop |
---|
Class cascading.stats.hadoop.BaseHadoopStepStats extends FlowStepStats implements Serializable |
---|
Serialized Fields |
---|
int numMapTasks
int numReduceTasks
Counters cachedCounters
int timeouts
Map<K,V> taskStats
Class cascading.stats.hadoop.HadoopStepStats extends BaseHadoopStepStats implements Serializable |
---|
Serialized Fields |
---|
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 |
---|
String pathPattern
PathFilter pathFilter
Class cascading.tap.hadoop.Hfs extends Tap<JobConf,RecordReader,OutputCollector> implements Serializable |
---|
Serialized Fields |
---|
String 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 |
---|
String name
Class<T> schemeClass
Package cascading.tuple.hadoop.collect |
---|
Class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap extends SpillableTupleMap implements Serializable |
---|
Serialized Fields |
---|
FlowProcess<Config> flowProcess
Spillable.SpillStrategy spillStrategy
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 |
---|
Comparator<T>[] comparators
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |