A B C D E F G H I J K L M N O P R S T U V W

A

accept(Class<?>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization
 
accept(Class<?>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
accept(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
Method accept implements Serialization.accept(Class).
accepts(Class<T>) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
accepts(Class<T>) - Method in interface cascading.flow.hadoop.util.ObjectSerializer
 
add(Tuple) - Method in class cascading.flow.hadoop.util.FalseCollection
 
addAll(Collection<? extends Tuple>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
addAttempt(TaskCompletionEvent) - Method in class cascading.stats.hadoop.HadoopSliceStats
 
addAttemptsToTaskStats(Map<String, HadoopSliceStats>, boolean) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
addAttemptsToTaskStats(Map<String, HadoopSliceStats>, boolean) - Method in class cascading.stats.hadoop.HadoopStepStats
 
addHadoopSerialization(String) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addHadoopSerialization adds a Hadoop serialization className to be used as properties.
addHadoopSerializations(List<String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addHadoopSerializations adds the Hadoop serialization classNames to be used as properties.
addInputFormat(JobConf, JobConf...) - Static method in class cascading.tap.hadoop.io.MultiInputFormat
Used to set the current JobConf with all sub jobs configurations.
addPropertiesTo(Properties) - Method in class cascading.tap.hadoop.HfsProps
 
addPropertiesTo(Properties) - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
addSerialization(Map<Object, Object>, String) - Static method in class cascading.tuple.hadoop.TupleSerialization
Deprecated. 
addSerialization(Map<Object, Object>, String) - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Adds the given className as a Hadoop IO serialization class.
addSerializationToken(Map<Object, Object>, int, String) - Static method in class cascading.tuple.hadoop.TupleSerialization
Deprecated. 
addSerializationToken(Map<Object, Object>, int, String) - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Adds the given token and className pair as a serialization token property.
addSerializationToken(int, String) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addSerializationToken adds the given integer token and classNames as a serialization properties.
addSerializationTokens(Map<Integer, String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addSerializationTokens adds the given integer tokens and classNames Map as a serialization properties.
addTaskStats(Map<String, HadoopSliceStats>, HadoopSliceStats.Kind, boolean) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
addTaskStats(Map<String, HadoopSliceStats>, HadoopSliceStats.Kind, boolean) - Method in class cascading.stats.hadoop.HadoopStepStats
 
addToClassPath(JobConf, List<String>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
Add to class path.
append(Path, int, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
applySourceConfInitIdentifiers(FlowProcess<JobConf>, JobConf, String...) - Method in class cascading.tap.hadoop.Hfs
 

B

BaseHadoopPlatform - Class in cascading.platform.hadoop
 
BaseHadoopPlatform() - Constructor for class cascading.platform.hadoop.BaseHadoopPlatform
 
BaseHadoopStepStats - Class in cascading.stats.hadoop
Class BaseHadoopStepStats is a base class to Hadoop specific statistics and methods to underlying Hadoop facilities.
BaseHadoopStepStats(FlowStep<JobConf>, ClientState) - Constructor for class cascading.stats.hadoop.BaseHadoopStepStats
 
BigDecimalSerialization - Class in cascading.tuple.hadoop
Class BigDecimalSerialization is an implementation of Hadoop's Serialization interface for use by BigDecimal instances.
BigDecimalSerialization() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization
 
BigDecimalSerialization.BigDecimalDeserializer - Class in cascading.tuple.hadoop
 
BigDecimalSerialization.BigDecimalDeserializer() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
BigDecimalSerialization.BigDecimalSerializer - Class in cascading.tuple.hadoop
 
BigDecimalSerialization.BigDecimalSerializer() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
bind(StreamGraph) - Method in class cascading.flow.hadoop.stream.HadoopCoGroupGate
 
bind(StreamGraph) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
BufferedInputStream - Class in cascading.tuple.hadoop.io
 
BufferedInputStream() - Constructor for class cascading.tuple.hadoop.io.BufferedInputStream
 
buildFlow(FlowDef) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
buildGraph() - Method in class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
buildGraph() - Method in class cascading.flow.hadoop.stream.HadoopReduceStreamGraph
 
BytesComparator - Class in cascading.tuple.hadoop.util
Class BytesComparator is used to compare arrays of bytes.
BytesComparator() - Constructor for class cascading.tuple.hadoop.util.BytesComparator
 
BytesSerialization - Class in cascading.tuple.hadoop
Class BytesSerialization is an implementation of Hadoop's Serialization interface for use by byte arrays (byte[]).
BytesSerialization() - Constructor for class cascading.tuple.hadoop.BytesSerialization
 
BytesSerialization.RawBytesDeserializer - Class in cascading.tuple.hadoop
 
BytesSerialization.RawBytesDeserializer() - Constructor for class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
BytesSerialization.RawBytesSerializer - Class in cascading.tuple.hadoop
 
BytesSerialization.RawBytesSerializer() - Constructor for class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 

C

cachedCounters() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
cachedCounters(boolean) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
captureDetail() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method captureDetail captures statistics task details and completion events.
captureDetail(boolean) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
cascading.flow.hadoop - package cascading.flow.hadoop
 
cascading.flow.hadoop.planner - package cascading.flow.hadoop.planner
 
cascading.flow.hadoop.stream - package cascading.flow.hadoop.stream
 
cascading.flow.hadoop.util - package cascading.flow.hadoop.util
 
cascading.platform.hadoop - package cascading.platform.hadoop
 
cascading.scheme.hadoop - package cascading.scheme.hadoop
 
cascading.stats.hadoop - package cascading.stats.hadoop
 
cascading.tap.hadoop - package cascading.tap.hadoop
 
cascading.tap.hadoop.io - package cascading.tap.hadoop.io
 
cascading.tap.hadoop.util - package cascading.tap.hadoop.util
 
cascading.tuple.hadoop - package cascading.tuple.hadoop
 
cascading.tuple.hadoop.collect - package cascading.tuple.hadoop.collect
 
cascading.tuple.hadoop.io - package cascading.tuple.hadoop.io
 
cascading.tuple.hadoop.util - package cascading.tuple.hadoop.util
 
CASCADING_SOURCE_PATH - Static variable in class cascading.tap.hadoop.io.MultiInputSplit
 
clean(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
Method clean removes any temporary files used by this FlowStep instance.
cleanup() - Method in class cascading.flow.hadoop.ProcessFlow
 
cleanupJob(JobConf) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
May only be called once.
cleanupTapMetaData(JobConf, Tap) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
Called from flow step to remove temp dirs
clear() - Method in class cascading.flow.hadoop.util.FalseCollection
 
clear() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
close() - Method in class cascading.flow.hadoop.FlowReducer
 
close() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
close() - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
close() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
 
close() - Method in class cascading.tap.hadoop.io.RecordReaderIterator
 
close() - Method in class cascading.tap.hadoop.io.TapOutputCollector
 
close() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
close() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
close() - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
close() - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
close() - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
close() - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 
close() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
close() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
closure - Variable in class cascading.flow.hadoop.stream.HadoopGroupGate
 
CoGroupingComparator - Class in cascading.tuple.hadoop.util
Class GroupingComparator is an implementation of RawComparator.
CoGroupingComparator() - Constructor for class cascading.tuple.hadoop.util.CoGroupingComparator
 
CoGroupingPartitioner - Class in cascading.tuple.hadoop.util
Class GroupingPartitioner is an implementation of Partitioner.
CoGroupingPartitioner() - Constructor for class cascading.tuple.hadoop.util.CoGroupingPartitioner
 
collect(Object, Object) - Method in class cascading.tap.hadoop.io.TapOutputCollector
Method collect writes the given values to the Tap this instance encapsulates.
collect(Object, Object) - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
collector - Variable in class cascading.flow.hadoop.stream.HadoopGroupGate
 
COMBINE_INPUT_FILES - Static variable in class cascading.tap.hadoop.HfsProps
Field COMBINE_INPUT_FILES
COMBINE_INPUT_FILES_SAFE_MODE - Static variable in class cascading.tap.hadoop.HfsProps
Field COMBINE_INPUT_FILES_SAFEMODE
COMBINE_INPUT_FILES_SIZE_MAX - Static variable in class cascading.tap.hadoop.HfsProps
Field COMBINE_INPUT_FILES_SIZE_MAX
combinedInputMaxSize - Variable in class cascading.tap.hadoop.HfsProps
 
combinedInputSafeMode - Variable in class cascading.tap.hadoop.HfsProps
 
CombineFileRecordReaderWrapper<K,V> - Class in cascading.tap.hadoop.io
A wrapper class for a record reader that handles a single file split.
CombineFileRecordReaderWrapper(CombineFileSplit, Configuration, Reporter, Integer) - Constructor for class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
commitTask(JobConf) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
copies all files from the taskoutputpath to the outputpath
compare(byte[], byte[]) - Method in class cascading.tuple.hadoop.util.BytesComparator
 
compare(BufferedInputStream, BufferedInputStream) - Method in class cascading.tuple.hadoop.util.BytesComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.CoGroupingComparator
 
compare(IndexTuple, IndexTuple) - Method in class cascading.tuple.hadoop.util.CoGroupingComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.DelegatingTupleElementComparator
 
compare(TupleInputStream, TupleInputStream) - Method in class cascading.tuple.hadoop.util.DelegatingTupleElementComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.GroupingComparator
 
compare(TuplePair, TuplePair) - Method in class cascading.tuple.hadoop.util.GroupingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.GroupingSortingComparator
 
compare(TuplePair, TuplePair) - Method in class cascading.tuple.hadoop.util.GroupingSortingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.IndexTupleCoGroupingComparator
 
compare(IndexTuple, IndexTuple) - Method in class cascading.tuple.hadoop.util.IndexTupleCoGroupingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.ReverseGroupingSortingComparator
 
compare(TuplePair, TuplePair) - Method in class cascading.tuple.hadoop.util.ReverseGroupingSortingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.ReverseTupleComparator
 
compare(Tuple, Tuple) - Method in class cascading.tuple.hadoop.util.ReverseTupleComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.TupleComparator
 
compare(Tuple, Tuple) - Method in class cascading.tuple.hadoop.util.TupleComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TupleElementComparator
 
compare(TupleInputStream, TupleInputStream) - Method in class cascading.tuple.hadoop.util.TupleElementComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TupleElementStreamComparator
 
compare(HadoopTupleInputStream, HadoopTupleInputStream) - Method in class cascading.tuple.hadoop.util.TupleElementStreamComparator
 
complete() - Method in class cascading.flow.hadoop.ProcessFlow
 
complete(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
configure(JobConf) - Method in class cascading.flow.hadoop.FlowMapper
 
configure(JobConf) - Method in class cascading.flow.hadoop.FlowReducer
 
configure(JobConf) - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
configure(JobConf) - Method in class cascading.tuple.hadoop.util.HasherPartitioner
 
contains(Object) - Method in class cascading.flow.hadoop.util.FalseCollection
 
containsAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
copyConfig(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
copyFromLocal(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
copyJobConf(Map<Object, Object>, JobConf) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner
Method copyJobConf adds the given JobConf values to the given properties object.
copyJobConf(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
copyProperties(JobConf, Map<Object, Object>) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner
Method copyProperties adds the given Map values to the given JobConf object.
copyToLocal(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
copyWith(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
countDownLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
COUNTER_TIMEOUT_PROPERTY - Static variable in class cascading.stats.hadoop.BaseHadoopStepStats
 
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
create(FlowProcess<JobConf>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
 
create(FlowProcess<JobConf>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
 
createCoGroupGate(CoGroup) - Method in class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
createCoGroupGate(CoGroup) - Method in class cascading.flow.hadoop.stream.HadoopReduceStreamGraph
 
createFlow(FlowDef) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
createFlowPlanner() - Method in class cascading.flow.hadoop.HadoopFlowConnector
 
createFlowStep(String, int) - Method in class cascading.flow.hadoop.planner.HadoopStepGraph
 
createFlowStepJob(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
createGroupByGate(GroupBy) - Method in class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
createGroupByGate(GroupBy) - Method in class cascading.flow.hadoop.stream.HadoopReduceStreamGraph
 
createHashJoinGate(HashJoin) - Method in class cascading.flow.hadoop.stream.HadoopReduceStreamGraph
 
createIterator(IndexTuple, Iterator<IndexTuple>) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
createJobConf(Map<Object, Object>) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner
Method createJobConf returns a new JobConf instance using the values in the given properties argument.
createJobConf(Map<Object, Object>, JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
createKey() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
createKey() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
createKeySet() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
createNonBlockingJoinGate(HashJoin) - Method in class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
createProperties(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
createResource(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
createSinks(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
createSinkStage(Tap) - Method in class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
createSinkStage(Tap) - Method in class cascading.flow.hadoop.stream.HadoopReduceStreamGraph
 
createSources(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
createStepStats(ClientState) - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
createTraps(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
createTupleCollection(Tuple) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
 
createTupleEntrySchemeCollector(FlowProcess<JobConf>, Tap, String, long) - Method in class cascading.tap.hadoop.PartitionTap
 
createTupleEntrySchemeCollector(FlowProcess<JobConf>, Tap, String) - Method in class cascading.tap.hadoop.TemplateTap
Deprecated.  
createTupleEntrySchemeIterator(FlowProcess<JobConf>, Tap, String, RecordReader) - Method in class cascading.tap.hadoop.PartitionTap
 
createTupleInputStream(File) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
createTupleMap() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
createTupleOutputStream(File) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
createValue() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
createValue() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 

D

decodeBytes(String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
DEFAULT_CHARSET - Static variable in class cascading.scheme.hadoop.TextDelimited
 
DEFAULT_CHARSET - Static variable in class cascading.scheme.hadoop.TextLine
 
DEFAULT_SOURCE_FIELDS - Static variable in class cascading.scheme.hadoop.TextLine
Field DEFAULT_SOURCE_FIELDS
defaultCodecs - Static variable in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
DelegatingTupleElementComparator - Class in cascading.tuple.hadoop.util
 
DelegatingTupleElementComparator(TupleSerialization) - Constructor for class cascading.tuple.hadoop.util.DelegatingTupleElementComparator
 
delete(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
Deprecated. 
delete(Path, boolean) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
deleteChildResource(JobConf, String) - Method in class cascading.tap.hadoop.Hfs
 
deleteResource(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
deleteSinkOnInit - Variable in class cascading.flow.hadoop.MapReduceFlow
Field deleteSinkOnInit
delimitedParser - Variable in class cascading.scheme.hadoop.TextDelimited
Field delimitedParser
deserialize(byte[], Class<T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
deserialize(byte[], Class<T>, boolean) - Method in interface cascading.flow.hadoop.util.ObjectSerializer
 
deserialize(BigDecimal) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
deserialize(byte[]) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
deserialize(IndexTuple) - Method in class cascading.tuple.hadoop.io.IndexTupleDeserializer
 
deserialize(Tuple) - Method in class cascading.tuple.hadoop.io.TupleDeserializer
 
deserialize(TuplePair) - Method in class cascading.tuple.hadoop.io.TuplePairDeserializer
 
deserializeBase64(String, Configuration, Class<T>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
This method deserializes the Base64 encoded String into an Object instance.
deserializeBase64(String, Configuration, Class<T>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
deserializeList(byte[], boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
deserializeMap(byte[], boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
DeserializerComparator<T> - Class in cascading.tuple.hadoop.util
Class DeserializerComparator is the base class for all Cascading comparator classes.
DeserializerComparator() - Constructor for class cascading.tuple.hadoop.util.DeserializerComparator
 
dfs - Static variable in class cascading.platform.hadoop.HadoopPlatform
 
Dfs - Class in cascading.tap.hadoop
Class Dfs is a Tap class that provides access to the Hadoop Distributed File System.
Dfs(Fields, URI) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Fields, URI, boolean) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Fields, URI, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Fields, String) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Fields, String, boolean) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Fields, String, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Scheme, URI) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
Dfs(Scheme, URI, boolean) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Scheme, URI, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
Dfs(Scheme, String) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
Dfs(Scheme, String, boolean) - Constructor for class cascading.tap.hadoop.Dfs
Deprecated. 
Dfs(Scheme, String, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
diffConfigIntoMap(JobConf, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
DistCacheTap - Class in cascading.tap.hadoop
Class DistCacheTap is a Tap decorator for Hfs and can be used to move a file to the DistributedCache on read when accessed cluster side.
DistCacheTap(Hfs) - Constructor for class cascading.tap.hadoop.DistCacheTap
Constructs a new DistCacheTap instance with the given Hfs.
dumpDebugInfo() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 

E

encodeBytes(byte[]) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
equals(Object) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
equals(Object) - Method in class cascading.tap.hadoop.GlobHfs
 
equals(Object) - Method in class cascading.tap.hadoop.util.TempHfs
 
exists(Path) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 

F

FalseCollection - Class in cascading.flow.hadoop.util
 
FalseCollection() - Constructor for class cascading.flow.hadoop.util.FalseCollection
 
fileSys - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform
 
findMainClass(Class) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
FlowMapper - Class in cascading.flow.hadoop
Class FlowMapper is the Hadoop Mapper implementation.
FlowMapper() - Constructor for class cascading.flow.hadoop.FlowMapper
Constructor FlowMapper creates a new FlowMapper instance.
FlowReducer - Class in cascading.flow.hadoop
Class FlowReducer is the Hadoop Reducer implementation.
FlowReducer() - Constructor for class cascading.flow.hadoop.FlowReducer
Constructor FlowReducer creates a new FlowReducer instance.
FSDigestInputStream - Class in cascading.tap.hadoop.io
Class FSDigestInputStream is an FSInputStream implementation that can verify a MessageDigest and will count the number of bytes read for use in progress status.
FSDigestInputStream(InputStream, String) - Constructor for class cascading.tap.hadoop.io.FSDigestInputStream
Constructor FSDigestInputStream creates a new FSDigestInputStream instance.
FSDigestInputStream(InputStream, MessageDigest, String) - Constructor for class cascading.tap.hadoop.io.FSDigestInputStream
Constructor FSDigestInputStream creates a new FSDigestInputStream instance.

G

getAttempts() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getBlockSize(JobConf) - Method in class cascading.tap.hadoop.Hfs
Method getBlockSize returns the blocksize specified by the underlying file system for this resource.
getBuffer() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
getCharsetName() - Method in class cascading.scheme.hadoop.TextLine
 
getChildIdentifiers(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
getChildIdentifiers(JobConf, int, boolean) - Method in class cascading.tap.hadoop.Hfs
 
getChildIDs() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
getChildren() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getChildren returns the children of this HadoopStepStats object.
getClass(String) - Method in class cascading.tuple.hadoop.TupleSerialization
 
getClassNameFor(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
getCodec(FlowProcess, String) - Static method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
getCollapseAdjacentTaps(Map<Object, Object>) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getCombinedInputMaxSize() - Method in class cascading.tap.hadoop.HfsProps
 
getCombinedInputSafeMode(JobConf) - Static method in class cascading.tap.hadoop.Hfs
 
getComparator(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
getComparator(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
 
getComparatorFor(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
getConf() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getConfig() - Method in class cascading.flow.hadoop.HadoopFlow
 
getConfig() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
getConfig() - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getConfig(JobConf, JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getConfigAsProperties() - Method in class cascading.flow.hadoop.HadoopFlow
 
getConfigCopy() - Method in class cascading.flow.hadoop.HadoopFlow
 
getConfigCopy() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getCounterGroups() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getCounterGroups returns all of the Hadoop counter groups.
getCounterGroupsMatching(String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getCounterGroupsMatching returns all the Hadoop counter groups that match the give regex pattern.
getCounters() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getCountersFor(String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getCountersFor returns the Hadoop counters for the given group.
getCounterValue(Enum) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getCounterValue returns the Hadoop counter value for the given counter enum.
getCounterValue(String, String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getCounterValue returns the Hadoop counter value for the given group and counter name.
getCounterValue(Enum) - Method in class cascading.stats.hadoop.HadoopSliceStats
Method getCounterValue returns the raw Hadoop counter value.
getCounterValue(String, String) - Method in class cascading.stats.hadoop.HadoopSliceStats
Method getCounterValue returns the raw Hadoop counter value.
getCurrentIdentifier(FlowProcess<JobConf>) - Method in class cascading.tap.hadoop.PartitionTap
 
getCurrentNumMappers() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getCurrentNumReducers() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getCurrentSliceNum() - Method in class cascading.flow.hadoop.HadoopFlowProcess
Method getCurrentTaskNum returns the task number of this task.
getCurrentTapSourcePath(JobConf) - Static method in class cascading.tap.hadoop.io.MultiInputSplit
Method getCurrentTapSourcePath finds and returns the current source Tap filename path, if any.
getDefaultComparator(Comparator, Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization
 
getDefaultComparator(Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization
 
getDefaultComparator() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getDefaultFileSystem(JobConf) - Method in class cascading.tap.hadoop.Dfs
 
getDefaultFileSystem(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
getDefaultFileSystemURIScheme(JobConf) - Method in class cascading.tap.hadoop.Hfs
Method getDefaultFileSystemURIScheme returns the URI scheme for the default Hadoop FileSystem.
getDefaultIntermediateSchemeClass() - Method in class cascading.flow.hadoop.HadoopFlowConnector
 
getDelimitedFile(Fields, boolean, String, String, Class[], String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getDelimitedFile(Fields, boolean, boolean, String, String, Class[], String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getDelimitedFile(String, String, FieldTypeResolver, String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getDelimiter() - Method in class cascading.scheme.hadoop.TextDelimited
Method getDelimiter returns the delimiter used to parse fields from the current line of text.
getDeserializer(Class<BigDecimal>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization
 
getDeserializer(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
getDeserializer(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
Method getDeserializer implements Serialization.getDeserializer(Class).
getDiagnostics() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getElementReader() - Method in class cascading.tuple.hadoop.TupleSerialization
Method getElementReader returns the elementReader of this TupleSerialization object.
getElementWriter() - Method in class cascading.tuple.hadoop.TupleSerialization
Method getElementWriter returns the elementWriter of this TupleSerialization object.
getEventId() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt
 
getFieldComparatorsFrom(Configuration, String) - Static method in class cascading.tuple.hadoop.util.DeserializerComparator
 
getFileStatus(Path) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
getFileSystem(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
getFileSystem(JobConf) - Method in class cascading.tap.hadoop.Lfs
 
getFinishTime() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getFlowConnector(Map<Object, Object>) - Method in class cascading.platform.hadoop.HadoopPlatform
 
getFlowProcess() - Method in class cascading.flow.hadoop.HadoopFlow
 
getFlowProcess() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getFullIdentifier(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
getGrouping() - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getGroupTuple(Tuple) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
getGroupTuple(Tuple) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getHadoopSerializations() - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
getHDFSShutdownHook() - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getHiddenTemporaryPath() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getID() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getIdentifier() - Method in class cascading.tap.hadoop.GlobHfs
 
getIdentifier() - Method in class cascading.tap.hadoop.Hfs
 
getInitializedConfig(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getInitializedConfig(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.MapReduceFlowStep
 
getIterator(int) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
getIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getJobClient() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getJobClient returns the Hadoop JobClient managing this Hadoop job.
getJobConf() - Method in class cascading.flow.hadoop.HadoopFlowProcess
Method getJobConf returns the jobConf of this HadoopFlowProcess object.
getJobConf() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getJobConfs(JobConf, List<Map<String, String>>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getJobID() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getJobID returns the Hadoop running job JobID.
getJobID() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getJobPollingInterval(JobConf) - Static method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
getKind() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getLength() - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
getLength() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
getLocalModeScheme(JobConf, String) - Static method in class cascading.tap.hadoop.Hfs
 
getLocalModeScheme() - Method in class cascading.tap.hadoop.HfsProps
 
getLocations() - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
getLongComparator(boolean) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getMapperTrap(String) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getMapperTraps() - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getMapProgress() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Returns the underlying Map tasks progress percentage.
getMaxNumParallelSteps() - Method in class cascading.flow.hadoop.HadoopFlow
 
getMD5SumFor(Configuration, Path) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
getMD5SumFor(Configuration, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
getModifiedTime(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
getNextElement() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
getNormalizeHeterogeneousSources(Map<Object, Object>) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner
Deprecated. 
getNumElements() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
getNumMapTasks(Map<Object, Object>) - Method in class cascading.platform.hadoop.HadoopPlatform
 
getNumMapTasks() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getNumMapTasks returns the numMapTasks from the Hadoop job file.
getNumProcessSlices() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getNumReduceTasks(Map<Object, Object>) - Method in class cascading.platform.hadoop.HadoopPlatform
 
getNumReduceTasks() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getNumReduceTasks returns the numReducerTasks from the Hadoop job file.
getOutput() - Method in class cascading.flow.hadoop.stream.HadoopSinkStage
 
getOutputCollector() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getOutputCollector() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
getParentStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getPartition(IndexTuple, Tuple, int) - Method in class cascading.tuple.hadoop.util.CoGroupingPartitioner
 
getPartition(Tuple, Tuple, int) - Method in class cascading.tuple.hadoop.util.GroupingPartitioner
 
getPartition(TuplePair, Tuple, int) - Method in class cascading.tuple.hadoop.util.GroupingSortingPartitioner
 
getPartitionTap(Tap, Partition, int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getPath() - Method in class cascading.tap.hadoop.Hfs
 
getPlatformInfo() - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getPlatformInfo() - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getPos() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
getPos() - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
getPos() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
getPosition() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
getProcess() - Method in class cascading.flow.hadoop.ProcessFlow
Method getProcess returns the process of this ProcessFlow object.
getProgress() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getProgress() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
getProgress() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
getProperties() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getProperty(String) - Method in class cascading.flow.hadoop.HadoopFlow
Method getProperty returns the value associated with the given key from the underlying properties system.
getProperty(String) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getPropertyKeys() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getQuote() - Method in class cascading.scheme.hadoop.TextDelimited
Method getQuote returns the quote string, if any, used to encapsulate each field in a line to delimited text.
getRecordReader(InputSplit, JobConf, Reporter) - Method in class cascading.tap.hadoop.io.MultiInputFormat
Method getRecordReader delegates to the appropriate InputFormat.
getRecordReader() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
getReduceProgress() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Returns the underlying Reduce tasks progress percentage.
getReducerTrap(String) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getReducerTraps() - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getReplication(JobConf) - Method in class cascading.tap.hadoop.Hfs
Method getReplication returns the replication specified by the underlying file system for this resource.
getReporter() - Method in class cascading.flow.hadoop.HadoopFlowProcess
Method getReporter returns the reporter of this HadoopFlowProcess object.
getRunningJob() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getRunningJob returns the Hadoop RunningJob managing this Hadoop job.
getSchemeClass() - Method in class cascading.tap.hadoop.util.TempHfs
 
getSerializationTokens(Map<Object, Object>) - Static method in class cascading.tuple.hadoop.TupleSerialization
Deprecated. 
getSerializationTokens(Map<Object, Object>) - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Returns the serialization tokens property.
getSerializationTokens() - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
getSerializer(Class<BigDecimal>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization
 
getSerializer(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
getSerializer(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
Method getSerializer implements Serialization.getSerializer(Class).
getSinkCompression() - Method in class cascading.scheme.hadoop.TextLine
Method getSinkCompression returns the sinkCompression of this TextLine object.
getSize(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
getSpillStrategy() - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
Method getSpillStrategy returns a SpillStrategy instance that is passed to the underlying Spillable tuple collection.
getSplits(JobConf, int) - Method in class cascading.tap.hadoop.io.MultiInputFormat
Method getSplits delegates to the appropriate InputFormat.
getStartTime() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getState() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getStatusFor() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt
 
getStatusURL() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
getStreamedHead() - Method in class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
getStringComparator(boolean) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getTap(Scheme, String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getTapForID(Set<Tap>, String) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getTaps() - Method in class cascading.tap.hadoop.GlobHfs
 
getTaskID() - Method in class cascading.stats.hadoop.HadoopSliceStats
Method getId returns the Hadoop task id.
getTaskIDNum() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getTaskRunTime() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt
 
getTaskStats() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Method getTaskStats returns the taskStats of this HadoopStepStats object.
getTaskStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt
 
getTaskTrackerHttp() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt
 
getTemplateTap(Tap, String, int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getTemplateTap(Tap, String, Fields, int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getTemporaryDirectory(Map<Object, Object>) - Static method in class cascading.tap.hadoop.Hfs
Deprecated. see HfsProps
getTemporaryDirectory() - Method in class cascading.tap.hadoop.HfsProps
 
getTempPath(JobConf) - Static method in class cascading.tap.hadoop.Hfs
 
getTestConfigDefScheme() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getTestFailScheme() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getTextFile(Fields, Fields, String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getThrowable() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
getTrap(String) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getTraps() - Method in class cascading.flow.hadoop.HadoopFlowStep
 
getUri() - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
getURIScheme(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
getUseCombinedInput(JobConf) - Static method in class cascading.tap.hadoop.Hfs
 
getWorkingDirectory() - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
getWrappedInputSplit() - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
GlobHfs - Class in cascading.tap.hadoop
Class GlobHfs is a type of MultiSourceTap that accepts Hadoop style 'file globing' expressions so multiple files that match the given pattern may be used as the input sources for a given Flow.
GlobHfs(Scheme<JobConf, RecordReader, ?, ?, ?>, String) - Constructor for class cascading.tap.hadoop.GlobHfs
Constructor GlobHfs creates a new GlobHfs instance.
GlobHfs(Scheme<JobConf, RecordReader, ?, ?, ?>, String, PathFilter) - Constructor for class cascading.tap.hadoop.GlobHfs
Constructor GlobHfs creates a new GlobHfs instance.
globStatus(Path, PathFilter) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
grouping - Variable in class cascading.flow.hadoop.HadoopGroupByClosure
 
GroupingComparator - Class in cascading.tuple.hadoop.util
Class GroupingComparator is an implementation of RawComparator.
GroupingComparator() - Constructor for class cascading.tuple.hadoop.util.GroupingComparator
 
GroupingPartitioner - Class in cascading.tuple.hadoop.util
GroupingPartitioner is a Partitioner based on the hashCode of the tuple.
GroupingPartitioner() - Constructor for class cascading.tuple.hadoop.util.GroupingPartitioner
 
GroupingSortingComparator - Class in cascading.tuple.hadoop.util
Class TuplePairComparator is an implementation of RawComparator.
GroupingSortingComparator() - Constructor for class cascading.tuple.hadoop.util.GroupingSortingComparator
 
GroupingSortingPartitioner - Class in cascading.tuple.hadoop.util
Class GroupingPartitioner is an implementation of Partitioner.
GroupingSortingPartitioner() - Constructor for class cascading.tuple.hadoop.util.GroupingSortingPartitioner
 

H

Hadoop18TapUtil - Class in cascading.tap.hadoop.util
 
Hadoop18TapUtil() - Constructor for class cascading.tap.hadoop.util.Hadoop18TapUtil
 
HADOOP_IO_SERIALIZATIONS - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
 
HadoopCoGroupClosure - Class in cascading.flow.hadoop
Class CoGroupClosure is used internally to represent co-grouping results of multiple tuple streams.
HadoopCoGroupClosure(FlowProcess, int, Fields[], Fields[]) - Constructor for class cascading.flow.hadoop.HadoopCoGroupClosure
 
HadoopCoGroupClosure.Spill - Enum in cascading.flow.hadoop
 
HadoopCoGroupGate - Class in cascading.flow.hadoop.stream
 
HadoopCoGroupGate(FlowProcess, CoGroup, SpliceGate.Role) - Constructor for class cascading.flow.hadoop.stream.HadoopCoGroupGate
 
HadoopFlow - Class in cascading.flow.hadoop
Class HadoopFlow is the Apache Hadoop specific implementation of a Flow.
HadoopFlow() - Constructor for class cascading.flow.hadoop.HadoopFlow
 
HadoopFlow(PlatformInfo, Map<Object, Object>, JobConf, String, Map<String, String>) - Constructor for class cascading.flow.hadoop.HadoopFlow
 
HadoopFlow(PlatformInfo, Map<Object, Object>, JobConf, FlowDef) - Constructor for class cascading.flow.hadoop.HadoopFlow
 
HadoopFlowConnector - Class in cascading.flow.hadoop
Use the HadoopFlowConnector to link source and sink Tap instances with an assembly of Pipe instances into an executable HadoopFlow for execution on an Apache Hadoop cluster.
HadoopFlowConnector() - Constructor for class cascading.flow.hadoop.HadoopFlowConnector
Constructor FlowConnector creates a new FlowConnector instance.
HadoopFlowConnector(Map<Object, Object>) - Constructor for class cascading.flow.hadoop.HadoopFlowConnector
Constructor FlowConnector creates a new FlowConnector instance using the given Properties instance as default value for the underlying jobs.
HadoopFlowProcess - Class in cascading.flow.hadoop
Class HadoopFlowProcess is an implementation of FlowProcess for Hadoop.
HadoopFlowProcess() - Constructor for class cascading.flow.hadoop.HadoopFlowProcess
 
HadoopFlowProcess(JobConf) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess
 
HadoopFlowProcess(FlowSession, JobConf) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess
 
HadoopFlowProcess(FlowSession, JobConf, boolean) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess
Constructor HadoopFlowProcess creates a new HadoopFlowProcess instance.
HadoopFlowProcess(HadoopFlowProcess, JobConf) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess
 
HadoopFlowStep - Class in cascading.flow.hadoop
 
HadoopFlowStep(String, int) - Constructor for class cascading.flow.hadoop.HadoopFlowStep
 
HadoopFlowStepJob - Class in cascading.flow.hadoop.planner
 
HadoopFlowStepJob(ClientState, BaseFlowStep, JobConf) - Constructor for class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
HadoopGroupByClosure - Class in cascading.flow.hadoop
Class GroupClosure is used internally to represent groups of tuples during grouping.
HadoopGroupByClosure(FlowProcess, Fields[], Fields[]) - Constructor for class cascading.flow.hadoop.HadoopGroupByClosure
 
HadoopGroupByGate - Class in cascading.flow.hadoop.stream
 
HadoopGroupByGate(FlowProcess, GroupBy, SpliceGate.Role) - Constructor for class cascading.flow.hadoop.stream.HadoopGroupByGate
 
HadoopGroupGate - Class in cascading.flow.hadoop.stream
 
HadoopGroupGate(FlowProcess, Splice, SpliceGate.Role) - Constructor for class cascading.flow.hadoop.stream.HadoopGroupGate
 
HadoopMapStreamGraph - Class in cascading.flow.hadoop.stream
 
HadoopMapStreamGraph(HadoopFlowProcess, HadoopFlowStep, Tap) - Constructor for class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
HadoopMemoryJoinGate - Class in cascading.flow.hadoop.stream
 
HadoopMemoryJoinGate(FlowProcess<JobConf>, HashJoin) - Constructor for class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
HadoopMemoryJoinGate.Spill - Enum in cascading.flow.hadoop.stream
 
HadoopPlanner - Class in cascading.flow.hadoop.planner
Class HadoopPlanner is the core Hadoop MapReduce planner.
HadoopPlanner() - Constructor for class cascading.flow.hadoop.planner.HadoopPlanner
 
HadoopPlatform - Class in cascading.platform.hadoop
Class HadoopPlatform is automatically loaded and injected into a PlatformTestCase instance so that all *PlatformTest classes can be tested against Apache Hadoop.
HadoopPlatform() - Constructor for class cascading.platform.hadoop.HadoopPlatform
 
HadoopReduceStreamGraph - Class in cascading.flow.hadoop.stream
 
HadoopReduceStreamGraph(HadoopFlowProcess, HadoopFlowStep) - Constructor for class cascading.flow.hadoop.stream.HadoopReduceStreamGraph
 
HadoopSinkStage - Class in cascading.flow.hadoop.stream
 
HadoopSinkStage(FlowProcess, Tap) - Constructor for class cascading.flow.hadoop.stream.HadoopSinkStage
 
HadoopSliceStats - Class in cascading.stats.hadoop
Class HadoopTaskStats tracks individual task stats.
HadoopSliceStats.HadoopAttempt - Class in cascading.stats.hadoop
 
HadoopSliceStats.HadoopAttempt(TaskCompletionEvent) - Constructor for class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt
 
HadoopSliceStats.Kind - Enum in cascading.stats.hadoop
 
HadoopSpillableTupleList - Class in cascading.tuple.hadoop.collect
SpillableTupleList is a simple Iterable object that can store an unlimited number of Tuple instances by spilling excess to a temporary disk file.
HadoopSpillableTupleList(int, CompressionCodec, JobConf) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
Constructor SpillableTupleList creates a new SpillableTupleList instance using the given threshold value, and the first available compression codec, if any.
HadoopSpillableTupleList(int, TupleSerialization, CompressionCodec) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
HadoopSpillableTupleMap - Class in cascading.tuple.hadoop.collect
HadoopSpillableTupleMap is responsible for spilling values to disk if the map threshold is reached.
HadoopSpillableTupleMap(int, float, int, int, FlowProcess<JobConf>) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
 
HadoopStepGraph - Class in cascading.flow.hadoop.planner
 
HadoopStepGraph() - Constructor for class cascading.flow.hadoop.planner.HadoopStepGraph
 
HadoopStepGraph(String, ElementGraph) - Constructor for class cascading.flow.hadoop.planner.HadoopStepGraph
 
HadoopStepStats - Class in cascading.stats.hadoop
Hadoop 1 specific sub-class of BaseHadoopStats using the mapred API.
HadoopStepStats(FlowStep<JobConf>, ClientState) - Constructor for class cascading.stats.hadoop.HadoopStepStats
 
HadoopTupleCollectionFactory - Class in cascading.tuple.hadoop.collect
 
HadoopTupleCollectionFactory() - Constructor for class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
 
HadoopTupleEntrySchemeCollector - Class in cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeCollector is a kind of TupleEntryCollector that writes tuples to the resource managed by a particular Tap instance.
HadoopTupleEntrySchemeCollector(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
 
HadoopTupleEntrySchemeCollector(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, OutputCollector) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
 
HadoopTupleEntrySchemeIterator - Class in cascading.tap.hadoop.io
 
HadoopTupleEntrySchemeIterator(FlowProcess<JobConf>, Tap, RecordReader) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
 
HadoopTupleEntrySchemeIterator(FlowProcess<JobConf>, Scheme, CloseableIterator<RecordReader>) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
 
HadoopTupleInputStream - Class in cascading.tuple.hadoop.io
 
HadoopTupleInputStream(InputStream, TupleInputStream.ElementReader) - Constructor for class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
HadoopTupleMapFactory - Class in cascading.tuple.hadoop.collect
 
HadoopTupleMapFactory() - Constructor for class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
 
HadoopTupleOutputStream - Class in cascading.tuple.hadoop.io
 
HadoopTupleOutputStream(OutputStream, TupleOutputStream.ElementWriter) - Constructor for class cascading.tuple.hadoop.io.HadoopTupleOutputStream
 
HadoopUtil - Class in cascading.flow.hadoop.util
 
HadoopUtil() - Constructor for class cascading.flow.hadoop.util.HadoopUtil
 
hashCode() - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
hashCode() - Method in class cascading.tap.hadoop.GlobHfs
 
hashCode() - Method in class cascading.tap.hadoop.util.TempHfs
 
hashCode(byte[]) - Method in class cascading.tuple.hadoop.util.BytesComparator
 
HasherPartitioner - Class in cascading.tuple.hadoop.util
 
HasherPartitioner() - Constructor for class cascading.tuple.hadoop.util.HasherPartitioner
 
hasNext() - Method in class cascading.flow.hadoop.util.TimedIterator
 
hasNext() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
Method hasNext returns true if there more Tuple instances available.
Hfs - Class in cascading.tap.hadoop
Class Hfs is the base class for all Hadoop file system access.
Hfs() - Constructor for class cascading.tap.hadoop.Hfs
 
Hfs(Scheme<JobConf, RecordReader, OutputCollector, ?, ?>) - Constructor for class cascading.tap.hadoop.Hfs
 
Hfs(Fields, String) - Constructor for class cascading.tap.hadoop.Hfs
Deprecated. 
Hfs(Fields, String, boolean) - Constructor for class cascading.tap.hadoop.Hfs
Deprecated. 
Hfs(Fields, String, SinkMode) - Constructor for class cascading.tap.hadoop.Hfs
Deprecated. 
Hfs(Scheme<JobConf, RecordReader, OutputCollector, ?, ?>, String) - Constructor for class cascading.tap.hadoop.Hfs
Constructor Hfs creates a new Hfs instance.
Hfs(Scheme<JobConf, RecordReader, OutputCollector, ?, ?>, String, boolean) - Constructor for class cascading.tap.hadoop.Hfs
Deprecated. 
Hfs(Scheme<JobConf, RecordReader, OutputCollector, ?, ?>, String, SinkMode) - Constructor for class cascading.tap.hadoop.Hfs
Constructor Hfs creates a new Hfs instance.
HfsProps - Class in cascading.tap.hadoop
Class HfsProps is a fluent helper for setting various Hadoop FS level properties that some Flow may or may not be required to have set.
HfsProps() - Constructor for class cascading.tap.hadoop.HfsProps
 
hfsProps() - Static method in class cascading.tap.hadoop.HfsProps
Creates a new HfsProps instance.
HTTP_SCHEME - Static variable in class cascading.tap.hadoop.io.HttpFileSystem
Field HTTP_SCHEME
HttpFileSystem - Class in cascading.tap.hadoop.io
Class HttpFileSystem provides a basic read-only FileSystem for accessing remote HTTP and HTTPS data.
HttpFileSystem() - Constructor for class cascading.tap.hadoop.io.HttpFileSystem
 
HTTPS_SCHEME - Static variable in class cascading.tap.hadoop.io.HttpFileSystem
Field HTTPS_SCHEME

I

increment(Enum, long) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
increment(String, String, long) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
IndexTupleCoGroupingComparator - Class in cascading.tuple.hadoop.util
 
IndexTupleCoGroupingComparator() - Constructor for class cascading.tuple.hadoop.util.IndexTupleCoGroupingComparator
 
IndexTupleDeserializer - Class in cascading.tuple.hadoop.io
 
IndexTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.IndexTupleDeserializer
 
IndexTupleSerializer - Class in cascading.tuple.hadoop.io
 
IndexTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.IndexTupleSerializer
 
INDIVIDUAL_INPUT_FORMAT - Static variable in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
property that indicates how individual input format is to be interpreted
initConfig(Map<Object, Object>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlow
 
initFromProperties(Map<Object, Object>) - Method in class cascading.flow.hadoop.HadoopFlow
 
initFromSink(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
initFromSources(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
initFromTraps(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
initialize(FlowConnector, Map<Object, Object>) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
initialize(URI, Configuration) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
initialize() - Method in class cascading.tap.hadoop.io.TapOutputCollector
 
initialize(FlowProcess<JobConf>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
 
initialize(FlowProcess<JobConf>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
 
initLog4j(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
instantiateSerializer(Configuration, Class<T>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
internalBlockOnStop() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
internalClean(boolean) - Method in class cascading.flow.hadoop.HadoopFlow
 
internalIsStarted() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
internalJobId() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
internalNonBlockingIsComplete() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
internalNonBlockingIsSuccessful() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
internalNonBlockingStart() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
internalShutdown() - Method in class cascading.flow.hadoop.HadoopFlow
 
internalStart() - Method in class cascading.flow.hadoop.HadoopFlow
 
isCounterStatusInitialized() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
isDirectory(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
isEmpty(int) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
isEmpty(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
isEmpty() - Method in class cascading.flow.hadoop.util.FalseCollection
 
isHadoopLocalMode(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
isHDFSAvailable() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
isLocal(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
isMapper() - Method in class cascading.flow.hadoop.HadoopFlowProcess
Method isMapper returns true if this part of the FlowProcess is a MapReduce mapper.
isMapReduce() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
isPreserveTemporaryFiles() - Method in class cascading.flow.hadoop.HadoopFlow
Method isPreserveTemporaryFiles returns false if temporary files will be cleaned when this Flow completes.
isRemoteExecution() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
isSymmetrical() - Method in class cascading.scheme.hadoop.TextDelimited
 
isTemporary() - Method in class cascading.tap.hadoop.util.TempHfs
 
isUseCombinedInput() - Method in class cascading.tap.hadoop.HfsProps
 
isUseCombinedInputSafeMode() - Method in class cascading.tap.hadoop.HfsProps
 
iterator() - Method in class cascading.flow.hadoop.util.FalseCollection
 

J

JavaObjectSerializer - Class in cascading.flow.hadoop.util
Class JavaObjectSerializer is the default implementation of ObjectSerializer.
JavaObjectSerializer() - Constructor for class cascading.flow.hadoop.util.JavaObjectSerializer
 
jobConf - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform
 

K

keepAlive() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
keyType - Variable in class cascading.scheme.hadoop.WritableSequenceFile
 

L

Lfs - Class in cascading.tap.hadoop
Class Lfs is a Tap class that provides access to the Local File System via Hadoop.
Lfs(Fields, String) - Constructor for class cascading.tap.hadoop.Lfs
Deprecated. 
Lfs(Scheme, String) - Constructor for class cascading.tap.hadoop.Lfs
Constructor Lfs creates a new Lfs instance.
Lfs(Scheme, String, boolean) - Constructor for class cascading.tap.hadoop.Lfs
Deprecated. 
Lfs(Fields, String, SinkMode) - Constructor for class cascading.tap.hadoop.Lfs
Deprecated. 
Lfs(Scheme, String, SinkMode) - Constructor for class cascading.tap.hadoop.Lfs
Constructor Lfs creates a new Lfs instance.
listStatus(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
LOCAL_MODE_SCHEME - Static variable in class cascading.tap.hadoop.HfsProps
Fields LOCAL_MODE_SCHEME *
localModeScheme - Variable in class cascading.tap.hadoop.HfsProps
 
logger - Variable in class cascading.platform.hadoop.BaseHadoopPlatform
 

M

makeEncodedString(Object[]) - Method in class cascading.scheme.hadoop.TextLine
 
makeIterator(int, Iterator) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
makeStepGraph(String, ElementGraph) - Method in class cascading.flow.hadoop.planner.HadoopStepGraph
Creates the map reduce step graph.
makeTemporaryPathDirString(String) - Method in class cascading.tap.hadoop.Hfs
 
makeTempPath(JobConf) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
 
makeTempTap(String, String) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
makeURIScheme(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
MapReduceFlow - Class in cascading.flow.hadoop
Class MapReduceFlow is a HadoopFlow subclass that supports custom MapReduce jobs pre-configured via the JobConf object.
MapReduceFlow(JobConf) - Constructor for class cascading.flow.hadoop.MapReduceFlow
Constructor MapReduceFlow creates a new MapReduceFlow instance.
MapReduceFlow(JobConf, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow
Constructor MapReduceFlow creates a new MapReduceFlow instance.
MapReduceFlow(String, JobConf) - Constructor for class cascading.flow.hadoop.MapReduceFlow
Constructor MapReduceFlow creates a new MapReduceFlow instance.
MapReduceFlow(String, JobConf, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow
Constructor MapReduceFlow creates a new MapReduceFlow instance.
MapReduceFlow(String, JobConf, boolean, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow
Constructor MapReduceFlow creates a new MapReduceFlow instance.
MapReduceFlowStep - Class in cascading.flow.hadoop
Class MapReduceFlowStep wraps a JobConf and allows it to be executed as a Flow.
MeasuredOutputCollector - Class in cascading.tap.hadoop.util
 
MeasuredOutputCollector(FlowProcess, Enum) - Constructor for class cascading.tap.hadoop.util.MeasuredOutputCollector
 
MeasuredOutputCollector(FlowProcess, Enum, OutputCollector) - Constructor for class cascading.tap.hadoop.util.MeasuredOutputCollector
 
MeasuredRecordReader - Class in cascading.tap.hadoop.util
 
MeasuredRecordReader(FlowProcess, Enum) - Constructor for class cascading.tap.hadoop.util.MeasuredRecordReader
 
mergeConf(JobConf, Map<String, String>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
mergeMapIntoConfig(JobConf, Map<String, String>) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
mkdirs(Path, FsPermission) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
mr - Static variable in class cascading.platform.hadoop.HadoopPlatform
 
MultiInputFormat - Class in cascading.tap.hadoop.io
Class MultiInputFormat accepts multiple InputFormat class declarations allowing a single MR job to read data from incompatible file types.
MultiInputFormat() - Constructor for class cascading.tap.hadoop.io.MultiInputFormat
 
MultiInputSplit - Class in cascading.tap.hadoop.io
Class MultiInputSplit is used by MultiInputFormat
MultiInputSplit(InputSplit, Map<String, String>) - Constructor for class cascading.tap.hadoop.io.MultiInputSplit
 
MultiInputSplit() - Constructor for class cascading.tap.hadoop.io.MultiInputSplit
This constructor is used internally by Hadoop.
MultiRecordReaderIterator - Class in cascading.tap.hadoop.io
Class TapIterator is an implementation of CloseableIterator.
MultiRecordReaderIterator(FlowProcess<JobConf>, Tap) - Constructor for class cascading.tap.hadoop.io.MultiRecordReaderIterator
Constructor TapIterator creates a new TapIterator instance.

N

needsTaskCommit(JobConf) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
 
newConfig(JobConf) - Method in class cascading.flow.hadoop.HadoopFlow
 
newInstance(String) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
next() - Method in class cascading.flow.hadoop.util.TimedIterator
 
next(K, V) - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
next() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
Method next returns the next Tuple.
next(Object, Object) - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
numMapTasks - Variable in class cascading.platform.hadoop.BaseHadoopPlatform
 
numReduceTasks - Variable in class cascading.platform.hadoop.BaseHadoopPlatform
 

O

OBJECT_SERIALIZER_PROPERTY - Static variable in interface cascading.flow.hadoop.util.ObjectSerializer
 
ObjectSerializer - Interface in cascading.flow.hadoop.util
Class ObjectSerializer is an experimental interface for allowing custom java.lang.Object subclass serialization other than via the java.io.Serializable interface.
open(Path, int) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
open(InputStream) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
open(OutputStream) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
open(InputStream) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
open(OutputStream) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 
openForRead(FlowProcess<JobConf>, RecordReader) - Method in class cascading.tap.hadoop.DistCacheTap
 
openForRead(FlowProcess<JobConf>, RecordReader) - Method in class cascading.tap.hadoop.Hfs
 
openForWrite(FlowProcess<JobConf>, OutputCollector) - Method in class cascading.tap.hadoop.Hfs
 
openSystemIntermediateForWrite() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
openTapForRead(Tap) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
openTapForWrite(Tap) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
openTrapForWrite(Tap) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
outgoingScopeFor(Set<Scope>) - Method in class cascading.tap.hadoop.util.TempHfs
 

P

parentStepHasReducers() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
PART_TASK_PATTERN - Static variable in class cascading.tap.hadoop.io.TapOutputCollector
 
PART_TASK_SEQ_PATTERN - Static variable in class cascading.tap.hadoop.io.TapOutputCollector
 
PartitionTap - Class in cascading.tap.hadoop
Class PartitionTap can be used to write tuple streams out to files and sub-directories based on the values in the current Tuple instance.
PartitionTap(Hfs, Partition) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, int) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, SinkMode) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, SinkMode, boolean) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, SinkMode, boolean, int) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
prepare() - Method in class cascading.flow.hadoop.ProcessFlow
 
prepare() - Method in class cascading.flow.hadoop.stream.HadoopCoGroupGate
 
prepare() - Method in class cascading.flow.hadoop.stream.HadoopGroupByGate
 
prepare() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
presentSinkFields(FlowProcess<JobConf>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
presentSinkFields(FlowProcess<JobConf>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextLine
 
presentSourceFields(FlowProcess<JobConf>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
presentSourceFields(FlowProcess<JobConf>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextLine
 
ProcessFlow<P> - Class in cascading.flow.hadoop
Class ProcessFlow is a Flow subclass that supports custom Riffle jobs.
ProcessFlow(String, P) - Constructor for class cascading.flow.hadoop.ProcessFlow
Constructor ProcessFlow creates a new ProcessFlow instance.
ProcessFlow(Map<Object, Object>, String, P) - Constructor for class cascading.flow.hadoop.ProcessFlow
Constructor ProcessFlow creates a new ProcessFlow instance.
ProcessFlow(Map<Object, Object>, String, P, Map<String, String>) - Constructor for class cascading.flow.hadoop.ProcessFlow
Constructor ProcessFlow creates a new ProcessFlow instance.
properties - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform
 

R

read() - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
read(byte[], int, int) - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
read(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
readFields(DataInput) - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
readIndexTuple(IndexTuple) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readStateFromDistCache(JobConf, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
readString() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readToken() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readType(int) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readVInt() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readVLong() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
receive(Duct, TupleEntry) - Method in class cascading.flow.hadoop.stream.HadoopCoGroupGate
 
receive(Duct, TupleEntry) - Method in class cascading.flow.hadoop.stream.HadoopGroupByGate
 
recordChildStats() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
Synchronized to prevent state changes mid record, #stop may be called out of band
RecordReaderIterator - Class in cascading.tap.hadoop.io
RecordReaderIterator is a utility class for handing off a single RecordReader instance via the Iterator.
RecordReaderIterator(RecordReader) - Constructor for class cascading.tap.hadoop.io.RecordReaderIterator
 
reduce(Object, Iterator, OutputCollector, Reporter) - Method in class cascading.flow.hadoop.FlowReducer
 
remoteExists(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
remoteRemove(String, boolean) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
remove(Object) - Method in class cascading.flow.hadoop.util.FalseCollection
 
remove() - Method in class cascading.flow.hadoop.util.TimedIterator
 
remove() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
 
removeAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
removePropertiesFrom(JobConf, String...) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
removeStateFromDistCache(JobConf, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
rename(Path, Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
reportLocalError(Throwable) - Static method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
Internal method to report errors that happen on hadoop local mode.
reset(Tuple, Iterator) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
reset(Tuple, Iterator) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
reset(Iterator) - Method in class cascading.flow.hadoop.util.TimedIterator
 
reset(byte[], int, int) - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
resourceExists(JobConf) - Method in class cascading.tap.hadoop.Hfs
 
retainAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
retrieveSourceFields(FlowProcess<JobConf>, Tap) - Method in class cascading.scheme.hadoop.TextDelimited
 
ReverseGroupingSortingComparator - Class in cascading.tuple.hadoop.util
Class ReverseTuplePairComparator is an implementation of RawComparator.
ReverseGroupingSortingComparator() - Constructor for class cascading.tuple.hadoop.util.ReverseGroupingSortingComparator
 
ReverseTupleComparator - Class in cascading.tuple.hadoop.util
 
ReverseTupleComparator() - Constructor for class cascading.tuple.hadoop.util.ReverseTupleComparator
 
run(RecordReader, OutputCollector, Reporter) - Method in class cascading.flow.hadoop.FlowMapper
 
run(Tuple, Iterator) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 

S

safeFileName(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
Replaces characters, that are not allowed by HDFS with an "_".
seek(long) - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
seekToNewSource(long) - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
SequenceFile - Class in cascading.scheme.hadoop
A SequenceFile is a type of Scheme, which is a flat file consisting of binary key/value pairs.
SequenceFile() - Constructor for class cascading.scheme.hadoop.SequenceFile
Protected for use by TempDfs and other subclasses.
SequenceFile(Fields) - Constructor for class cascading.scheme.hadoop.SequenceFile
Creates a new SequenceFile instance that stores the given field names.
SERIALIZATION_TOKENS - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
 
SerializationToken - Annotation Type in cascading.tuple.hadoop
Annotation SerializationToken enables TupleInputStream and TupleOutputStream to substitute Integer values for a class name when writing out nested objects inside a Tuple.
serialize(T, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
serialize(T, boolean) - Method in interface cascading.flow.hadoop.util.ObjectSerializer
 
serialize(BigDecimal) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
serialize(byte[]) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 
serialize(IndexTuple) - Method in class cascading.tuple.hadoop.io.IndexTupleSerializer
 
serialize(TuplePair) - Method in class cascading.tuple.hadoop.io.TuplePairSerializer
 
serialize(Tuple) - Method in class cascading.tuple.hadoop.io.TupleSerializer
 
serializeBase64(T, JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
serializeBase64(T, JobConf, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
serializeList(List<T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
serializeMap(Map<String, T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
setCharsetName(String) - Method in class cascading.scheme.hadoop.TextLine
 
setCollapseAdjacentTaps(Map<Object, Object>, boolean) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner
Method setCollapseAdjacentTaps enables/disables an optimization that will identify if a sink tap and an intermediate tap are equivalent field wise, and discard the intermediate tap for the sink tap to minimize the number of MR jobs.
setCombinedInputMaxSize(Map<Object, Object>, Long) - Static method in class cascading.tap.hadoop.HfsProps
Method setCombinedInputMaxSize sets the maximum input split size to be used.
setCombinedInputMaxSize(long) - Method in class cascading.tap.hadoop.HfsProps
Method setCombinedInputMaxSize sets the maximum input split size to be used.
setConf(Configuration) - Method in class cascading.tuple.hadoop.TupleSerialization
 
setConf(Configuration) - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
setConf(Configuration) - Method in class cascading.tuple.hadoop.util.GroupingSortingComparator
 
setConfigProperty(JobConf, Object, Object) - Method in class cascading.flow.hadoop.HadoopFlow
 
setHadoopSerializations(List<String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method setHadoopSerializations sets the Hadoop serialization classNames to be used as properties.
setIterator(Iterator<Tuple>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
setLocal(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
setLocalModeScheme(Map<Object, Object>, String) - Static method in class cascading.tap.hadoop.HfsProps
Method setLocalModeScheme provides a means to change the scheme value used to detect when a MapReduce job should be run in Hadoop local mode.
setLocalModeScheme(String) - Method in class cascading.tap.hadoop.HfsProps
Method setLocalModeScheme provides a means to change the scheme value used to detect when a MapReduce job should be run in Hadoop local mode.
setMD5SumFor(Configuration, Path, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
setMD5SumFor(Configuration, String, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
setNormalizeHeterogeneousSources(Map<Object, Object>, boolean) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner
Deprecated. 
setNumMapTasks(int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
setNumMapTasks(Map<Object, Object>, int) - Method in class cascading.platform.hadoop.HadoopPlatform
 
setNumReduceTasks(int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
setNumReduceTasks(Map<Object, Object>, int) - Method in class cascading.platform.hadoop.HadoopPlatform
 
setOutputCollector(OutputCollector) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
setOutputCollector(OutputCollector) - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
setRecordReader(RecordReader) - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
setReporter(Reporter) - Method in class cascading.flow.hadoop.HadoopFlowProcess
Method setReporter sets the reporter of this HadoopFlowProcess object.
setSerializations(JobConf) - Static method in class cascading.tuple.hadoop.TupleSerialization
Adds this class as a Hadoop Serialization class.
setSerializationTokens(Map<Integer, String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method setSerializationTokens sets the given integer tokens and classNames Map as a serialization properties.
setSinkCompression(TextLine.Compress) - Method in class cascading.scheme.hadoop.TextLine
Method setSinkCompression sets the sinkCompression of this TextLine object.
setSinkFields(Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
setSourceFields(Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
setStatus(String) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
setStringPath(String) - Method in class cascading.tap.hadoop.Dfs
 
setStringPath(String) - Method in class cascading.tap.hadoop.Hfs
 
setStringPath(String) - Method in class cascading.tap.hadoop.Lfs
 
setTapFromProcess() - Method in class cascading.flow.hadoop.ProcessFlow
Method setTapFromProcess build Tap instance for the give process incoming and outgoing dependencies.
setTaskStats(Map<String, HadoopSliceStats>) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
 
setTemporaryDirectory(Map<Object, Object>, String) - Static method in class cascading.tap.hadoop.Hfs
Deprecated. see HfsProps
setTemporaryDirectory(Map<Object, Object>, String) - Static method in class cascading.tap.hadoop.HfsProps
Method setTemporaryDirectory sets the temporary directory on the given properties object.
setTemporaryDirectory(String) - Method in class cascading.tap.hadoop.HfsProps
Method setTemporaryDirectory sets the temporary directory for use on the underlying filesystem.
setUp() - Method in class cascading.platform.hadoop.HadoopPlatform
 
setupJob(JobConf) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
should only be called if not in a Flow
setupTask(JobConf) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
 
setUriScheme(URI) - Method in class cascading.tap.hadoop.Hfs
 
setUseCombinedInput(Map<Object, Object>, Boolean) - Static method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInput provides a means to indicate whether to leverage CombineFileInputFormat for the input format.
setUseCombinedInput(boolean) - Method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInput provides a means to indicate whether to leverage CombineFileInputFormat for the input format.
setUseCombinedInputSafeMode(Map<Object, Object>, Boolean) - Static method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInputSafeMode toggles safe mode when using CombineFileInputFormat.
setUseCombinedInputSafeMode(boolean) - Method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInputSafeMode toggles safe mode when using CombineFileInputFormat.
setWorkingDirectory(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
sink(FlowProcess<JobConf>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.SequenceFile
 
sink(FlowProcess<JobConf>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
 
sink(FlowProcess<JobConf>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextLine
 
sink(FlowProcess<JobConf>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class cascading.scheme.hadoop.SequenceFile
 
sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class cascading.scheme.hadoop.TextLine
 
sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
sinkConfInit(FlowProcess<JobConf>, JobConf) - Method in class cascading.tap.hadoop.Hfs
 
sinkPrepare(FlowProcess<JobConf>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
 
sinkPrepare(FlowProcess<JobConf>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextLine
 
size() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
size() - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
size() - Method in class cascading.flow.hadoop.util.FalseCollection
 
source(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
 
source(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited
 
source(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
source(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
sourceCleanup(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
 
sourceCleanup(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class cascading.scheme.hadoop.SequenceFile
 
sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class cascading.scheme.hadoop.TextLine
 
sourceConfInit(FlowProcess<JobConf>, JobConf) - Method in class cascading.tap.hadoop.DistCacheTap
 
sourceConfInit(FlowProcess<JobConf>, JobConf) - Method in class cascading.tap.hadoop.GlobHfs
 
sourceConfInit(FlowProcess<JobConf>, JobConf) - Method in class cascading.tap.hadoop.Hfs
 
sourceConfInit(FlowProcess<JobConf>, JobConf) - Method in class cascading.tap.hadoop.PartitionTap
 
sourceConfInitAddInputPath(JobConf, Path) - Method in class cascading.tap.hadoop.Hfs
 
sourceConfInitComplete(FlowProcess<JobConf>, JobConf) - Method in class cascading.tap.hadoop.Hfs
 
sourceHandleInput(SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
sourcePrepare(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
 
sourcePrepare(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited
 
sourcePrepare(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
start() - Method in class cascading.flow.hadoop.ProcessFlow
 
start(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
stepsAreLocal() - Method in class cascading.flow.hadoop.HadoopFlow
 
stop() - Method in class cascading.flow.hadoop.ProcessFlow
 
stopOnElement(FlowElement, List<FlowElement>) - Method in class cascading.flow.hadoop.stream.HadoopMapStreamGraph
 
stopOnElement(FlowElement, List<FlowElement>) - Method in class cascading.flow.hadoop.stream.HadoopReduceStreamGraph
 
StreamedFileSystem - Class in cascading.tap.hadoop.io
Class StreamedFileSystem is a base class for FileSystem implementations that manage remote resources.
StreamedFileSystem() - Constructor for class cascading.tap.hadoop.io.StreamedFileSystem
 
stringPath - Variable in class cascading.tap.hadoop.Hfs
Field stringPath
syncPaths(JobConf, Map<Path, Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 

T

TapOutputCollector - Class in cascading.tap.hadoop.io
 
TapOutputCollector(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
 
TapOutputCollector(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, String) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
 
TapOutputCollector(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, String, long) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
 
tearDown() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
TempHfs - Class in cascading.tap.hadoop.util
Class TempHfs creates a temporary Tap instance for use internally.
TempHfs(JobConf, String, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs
Constructor TempHfs creates a new TempHfs instance.
TempHfs(JobConf, String, Class<? extends Scheme>) - Constructor for class cascading.tap.hadoop.util.TempHfs
Constructor TempDfs creates a new TempDfs instance.
TempHfs(JobConf, String, Class<? extends Scheme>, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs
 
TemplateTap - Class in cascading.tap.hadoop
Deprecated. see PartitionTap
TemplateTap(Hfs, String) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, int) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, SinkMode) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, SinkMode, boolean) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, SinkMode, boolean, int) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, Fields) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, Fields, int) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, Fields, SinkMode) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, Fields, SinkMode, boolean) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TemplateTap(Hfs, String, Fields, SinkMode, boolean, int) - Constructor for class cascading.tap.hadoop.TemplateTap
Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent Hfs Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.
TEMPORARY_DIRECTORY - Static variable in class cascading.tap.hadoop.Hfs
Deprecated. see HfsProps.TEMPORARY_DIRECTORY
TEMPORARY_DIRECTORY - Static variable in class cascading.tap.hadoop.HfsProps
Field TEMPORARY_DIRECTORY
TEMPORARY_PATH - Static variable in class cascading.tap.hadoop.util.Hadoop18TapUtil
The Hadoop temporary path used to prevent collisions
temporaryDirectory - Variable in class cascading.tap.hadoop.HfsProps
 
TextDelimited - Class in cascading.scheme.hadoop
Class TextDelimited is a sub-class of TextLine.
TextDelimited() - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(TextLine.Compress, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(TextLine.Compress, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(TextLine.Compress, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(Fields) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance with TAB as the default delimiter.
TextDelimited(Fields, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String, Class[], boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, Class[], boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, boolean, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, boolean, String, Class[], boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextLine - Class in cascading.scheme.hadoop
A TextLine is a type of Scheme for plain text files.
TextLine() - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance that sources "offset" and "line" fields, and sinks all incoming fields, where "offset" is the byte offset in the input file.
TextLine(int) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance that sources "offset" and "line" fields, and sinks all incoming fields, where "offset" is the byte offset in the input file.
TextLine(TextLine.Compress) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance that sources "offset" and "line" fields, and sinks all incoming fields, where "offset" is the byte offset in the input file.
TextLine(Fields, Fields) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, Fields, String) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, Fields, int) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress, String) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress, int) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress, int, String) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, String) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, int) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine.Compress - Enum in cascading.scheme.hadoop
 
TimedIterator - Class in cascading.flow.hadoop.util
 
TimedIterator(FlowProcess, Enum, Enum) - Constructor for class cascading.flow.hadoop.util.TimedIterator
 
TIMEOUT_MAX - Static variable in class cascading.stats.hadoop.BaseHadoopStepStats
 
toArray() - Method in class cascading.flow.hadoop.util.FalseCollection
 
toArray(T[]) - Method in class cascading.flow.hadoop.util.FalseCollection
 
toString() - Method in class cascading.flow.hadoop.ProcessFlow
 
toString() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
toString() - Method in class cascading.tap.hadoop.GlobHfs
 
toString() - Method in class cascading.tap.hadoop.util.TempHfs
 
TupleComparator - Class in cascading.tuple.hadoop.util
 
TupleComparator() - Constructor for class cascading.tuple.hadoop.util.TupleComparator
 
TupleDeserializer - Class in cascading.tuple.hadoop.io
 
TupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.TupleDeserializer
 
TupleElementComparator - Class in cascading.tuple.hadoop.util
 
TupleElementComparator() - Constructor for class cascading.tuple.hadoop.util.TupleElementComparator
 
TupleElementComparator(Comparator) - Constructor for class cascading.tuple.hadoop.util.TupleElementComparator
 
TupleElementStreamComparator - Class in cascading.tuple.hadoop.util
 
TupleElementStreamComparator(StreamComparator) - Constructor for class cascading.tuple.hadoop.util.TupleElementStreamComparator
 
TuplePairDeserializer - Class in cascading.tuple.hadoop.io
 
TuplePairDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.TuplePairDeserializer
 
TuplePairSerializer - Class in cascading.tuple.hadoop.io
 
TuplePairSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.TuplePairSerializer
 
TupleSerialization - Class in cascading.tuple.hadoop
Class TupleSerialization is an implementation of Hadoop's Serialization interface.
TupleSerialization() - Constructor for class cascading.tuple.hadoop.TupleSerialization
Constructor TupleSerialization creates a new TupleSerialization instance.
TupleSerialization(FlowProcess<JobConf>) - Constructor for class cascading.tuple.hadoop.TupleSerialization
 
TupleSerialization(Configuration) - Constructor for class cascading.tuple.hadoop.TupleSerialization
Constructor TupleSerialization creates a new TupleSerialization instance.
TupleSerialization.SerializationElementReader - Class in cascading.tuple.hadoop
 
TupleSerialization.SerializationElementReader(TupleSerialization) - Constructor for class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
Constructor SerializationElementReader creates a new SerializationElementReader instance.
TupleSerialization.SerializationElementWriter - Class in cascading.tuple.hadoop
 
TupleSerialization.SerializationElementWriter(TupleSerialization) - Constructor for class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
TupleSerializationProps - Class in cascading.tuple.hadoop
Class TupleSerializationProps is a fluent interface for building properties to be passed to a FlowConnector before creating new Flow instances.
TupleSerializationProps() - Constructor for class cascading.tuple.hadoop.TupleSerializationProps
 
tupleSerializationProps() - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Creates a new TupleSerializationProps instance.
TupleSerializer - Class in cascading.tuple.hadoop.io
 
TupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.TupleSerializer
 

U

unwrapGrouping(Tuple) - Method in class cascading.flow.hadoop.stream.HadoopCoGroupGate
 
unwrapGrouping(Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupByGate
 
unwrapGrouping(Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
useCombinedInput - Variable in class cascading.tap.hadoop.HfsProps
 

V

validateInput(JobConf) - Method in class cascading.tap.hadoop.io.MultiInputFormat
 
valueOf(String) - Static method in enum cascading.flow.hadoop.HadoopCoGroupClosure.Spill
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum cascading.flow.hadoop.stream.HadoopMemoryJoinGate.Spill
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum cascading.scheme.hadoop.TextLine.Compress
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum cascading.stats.hadoop.HadoopSliceStats.Kind
Returns the enum constant of this type with the specified name.
values() - Static method in enum cascading.flow.hadoop.HadoopCoGroupClosure.Spill
Returns an array containing the constants of this enum type, in the order they are declared.
values - Variable in class cascading.flow.hadoop.HadoopGroupByClosure
 
values() - Static method in enum cascading.flow.hadoop.stream.HadoopMemoryJoinGate.Spill
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum cascading.scheme.hadoop.TextLine.Compress
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum cascading.stats.hadoop.HadoopSliceStats.Kind
Returns an array containing the constants of this enum type, in the order they are declared.
valueType - Variable in class cascading.scheme.hadoop.WritableSequenceFile
 
verify(Fields) - Method in class cascading.scheme.hadoop.TextLine
 
verifyNoDuplicates(JobConf) - Static method in class cascading.tap.hadoop.Hfs
 

W

waitOnLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
wrapInput(RecordReader) - Method in class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
 
wrapOutput(OutputCollector) - Method in class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
 
WRITABLE_TOKEN - Static variable in class cascading.tuple.hadoop.io.HadoopTupleOutputStream
Field WRITABLE_TOKEN
WritableSequenceFile - Class in cascading.scheme.hadoop
Class WritableSequenceFile is a sub-class of SequenceFile that reads and writes values of the given writableType Class, instead of Tuple instances used by default in SequenceFile.
WritableSequenceFile(Fields, Class<? extends Writable>) - Constructor for class cascading.scheme.hadoop.WritableSequenceFile
Constructor WritableSequenceFile creates a new WritableSequenceFile instance.
WritableSequenceFile(Fields, Class<? extends Writable>, Class<? extends Writable>) - Constructor for class cascading.scheme.hadoop.WritableSequenceFile
Constructor WritableSequenceFile creates a new WritableSequenceFile instance.
write(DataOutput) - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
write(DataOutputStream, Object) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
writeHeader(SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
 
writeIndexTuple(IndexTuple) - Method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream
 
writeIntInternal(int) - Method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream
 
writeStateToDistCache(JobConf, String, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 

A B C D E F G H I J K L M N O P R S T U V W

Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.