Index (Cascading 3.0.4)

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

A

accept(Tuple, Iterator<Tuple>[]) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
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
AccumulatedPostNodeAnnotator - Class in cascading.flow.tez.planner.rule.annotator
AccumulatedPostNodeAnnotator() - Constructor for class cascading.flow.tez.planner.rule.annotator.AccumulatedPostNodeAnnotator
AccumulatedSourceExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
AccumulatedSourceExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.AccumulatedSourceExpressionGraph
add(Tuple) - Method in class cascading.flow.hadoop.util.FalseCollection
add(Tuple) - Method in class cascading.flow.hadoop.util.LazyCollection
addAll(Collection<? extends Tuple>) - Method in class cascading.flow.hadoop.util.FalseCollection
addAll(Collection<? extends Tuple>) - Method in class cascading.flow.hadoop.util.LazyCollection
addAttempt(Object) - Method in class cascading.stats.tez.TezSliceStats
addComparators(Configuration, String, Map<String, Fields>, BaseFlowStep, Group) - Static method in class cascading.flow.hadoop.util.HadoopUtil
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.
addInputPath(Configuration, Path) - Static method in class cascading.flow.hadoop.util.HadoopUtil
addLocalCacheFiles(Configuration, URI) - Method in class cascading.tap.hadoop.BaseDistCacheTap
addLocalCacheFiles(Configuration, URI) - Method in class cascading.tap.hadoop.DistCacheTap
addPropertiesTo(Properties) - Method in class cascading.tap.hadoop.HfsProps
addPropertiesTo(Properties) - Method in class cascading.tuple.hadoop.TupleSerializationProps
addResource(Map<String, LocalResource>, Map<String, String>, String, FileStatus, Path, LocalResourceType) - Static method in class cascading.flow.tez.util.TezUtil
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.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.
addToClassPath(Configuration, List<String>) - Static method in class cascading.flow.hadoop.util.HadoopUtil: Add to class path.
addToClassPath(Configuration, String, String, Collection<String>, LocalResourceType, Map<String, LocalResource>, Map<String, String>) - Static method in class cascading.flow.tez.util.TezUtil
advance() - Method in class cascading.flow.tez.util.SecondarySortKeyValuesReader
allChildrenFinished - Variable in class cascading.stats.hadoop.BaseHadoopNodeStats
append(Path, int, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
applySourceConfInitIdentifiers(FlowProcess<? extends Configuration>, Configuration, String...) - Method in class cascading.tap.hadoop.Hfs
areCountersAvailable(JobStatus) - Method in class cascading.stats.hadoop.CounterCache
areCountersAvailable(JobStatus) - Method in class cascading.stats.tez.TezCounterCache
asJobConf(Configuration) - Static method in class cascading.flow.tez.util.TezUtil: Attempting to localize all new JobConf calls
asJobConfInstance(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

B

BalanceCheckpointWithBoundaryExpression - Class in cascading.flow.tez.planner.rule.expression
BalanceCheckpointWithBoundaryExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceCheckpointWithBoundaryExpression
BalanceCheckpointWithTapExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceCheckpointWithTapExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceCheckpointWithTapExpression
BalanceGroupBlockingHashJoinExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceGroupBlockingHashJoinExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupBlockingHashJoinExpression
BalanceGroupGroupExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceGroupGroupExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupGroupExpression
BalanceGroupMergeGroupExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceGroupMergeGroupExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupMergeGroupExpression
BalanceGroupNonBlockingHashJoinExpression - Class in cascading.flow.hadoop.planner.rule.expression: This rule is a compliment to GroupNonBlockingHashJoinTransformRule and is intended to prevent a HashJoin from landing in a Reducer until reduce side HashJoins are supported.
BalanceGroupNonBlockingHashJoinExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupNonBlockingHashJoinExpression
BalanceGroupSplitExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceGroupSplitExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitExpression
BalanceGroupSplitHashJoinExpression - Class in cascading.flow.tez.planner.rule.expression
BalanceGroupSplitHashJoinExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitHashJoinExpression
BalanceGroupSplitJoinExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceGroupSplitJoinExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitJoinExpression
BalanceGroupSplitMergeGroupExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceGroupSplitMergeGroupExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
BalanceGroupSplitSpliceExpression - Class in cascading.flow.tez.planner.rule.expression
BalanceGroupSplitSpliceExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitSpliceExpression
BalanceHashJoinBlockingHashJoinExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceHashJoinBlockingHashJoinExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceHashJoinBlockingHashJoinExpression
BalanceHashJoinSameSourceExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceHashJoinSameSourceExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceHashJoinSameSourceExpression
BalanceHashJoinToHashJoinExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceHashJoinToHashJoinExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceHashJoinToHashJoinExpression
BalanceJoinSplitExpression - Class in cascading.flow.tez.planner.rule.expressiongraph
BalanceJoinSplitExpression() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.BalanceJoinSplitExpression
BalanceNonSafePipeSplitExpression - Class in cascading.flow.hadoop.planner.rule.expression: Captures a split against a non-safe Operation to prevent the operation from running in parallel mappers.
BalanceNonSafePipeSplitExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceNonSafePipeSplitExpression
BalanceNonSafeSplitExpression - Class in cascading.flow.hadoop.planner.rule.expression: Captures a split against a non-safe Operation to prevent the operation from running in parallel mappers
BalanceNonSafeSplitExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceNonSafeSplitExpression
BalanceSameSourceStreamedAccumulatedExpression - Class in cascading.flow.hadoop.planner.rule.expression
BalanceSameSourceStreamedAccumulatedExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceSameSourceStreamedAccumulatedExpression
BalanceSplitToStreamedHashJoinExpression - Class in cascading.flow.tez.planner.rule.expression
BalanceSplitToStreamedHashJoinExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceSplitToStreamedHashJoinExpression
BaseDistCacheTap - Class in cascading.tap.hadoop
BaseDistCacheTap(Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.BaseDistCacheTap
BaseHadoopNodeStats<JobStatus,Counters> - Class in cascading.stats.hadoop
BaseHadoopNodeStats(FlowNode, ClientState) - Constructor for class cascading.stats.hadoop.BaseHadoopNodeStats: Constructor CascadingStats creates a new CascadingStats instance.
BaseHadoopStepStats<JobStatusClient,Counters> - Class in cascading.stats.hadoop
BaseHadoopStepStats(FlowStep, 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.HadoopGroupGate
bind(StreamGraph) - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
bind(StreamGraph) - Method in class cascading.flow.tez.stream.element.TezMergeGate
BottomUpBoundariesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
BottomUpBoundariesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.BottomUpBoundariesNodePartitioner
BottomUpConsecutiveBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
BottomUpConsecutiveBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.BottomUpConsecutiveBoundariesExpressionGraph
BottomUpJoinedBoundariesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
BottomUpJoinedBoundariesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.BottomUpJoinedBoundariesNodePartitioner
BottomUpNoSplitConsecutiveBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
BottomUpNoSplitConsecutiveBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.BottomUpNoSplitConsecutiveBoundariesExpressionGraph
BOUNDARY_PIPE - Static variable in class cascading.flow.tez.planner.rule.transformer.BoundaryElementFactory
BoundaryBalanceCheckpointTransformer - Class in cascading.flow.tez.planner.rule.transformer
BoundaryBalanceCheckpointTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceCheckpointTransformer
BoundaryBalanceGroupBlockingHashJoinTransformer - Class in cascading.flow.tez.planner.rule.transformer
BoundaryBalanceGroupBlockingHashJoinTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceGroupBlockingHashJoinTransformer
BoundaryBalanceGroupSplitHashJoinTransformer - Class in cascading.flow.tez.planner.rule.transformer
BoundaryBalanceGroupSplitHashJoinTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceGroupSplitHashJoinTransformer
BoundaryBalanceGroupSplitSpliceTransformer - Class in cascading.flow.tez.planner.rule.transformer
BoundaryBalanceGroupSplitSpliceTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceGroupSplitSpliceTransformer
BoundaryBalanceHashJoinSameSourceTransformer - Class in cascading.flow.tez.planner.rule.transformer
BoundaryBalanceHashJoinSameSourceTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceHashJoinSameSourceTransformer
BoundaryBalanceHashJoinToHashJoinTransformer - Class in cascading.flow.tez.planner.rule.transformer
BoundaryBalanceHashJoinToHashJoinTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceHashJoinToHashJoinTransformer
BoundaryBalanceJoinSplitTransformer - Class in cascading.flow.tez.planner.rule.transformer
BoundaryBalanceJoinSplitTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceJoinSplitTransformer
BoundaryBalanceSplitToStreamedHashJoinTransformer - Class in cascading.flow.tez.planner.rule.transformer: Inserts Boundary after split that joins back into a HashJoin.
BoundaryBalanceSplitToStreamedHashJoinTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceSplitToStreamedHashJoinTransformer
BoundaryElementFactory - Class in cascading.flow.tez.planner.rule.transformer
BoundaryElementFactory() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryElementFactory
BoundarySelJoinCoGroupExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
BoundarySelJoinCoGroupExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.BoundarySelJoinCoGroupExpressionGraph
BufferedInputStream - Class in cascading.tuple.hadoop.io
BufferedInputStream() - Constructor for class cascading.tuple.hadoop.io.BufferedInputStream
build() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
build() - Method in class cascading.flow.tez.TezCoGroupClosure
buildGraph() - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
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(boolean) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
cachedCounters(boolean) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
cachedCounters() - Method in class cascading.stats.hadoop.CounterCache
cachedCounters(boolean) - Method in class cascading.stats.hadoop.CounterCache
callCopyConstructor(Class, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
captureChildDetailInternal() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats: Returns true if was able to capture/refresh the internal child stats cache.
captureChildDetailInternal() - Method in class cascading.stats.tez.TezNodeStats
captureDetail(CascadingStats.Type) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
captureDetail(CascadingStats.Type) - Method in class cascading.stats.tez.TezStepStats: Method captureDetail captures statistics task details and completion events.
cascading.flow.hadoop - package cascading.flow.hadoop
cascading.flow.hadoop.planner.rule.assertion - package cascading.flow.hadoop.planner.rule.assertion
cascading.flow.hadoop.planner.rule.expression - package cascading.flow.hadoop.planner.rule.expression
cascading.flow.hadoop.planner.rule.expressiongraph - package cascading.flow.hadoop.planner.rule.expressiongraph
cascading.flow.hadoop.planner.rule.partitioner - package cascading.flow.hadoop.planner.rule.partitioner
cascading.flow.hadoop.planner.rule.transformer - package cascading.flow.hadoop.planner.rule.transformer
cascading.flow.hadoop.stream - package cascading.flow.hadoop.stream
cascading.flow.hadoop.util - package cascading.flow.hadoop.util
cascading.flow.tez - package cascading.flow.tez
cascading.flow.tez.planner - package cascading.flow.tez.planner
cascading.flow.tez.planner.rule.annotator - package cascading.flow.tez.planner.rule.annotator
cascading.flow.tez.planner.rule.assertion - package cascading.flow.tez.planner.rule.assertion
cascading.flow.tez.planner.rule.expression - package cascading.flow.tez.planner.rule.expression
cascading.flow.tez.planner.rule.expressiongraph - package cascading.flow.tez.planner.rule.expressiongraph
cascading.flow.tez.planner.rule.partitioner - package cascading.flow.tez.planner.rule.partitioner
cascading.flow.tez.planner.rule.transformer - package cascading.flow.tez.planner.rule.transformer
cascading.flow.tez.stream.element - package cascading.flow.tez.stream.element
cascading.flow.tez.stream.graph - package cascading.flow.tez.stream.graph
cascading.flow.tez.util - package cascading.flow.tez.util
cascading.scheme.hadoop - package cascading.scheme.hadoop
cascading.stats.hadoop - package cascading.stats.hadoop
cascading.stats.tez - package cascading.stats.tez
cascading.stats.tez.util - package cascading.stats.tez.util
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.tuple.tez.util - package cascading.tuple.tez.util
CASCADING_FLOW_EXECUTING - Static variable in class cascading.flow.hadoop.util.HadoopUtil
CASCADING_LOCAL_RESOURCES - Static variable in class cascading.tap.hadoop.DistCacheTap
CASCADING_REMOTE_RESOURCES - Static variable in class cascading.tap.hadoop.DistCacheTap
CASCADING_SOURCE_PATH - Static variable in class cascading.tap.hadoop.io.MultiInputSplit
clean(TezConfiguration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
cleanup() - Method in class cascading.flow.tez.stream.element.TezSinkStage
cleanupJob(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil: May only be called once.
cleanupTapMetaData(Configuration, 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.flow.hadoop.util.LazyCollection
clear() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
clearGroups() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
close() - Method in class cascading.flow.hadoop.util.TimedIterator
close() - Method in class cascading.flow.tez.FlowProcessor
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.tez.util: Class GroupingPartitioner is an implementation of Partitioner.
CoGroupingPartitioner(Configuration) - Constructor for class cascading.tuple.tez.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
collections - Variable in class cascading.flow.hadoop.HadoopCoGroupClosure: Field groups
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
CombineInputPartitionTupleEntryIterator - Class in cascading.tap.hadoop.io
CombineInputPartitionTupleEntryIterator(FlowProcess<? extends Configuration>, Fields, Partition, String, TupleEntrySchemeIterator) - Constructor for class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
commitTask(Configuration) - 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(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
complete(Duct) - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
complete(Duct) - Method in class cascading.flow.tez.stream.element.TezMergeGate
configRuleRegistryDefaults(RuleRegistry) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
ConfigurationSetter - Class in cascading.flow.hadoop
ConfigurationSetter(Configuration) - Constructor for class cascading.flow.hadoop.ConfigurationSetter
configure(JobConf) - Method in class cascading.tap.hadoop.io.MultiInputSplit
ConsecutiveGroupOrMergeExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
ConsecutiveGroupOrMergeExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.ConsecutiveGroupOrMergeExpressionGraph
ConsecutiveGroupOrMergesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner: Merge -> (Merge or GroupBy)
ConsecutiveGroupOrMergesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.ConsecutiveGroupOrMergesNodePartitioner
ConsecutiveTapsNodePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
ConsecutiveTapsNodePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.ConsecutiveTapsNodePartitioner
ConsecutiveTapsPartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
ConsecutiveTapsPartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.ConsecutiveTapsPartitionExpression
ConsecutiveTapsStepPartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
ConsecutiveTapsStepPartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.ConsecutiveTapsStepPartitioner
contains(Object) - Method in class cascading.flow.hadoop.util.FalseCollection
contains(Object) - Method in class cascading.flow.hadoop.util.LazyCollection
containsAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
containsAll(Collection<?>) - Method in class cascading.flow.hadoop.util.LazyCollection
copyConfig(C) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
copyConfiguration(C) - Static method in class cascading.flow.hadoop.util.HadoopUtil
copyConfiguration(Map<Object, Object>, C) - Static method in class cascading.flow.hadoop.util.HadoopUtil
copyConfiguration(Map<Object, Object>, Configuration) - Static method in class cascading.flow.tez.planner.Hadoop2TezPlanner
copyJobConf(C) - Static method in class cascading.flow.hadoop.util.HadoopUtil
copyJobConf(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
copyProperties(Configuration, Map<Object, Object>) - Static method in class cascading.flow.tez.planner.Hadoop2TezPlanner
copyWith(TezConfiguration) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
countDownLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
COUNTER_FETCH_RETRIES_PROPERTY - Static variable in class cascading.stats.hadoop.CounterCache
COUNTER_MAX_AGE_PROPERTY - Static variable in class cascading.stats.hadoop.CounterCache
COUNTER_TIMEOUT_PROPERTY - Static variable in class cascading.stats.hadoop.CounterCache
counterCache - Variable in class cascading.stats.hadoop.BaseHadoopNodeStats
counterCache - Variable in class cascading.stats.hadoop.BaseHadoopStepStats
CounterCache<JobStatus,Counters> - Class in cascading.stats.hadoop
CounterCache(CascadingStats, Configuration) - Constructor for class cascading.stats.hadoop.CounterCache
create(ElementGraph, FlowElement) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner.IntermediateBoundaryElementFactory
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
create(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
create(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
createBoundaryStage(Boundary, IORole) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createClosure() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
createClosure() - Method in class cascading.flow.tez.stream.element.TezCoGroupGate
createClosure() - Method in class cascading.flow.tez.stream.element.TezGroupByGate
createCoGroupGate(CoGroup, IORole) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createConfiguration(Map<Object, Object>) - Static method in class cascading.flow.tez.planner.Hadoop2TezPlanner
createDefaultRuleRegistrySet() - Method in class cascading.flow.tez.Hadoop2TezFlowConnector
createFlow(FlowDef) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
createFlowPlanner() - Method in class cascading.flow.tez.Hadoop2TezFlowConnector
createFlowStep(ElementGraph, FlowNodeGraph) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
createFlowStepJob(ClientState, FlowProcess<TezConfiguration>, TezConfiguration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
createGroupByGate(GroupBy, IORole) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createInitializedConfig(FlowProcess<TezConfiguration>, TezConfiguration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
createIterator(IndexTuple, Iterator<IndexTuple>) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
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
createMergeStage(Merge, IORole) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createNonBlockingJoinGate(HashJoin) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createOutputCollector() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
createOutputCollector() - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
createOutputCollector() - Method in class cascading.flow.tez.stream.element.TezGroupGate
createOutputCollector() - Method in class cascading.flow.tez.stream.element.TezMergeGate
createProperties(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
createResource(Configuration) - Method in class cascading.tap.hadoop.Hfs
createSinkGroupByGate(GroupBy) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createSinkStage(Tap) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createSourceGroupByGate(GroupBy) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createSourceStage(Tap, FlowProcess) - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
createStepStats(ClientState) - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
createTezConf(Map<Object, Object>, TezConfiguration) - Static method in class cascading.flow.tez.util.TezUtil
createTimelineClient(DAGClient) - Static method in class cascading.stats.tez.util.TezStatsUtil: Only called if the service is enabled
createTupleCollection(Fields) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
createTupleCollection(Fields) - Method in class cascading.flow.tez.TezCoGroupClosure
createTupleCollection(Tuple) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
createTupleEntrySchemeCollector(FlowProcess<? extends Configuration>, Tap, String, long) - Method in class cascading.tap.hadoop.PartitionTap
createTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, 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
createVertex(FlowProcess<TezConfiguration>, TezConfiguration, FlowNode) - Method in class cascading.flow.tez.Hadoop2TezFlowStep

D

decodeBytes(String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
DEFAULT_CACHED_AGE_MAX - Static variable in class cascading.stats.hadoop.CounterCache
DEFAULT_CHARSET - Static variable in class cascading.scheme.hadoop.TextDelimited
DEFAULT_CHARSET - Static variable in class cascading.scheme.hadoop.TextLine
DEFAULT_FETCH_LIMIT - Static variable in class cascading.stats.tez.TezNodeStats
DEFAULT_FETCH_RETRIES - Static variable in class cascading.stats.hadoop.CounterCache
DEFAULT_SOURCE_FIELDS - Static variable in class cascading.scheme.hadoop.TextLine: Field DEFAULT_SOURCE_FIELDS
DEFAULT_TIMEOUT_TIMEOUT_SEC - Static variable in class cascading.stats.hadoop.CounterCache
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(FlowProcess<? extends Configuration>, String) - Method in class cascading.tap.hadoop.Hfs
deleteChildResource(Configuration, String) - Method in class cascading.tap.hadoop.Hfs
deleteResource(Configuration) - Method in class cascading.tap.hadoop.Hfs
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 - Class in cascading.tap.hadoop: Class Dfs is a Tap class that provides access to the Hadoop Distributed File System.
Dfs(Scheme, URI) - Constructor for class cascading.tap.hadoop.Dfs: Constructor Dfs creates a new Dfs instance.
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, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs: Constructor Dfs creates a new Dfs instance.
diffConfigIntoMap(C, C) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
DistCacheTap - Class in cascading.tap.hadoop
DistCacheTap(Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.DistCacheTap
DualStreamedAccumulatedExpression - Class in cascading.flow.hadoop.planner.rule.expression
DualStreamedAccumulatedExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.DualStreamedAccumulatedExpression
DualStreamedAccumulatedMergeNodeAssert - Class in cascading.flow.tez.planner.rule.assertion: Throws a planner failure if a Tap, both accumulating and streamed, flows into a single merge within a given pipeline.
DualStreamedAccumulatedMergeNodeAssert() - Constructor for class cascading.flow.tez.planner.rule.assertion.DualStreamedAccumulatedMergeNodeAssert
DualStreamedAccumulatedMergePipelineAssert - Class in cascading.flow.hadoop.planner.rule.assertion: Throws a planner failure if a Tap, both accumulating and streamed, flows into a single merge within a given pipeline.
DualStreamedAccumulatedMergePipelineAssert() - Constructor for class cascading.flow.hadoop.planner.rule.assertion.DualStreamedAccumulatedMergePipelineAssert
dumpDebugInfo() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob

E

encodeBytes(byte[]) - Static method in class cascading.flow.hadoop.util.HadoopUtil
equals(Object) - Method in class cascading.flow.hadoop.util.LazyCollection
equals(Object) - Method in class cascading.scheme.hadoop.WritableSequenceFile
equals(Object) - Method in class cascading.tap.hadoop.GlobHfs
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
fetchAttempts - Variable in class cascading.stats.hadoop.CounterCache
findMainClass(Class) - Static method in class cascading.flow.hadoop.util.HadoopUtil
FlowProcessor - Class in cascading.flow.tez
FlowProcessor(ProcessorContext) - Constructor for class cascading.flow.tez.FlowProcessor
flush() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
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

get(String) - Method in class cascading.flow.hadoop.ConfigurationSetter
getAllLocalResources() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
getAttempts() - Method in class cascading.stats.tez.TezSliceStats
getBlockSize(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs: Method getBlockSize returns the blocksize specified by the underlying file system for this resource.
getBlockSize(Configuration) - 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(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
getChildIdentifiers(Configuration) - Method in class cascading.tap.hadoop.Hfs
getChildIdentifiers(FlowProcess<? extends Configuration>, int, boolean) - Method in class cascading.tap.hadoop.Hfs
getChildIdentifiers(Configuration, int, boolean) - Method in class cascading.tap.hadoop.Hfs
getChildren() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
getChildWith(String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
getClass(String) - Method in class cascading.tuple.hadoop.TupleSerialization
getClassNameFor(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
getCodec(FlowProcess<? extends Configuration>, String) - Static method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
getCombinedInputMaxSize() - Method in class cascading.tap.hadoop.HfsProps
getCombinedInputSafeMode(Configuration) - Static method in class cascading.tap.hadoop.Hfs
getCommonPaths(Map<String, Path>, Map<String, Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
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
getConf() - Method in class cascading.tuple.hadoop.util.HasherPartitioner
getConfig(Configuration, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
getConfig() - Method in class cascading.flow.tez.Hadoop2TezFlow
getConfig() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
getConfigAsProperties() - Method in class cascading.flow.tez.Hadoop2TezFlow
getConfigAsProperties() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
getConfigCopy() - Method in class cascading.flow.tez.Hadoop2TezFlow
getConfigCopy() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
getConfiguration() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess: Method getJobConf returns the jobConf of this HadoopFlowProcess object.
getContext() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
getCounterGroups() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats: Method getCounterGroups returns all of the Hadoop counter groups.
getCounterGroups() - Method in class cascading.stats.hadoop.BaseHadoopStepStats: Method getCounterGroups returns all of the Hadoop counter groups.
getCounterGroups() - Method in class cascading.stats.hadoop.CounterCache
getCounterGroups() - Method in class cascading.stats.tez.TezSliceStats
getCounterGroupsMatching(String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats: Method getCounterGroupsMatching returns all the Hadoop counter groups that match the give regex pattern.
getCounterGroupsMatching(String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats: Method getCounterGroupsMatching returns all the Hadoop counter groups that match the give regex pattern.
getCounterGroupsMatching(String) - Method in class cascading.stats.hadoop.CounterCache
getCounters(JobStatus) - Method in class cascading.stats.hadoop.CounterCache
getCounters() - Method in class cascading.stats.tez.TezSliceStats
getCounters() - Method in class cascading.stats.tez.util.TaskStatus
getCountersFor(String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats: Method getCountersFor returns the Hadoop counters for the given group.
getCountersFor(String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats: Method getCountersFor returns the Hadoop counters for the given group.
getCountersFor(Counters, String) - Method in class cascading.stats.hadoop.CounterCache
getCountersFor(String) - Method in class cascading.stats.hadoop.CounterCache
getCountersFor(TezCounters, String) - Method in class cascading.stats.tez.TezCounterCache
getCountersFor(String) - Method in class cascading.stats.tez.TezSliceStats
getCountersFor(Class<? extends Enum>) - Method in class cascading.stats.tez.TezSliceStats
getCounterValue(Enum) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
getCounterValue(String, String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
getCounterValue(Enum) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats: Method getCounterValue returns the Hadoop counter value for the given counter enum.
getCounterValue(String, String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats: Method getCounterValue returns the Hadoop counter value for the given group and counter name.
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(Counters, Enum) - Method in class cascading.stats.hadoop.CounterCache
getCounterValue(Counters, String, String) - Method in class cascading.stats.hadoop.CounterCache
getCounterValue(Enum) - Method in class cascading.stats.hadoop.CounterCache
getCounterValue(String, String) - Method in class cascading.stats.hadoop.CounterCache
getCounterValue(TezCounters, Enum) - Method in class cascading.stats.tez.TezCounterCache
getCounterValue(TezCounters, String, String) - Method in class cascading.stats.tez.TezCounterCache
getCounterValue(Enum) - Method in class cascading.stats.tez.TezSliceStats
getCounterValue(String, String) - Method in class cascading.stats.tez.TezSliceStats
getCurrentIdentifier(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.PartitionTap
getCurrentKey() - Method in class cascading.flow.tez.util.SecondarySortKeyValuesReader
getCurrentSliceNum() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess: 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.
getCurrentUser() - Static method in class cascading.flow.tez.util.TezUtil
getCurrentValues() - Method in class cascading.flow.tez.util.SecondarySortKeyValuesReader
getDAGClient() - Method in class cascading.stats.tez.util.TezTimelineClient
getDAGStatus(Set<StatusGetOpts>) - Method in class cascading.stats.tez.util.TezTimelineClient
getDagStatusWithCounters(DAGClient) - Static method in class cascading.stats.tez.util.TezStatsUtil
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
getDefaultConfig() - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
getDefaultFileSystem(Configuration) - Method in class cascading.tap.hadoop.Dfs
getDefaultFileSystem(Configuration) - Method in class cascading.tap.hadoop.Hfs
getDefaultFileSystemURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs: Method getDefaultFileSystemURIScheme returns the URI scheme for the default Hadoop FileSystem.
getDefaultFS(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
getDefaultIntermediateSchemeClass() - Method in class cascading.flow.tez.Hadoop2TezFlowConnector
getDefaultURIScheme(Tap) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
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.tez.TezSliceStats
getDiagnostics() - Method in class cascading.stats.tez.util.TaskStatus
getEdgeSinkID(LogicalOutput, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
getEdgeSourceID(LogicalInput, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
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.
getEndTime() - Method in class cascading.stats.tez.util.TaskStatus
getEventId() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
getFailedTaskCount() - Method in class cascading.stats.tez.TezNodeStats
getFieldComparatorsFrom(Configuration, String) - Static method in class cascading.tuple.hadoop.util.DeserializerComparator
getFileStatus(Path) - Method in class cascading.tap.hadoop.io.HttpFileSystem
getFileSystem(Configuration) - Method in class cascading.tap.hadoop.Hfs
getFileSystem(Configuration) - Method in class cascading.tap.hadoop.Lfs
getFlowProcess() - Method in class cascading.flow.tez.Hadoop2TezFlow
getFlowStagingPath() - Method in class cascading.flow.tez.Hadoop2TezFlow
getFrameworkClient() - Method in class cascading.stats.tez.util.TezTimelineClient
getFullIdentifier(Configuration) - Method in class cascading.tap.hadoop.Hfs
getGrouping() - Method in class cascading.flow.hadoop.HadoopGroupByClosure
getGrouping() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
getGroupNames(Counters) - Method in class cascading.stats.hadoop.CounterCache
getGroupNames(TezCounters) - Method in class cascading.stats.tez.TezCounterCache
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
getID() - Method in class cascading.stats.tez.TezSliceStats
getIdentifier() - Method in class cascading.tap.hadoop.GlobHfs
getIdentifier() - Method in class cascading.tap.hadoop.Hfs
getInputConfiguration(LogicalInput) - Static method in class cascading.flow.tez.util.TezUtil
getIterator(int) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
getIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
getJobConfs(Configuration, List<Map<String, String>>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
getJobPollingInterval(Configuration) - Static method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
getJobStatusClient() - Method in class cascading.stats.hadoop.BaseHadoopStepStats: Method getRunningJob returns the Hadoop RunningJob managing this Hadoop job.
getJobStatusClient() - Method in class cascading.stats.hadoop.CounterCache
getJsonObject(JSONArray, int) - Method in class cascading.stats.tez.util.TezTimelineClient
getKilledTaskCount() - Method in class cascading.stats.tez.TezNodeStats
getKind() - Method in class cascading.stats.tez.TezNodeStats
getKind() - Method in class cascading.stats.tez.TezSliceStats
getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.tez.TezSliceStats
getLastSuccessfulFetch() - Method in class cascading.stats.hadoop.CounterCache
getLength() - Method in class cascading.tap.hadoop.io.MultiInputSplit
getLength() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
getLocalCacheFiles(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.BaseDistCacheTap
getLocalCacheFiles(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.DistCacheTap
getLocalFS(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
getLocalModeScheme(Configuration, 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
getMaxNumParallelSteps() - Method in class cascading.flow.tez.Hadoop2TezFlow
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(Configuration) - Method in class cascading.tap.hadoop.Hfs
getNextElement() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
getNumElements() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
getNumProcessSlices() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
getOutput() - Method in class cascading.flow.tez.stream.element.TezSinkStage
getOutputCollector() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
getOutputConfiguration(LogicalOutput) - Static method in class cascading.flow.tez.util.TezUtil
getOutputPath(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
getOutputPath(Configuration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
getParallelism(FlowNode, JobConf) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
getParent(LazyCollection) - Static method in class cascading.flow.hadoop.util.LazyCollection
getParentStatus() - Method in class cascading.stats.tez.TezSliceStats
getPartition(Object, Object, int) - Method in class cascading.tuple.tez.util.CoGroupingPartitioner
getPartition(Object, Object, int) - Method in class cascading.tuple.tez.util.GroupingSortingPartitioner
getPartition(Object, Object, int) - Method in class cascading.tuple.tez.util.TuplePartitioner
getPath() - Method in class cascading.tap.hadoop.Hfs
getPlannerInfo(String) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
getPlatformInfo() - Static method in class cascading.flow.hadoop.util.HadoopUtil
getPlatformInfo(Class, String, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
getPlatformInfo() - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
getPlatformVersion() - Static method in class cascading.stats.tez.util.TezStatsUtil
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
getProcessAttemptID() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
getProcessDuration() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
getProcessFinishTime() - Method in class cascading.stats.tez.TezSliceStats
getProcessProgress() - Method in class cascading.stats.tez.TezSliceStats
getProcessRunTime() - Method in class cascading.stats.tez.TezSliceStats
getProcessSliceID() - Method in class cascading.stats.tez.TezSliceStats
getProcessStartTime() - Method in class cascading.stats.tez.TezSliceStats
getProcessStatus() - Method in class cascading.stats.tez.TezSliceStats
getProcessStatus() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
getProcessStepID() - Method in class cascading.stats.tez.TezSliceStats
getProgress() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
getProgress() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
getProperty(String) - Method in class cascading.flow.tez.Hadoop2TezFlow: Method getProperty returns the value associated with the given key from the underlying properties system.
getProperty(String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
getPropertyKeys() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
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
getRemoveJsonObject(JSONArray, int, boolean) - Method in class cascading.stats.tez.util.TezTimelineClient
getReplication(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs: Method getReplication returns the replication specified by the underlying file system for this resource.
getReplication(Configuration) - Method in class cascading.tap.hadoop.Hfs: Method getReplication returns the replication specified by the underlying file system for this resource.
getReporter() - Method in interface cascading.flow.hadoop.MapRed
getReporter() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess: Method getReporter returns the reporter of this HadoopFlowProcess object.
getRunningTaskCount() - Method in class cascading.stats.tez.TezNodeStats
getScheduledTime() - Method in class cascading.stats.tez.util.TaskStatus
getSchemeClass() - Method in class cascading.tap.hadoop.util.TempHfs
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(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
getSize(Configuration) - 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.tez.util.TaskStatus
getStatus() - Method in class cascading.stats.tez.TezSliceStats
getStatus() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
getStatus() - Method in class cascading.stats.tez.util.TaskStatus
getStatusURL() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
getStreamedHead() - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
getSucceededTaskCount() - Method in class cascading.stats.tez.TezNodeStats
getSuccessfulAttemptID() - Method in class cascading.stats.tez.util.TaskStatus
getTaps() - Method in class cascading.tap.hadoop.GlobHfs
getTaskID() - Method in class cascading.stats.tez.util.TaskStatus
getTemporaryDirectory() - Method in class cascading.tap.hadoop.HfsProps
getTempPath(Configuration) - Static method in class cascading.tap.hadoop.Hfs
getThrowable() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
getTotalSliceCPUMilliSeconds() - Method in class cascading.flow.tez.Hadoop2TezFlow
getTotalTaskCount() - Method in class cascading.stats.tez.TezNodeStats
getTrackingURL(TezClient, DAGClient) - Static method in class cascading.stats.tez.util.TezStatsUtil
getUri() - Method in class cascading.tap.hadoop.io.HttpFileSystem
getURIScheme(Tap) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
getURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs
getUseCombinedInput(Configuration) - Static method in class cascading.tap.hadoop.Hfs
getValueIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
getValueIterator(int) - Method in class cascading.flow.tez.TezGroupByClosure
getVertexChild(String) - Method in class cascading.stats.tez.util.TezTimelineClient
getVertexChild(String) - Method in interface cascading.stats.tez.util.TimelineClient
getVertexChildren(String, int, String) - Method in class cascading.stats.tez.util.TezTimelineClient
getVertexChildren(String, int, String) - Method in interface cascading.stats.tez.util.TimelineClient
getVertexID(String) - Method in class cascading.stats.tez.util.TezTimelineClient
getVertexID(String) - Method in interface cascading.stats.tez.util.TimelineClient
getVertexStatus(String, Set<StatusGetOpts>) - Method in class cascading.stats.tez.util.TezTimelineClient
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<Configuration, RecordReader, ?, ?, ?>, String) - Constructor for class cascading.tap.hadoop.GlobHfs: Constructor GlobHfs creates a new GlobHfs instance.
GlobHfs(Scheme<Configuration, 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
GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
GROUP - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitSpliceExpression
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
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.tez.util: Class GroupingPartitioner is an implementation of Partitioner.
GroupingSortingPartitioner(Configuration) - Constructor for class cascading.tuple.tez.util.GroupingSortingPartitioner
GroupMergeToTapBoundaryExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
GroupMergeToTapBoundaryExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.GroupMergeToTapBoundaryExpressionGraph
GroupTapNodePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
GroupTapNodePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.GroupTapNodePartitioner
GroupTapPartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
GroupTapPartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.GroupTapPartitionExpression

H

Hadoop18TapUtil - Class in cascading.tap.hadoop.util
Hadoop18TapUtil() - Constructor for class cascading.tap.hadoop.util.Hadoop18TapUtil
Hadoop2TezFlow - Class in cascading.flow.tez: Class HadoopFlow is the Apache Hadoop specific implementation of a Flow.
Hadoop2TezFlow() - Constructor for class cascading.flow.tez.Hadoop2TezFlow
Hadoop2TezFlow(PlatformInfo, Map<Object, Object>, TezConfiguration, String) - Constructor for class cascading.flow.tez.Hadoop2TezFlow
Hadoop2TezFlow(PlatformInfo, Map<Object, Object>, TezConfiguration, FlowDef) - Constructor for class cascading.flow.tez.Hadoop2TezFlow
Hadoop2TezFlowConnector - Class in cascading.flow.tez
Hadoop2TezFlowConnector() - Constructor for class cascading.flow.tez.Hadoop2TezFlowConnector
Hadoop2TezFlowConnector(Map<Object, Object>) - Constructor for class cascading.flow.tez.Hadoop2TezFlowConnector
Hadoop2TezFlowConnector(RuleRegistrySet) - Constructor for class cascading.flow.tez.Hadoop2TezFlowConnector
Hadoop2TezFlowConnector(Map<Object, Object>, RuleRegistrySet) - Constructor for class cascading.flow.tez.Hadoop2TezFlowConnector
Hadoop2TezFlowProcess - Class in cascading.flow.tez: Class HadoopFlowProcess is an implementation of FlowProcess for Hadoop.
Hadoop2TezFlowProcess() - Constructor for class cascading.flow.tez.Hadoop2TezFlowProcess
Hadoop2TezFlowProcess(TezConfiguration) - Constructor for class cascading.flow.tez.Hadoop2TezFlowProcess
Hadoop2TezFlowProcess(FlowSession, ProcessorContext, TezConfiguration) - Constructor for class cascading.flow.tez.Hadoop2TezFlowProcess
Hadoop2TezFlowProcess(Hadoop2TezFlowProcess, TezConfiguration) - Constructor for class cascading.flow.tez.Hadoop2TezFlowProcess
Hadoop2TezFlowStep - Class in cascading.flow.tez
Hadoop2TezFlowStep(ElementGraph, FlowNodeGraph) - Constructor for class cascading.flow.tez.Hadoop2TezFlowStep
Hadoop2TezFlowStepJob - Class in cascading.flow.tez.planner
Hadoop2TezFlowStepJob(ClientState, BaseFlowStep<TezConfiguration>, TezConfiguration, DAG) - Constructor for class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
Hadoop2TezPlanner - Class in cascading.flow.tez.planner
Hadoop2TezPlanner() - Constructor for class cascading.flow.tez.planner.Hadoop2TezPlanner
Hadoop2TezPlanner.IntermediateBoundaryElementFactory - Class in cascading.flow.tez.planner
Hadoop2TezPlanner.IntermediateBoundaryElementFactory() - Constructor for class cascading.flow.tez.planner.Hadoop2TezPlanner.IntermediateBoundaryElementFactory
Hadoop2TezStreamGraph - Class in cascading.flow.tez.stream.graph
Hadoop2TezStreamGraph(Hadoop2TezFlowProcess, FlowNode, Map<String, LogicalInput>, Map<String, LogicalOutput>) - Constructor for class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
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
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
HadoopGroupGate - Class in cascading.flow.hadoop.stream
HadoopGroupGate(FlowProcess, Splice, IORole) - Constructor for class cascading.flow.hadoop.stream.HadoopGroupGate
HadoopMemoryJoinGate - Class in cascading.flow.hadoop.stream
HadoopMemoryJoinGate(FlowProcess<? extends Configuration>, HashJoin) - Constructor for class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
HadoopMemoryJoinGate.Spill - Enum in cascading.flow.hadoop.stream
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, Configuration) - 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<? extends Configuration>) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
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<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, OutputCollector) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
HadoopTupleEntrySchemeIterator - Class in cascading.tap.hadoop.io
HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, Tap, RecordReader) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, 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
handleEvents(List<Event>) - Method in class cascading.flow.tez.FlowProcessor
hashCode() - Method in class cascading.flow.hadoop.util.LazyCollection
hashCode() - Method in class cascading.scheme.hadoop.WritableSequenceFile
hashCode() - Method in class cascading.tap.hadoop.GlobHfs
hashCode(byte[]) - Method in class cascading.tuple.hadoop.util.BytesComparator
HASHER_PARTITIONER_USE_LEGACY_HASH - Static variable in class cascading.tuple.hadoop.util.HasherPartitioner
HasherPartitioner - Class in cascading.tuple.hadoop.util: Super class of all Hadoop partitioners.
HasherPartitioner() - Constructor for class cascading.tuple.hadoop.util.HasherPartitioner
HashJoinHadoop2TezRuleRegistry - Class in cascading.flow.tez.planner: The HashJoinHadoop2TezRuleRegistry provides support for assemblies using HashJoin pipes.
HashJoinHadoop2TezRuleRegistry() - Constructor for class cascading.flow.tez.planner.HashJoinHadoop2TezRuleRegistry
hasNext() - Method in class cascading.flow.hadoop.util.TimedIterator
hasNext() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
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<Configuration, RecordReader, OutputCollector, ?, ?>) - Constructor for class cascading.tap.hadoop.Hfs
Hfs(Scheme<Configuration, RecordReader, OutputCollector, ?, ?>, String) - Constructor for class cascading.tap.hadoop.Hfs: Constructor Hfs creates a new Hfs instance.
Hfs(Scheme<Configuration, 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.tez.Hadoop2TezFlowProcess
increment(String, String, long) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
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>, TezConfiguration) - Method in class cascading.flow.tez.Hadoop2TezFlow
initFromProperties(Map<Object, Object>) - Method in class cascading.flow.tez.Hadoop2TezFlow
initFromSinks(FlowNode, FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
initFromSources(FlowNode, FlowProcess<TezConfiguration>, Configuration, Map<String, LocalResource>) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
initFromTraps(FlowNode, FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
initialize() - Method in class cascading.flow.tez.FlowProcessor
initialize(FlowConnector, Map<Object, Object>) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
initialize() - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
initialize() - Method in class cascading.flow.tez.stream.element.TezGroupGate
initialize() - Method in class cascading.flow.tez.stream.element.TezMergeGate
initialize(URI, Configuration) - Method in class cascading.tap.hadoop.io.HttpFileSystem
initialize() - Method in class cascading.tap.hadoop.io.TapOutputCollector
initialize(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
initialize(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
initLists() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
initLog4j(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
initLog4j(Configuration) - 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.tez.planner.Hadoop2TezFlowStepJob
internalClean(boolean) - Method in class cascading.flow.tez.Hadoop2TezFlow
internalCleanup() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
internalIsStartedRunning() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
internalJobId() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
internalNonBlockingIsComplete() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
internalNonBlockingIsSuccessful() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
internalNonBlockingStart() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
internalShutdown() - Method in class cascading.flow.tez.Hadoop2TezFlow
internalStart() - Method in class cascading.flow.tez.Hadoop2TezFlow
isAllChildrenFinished() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
isCounterStatusInitialized() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
isDirectory(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
isDirectory(Configuration) - 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
isEmpty() - Method in class cascading.flow.hadoop.util.LazyCollection
isFileOutputFormat(Class) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
isInflow(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
isLocal(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
isPreserveTemporaryFiles() - Method in class cascading.flow.tez.Hadoop2TezFlow: Method isPreserveTemporaryFiles returns false if temporary files will be cleaned when this Flow completes.
isRemoteExecution() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
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
isYARN(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
iterator() - Method in class cascading.flow.hadoop.util.FalseCollection
iterator() - Method in class cascading.flow.hadoop.util.LazyCollection
iterators(TimedIterator<V>...) - Static method in class cascading.flow.hadoop.util.TimedIterator

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

K

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

L

LazyCollection - Class in cascading.flow.hadoop.util
LazyCollection(Collection<Tuple>) - Constructor for class cascading.flow.hadoop.util.LazyCollection
LazySpillableTupleCollection - Class in cascading.flow.hadoop.util
LazySpillableTupleCollection(Collection<Tuple>) - Constructor for class cascading.flow.hadoop.util.LazySpillableTupleCollection
Lfs - Class in cascading.tap.hadoop: Class Lfs is a Tap class that provides access to the Local File System via Hadoop.
Lfs(Scheme, String) - Constructor for class cascading.tap.hadoop.Lfs: Constructor Lfs creates a new Lfs instance.
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
logicalInput - Variable in class cascading.flow.tez.stream.element.TezBoundaryStage
logicalInputs - Variable in class cascading.flow.tez.stream.element.TezGroupGate
logicalInputs - Variable in class cascading.flow.tez.stream.element.TezMergeGate
logicalOutput - Variable in class cascading.flow.tez.stream.element.TezGroupGate
logicalOutputs - Variable in class cascading.flow.tez.stream.element.TezBoundaryStage
logicalOutputs - Variable in class cascading.flow.tez.stream.element.TezMergeGate

M

makeEncodedString(Object[]) - Method in class cascading.scheme.hadoop.TextLine
makeIterator(int, Iterator) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
makeTemporaryPathDirString(String) - Method in class cascading.tap.hadoop.Hfs
makeTempPath(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
makeTempTap(String, String) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
makeURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs
MalformedJoinExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph
MalformedJoinExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.MalformedJoinExpressionGraph
map() - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
map() - Method in class cascading.flow.tez.stream.element.TezMergeGate
MapRed - Interface in cascading.flow.hadoop: A helper interface to allow a mapred.* package implementation instances to be exposed for internal use.
maxAge - Variable in class cascading.stats.hadoop.CounterCache
maxFetchAttempts - Variable in class cascading.stats.hadoop.CounterCache
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
MERGE - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
mergeConf(J, Map<String, String>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
mergeMapIntoConfig(TezConfiguration, Map<String, String>) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
mkdirs(Path, FsPermission) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
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<? extends Configuration>, Tap) - Constructor for class cascading.tap.hadoop.io.MultiRecordReaderIterator: Constructor TapIterator creates a new TapIterator instance.
MultiTapGroupNodePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
MultiTapGroupNodePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.MultiTapGroupNodePartitioner

N

needsTaskCommit(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
newConfig(TezConfiguration) - Method in class cascading.flow.tez.Hadoop2TezFlow
newInstance(String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
next() - Method in class cascading.flow.hadoop.util.TimedIterator
next() - Method in class cascading.flow.tez.util.SecondarySortKeyValuesReader
next(K, V) - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
next() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
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
NoGroupMergeBoundaryTapExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
NoGroupMergeBoundaryTapExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.NoGroupMergeBoundaryTapExpressionGraph
NoGroupTapExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph
NoGroupTapExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.NoGroupTapExpressionGraph
NoHashJoinAssert - Class in cascading.flow.tez.planner.rule.assertion: Verifies that there are no HashJoin pipes in the assembly.
NoHashJoinAssert() - Constructor for class cascading.flow.tez.planner.rule.assertion.NoHashJoinAssert
NoHashJoinHadoop2TezRuleRegistry - Class in cascading.flow.tez.planner: The NoHashJoinHadoop2TezRuleRegistry assumes the plan has no HashJoin Pipes in the assembly, otherwise an planner failure will be thrown.
NoHashJoinHadoop2TezRuleRegistry() - Constructor for class cascading.flow.tez.planner.NoHashJoinHadoop2TezRuleRegistry
NoSpliceTapExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
NoSpliceTapExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.NoSpliceTapExpressionGraph
numSelfJoins - Variable in class cascading.flow.hadoop.HadoopCoGroupClosure

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<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.BaseDistCacheTap
openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.Hfs
openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.PartitionTap
openForWrite(FlowProcess<? extends Configuration>, OutputCollector) - Method in class cascading.tap.hadoop.Hfs
openSystemIntermediateForWrite() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
openTapForRead(Tap) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
openTapForWrite(Tap) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
openTrapForWrite(Tap) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
outgoingScopeFor(Set<Scope>) - Method in class cascading.tap.hadoop.util.TempHfs

P

pack(Object, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
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.
PLATFORM_NAME - Static variable in class cascading.flow.tez.planner.Hadoop2TezPlanner
prepare() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
prepare() - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
prepare() - Method in class cascading.flow.tez.stream.element.TezGroupGate
prepare() - Method in class cascading.flow.tez.stream.element.TezMergeGate
prepare() - Method in class cascading.flow.tez.stream.element.TezSinkStage
prepare() - Method in class cascading.flow.tez.stream.element.TezSourceStage
presentSinkFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextDelimited
presentSinkFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextLine
presentSourceFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextDelimited
presentSourceFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextLine

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
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.HadoopGroupGate
receive(Duct, TupleEntry) - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
receive(Duct, TupleEntry) - Method in class cascading.flow.tez.stream.element.TezMergeGate
recordChildStats() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats: Synchronized to prevent state changes mid record, #stop may be called out of band
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() - Method in class cascading.flow.tez.stream.element.TezCoGroupGate
reduce() - Method in class cascading.flow.tez.stream.element.TezGroupByGate
reduce() - Method in class cascading.flow.tez.stream.element.TezGroupGate
remove(Object) - Method in class cascading.flow.hadoop.util.FalseCollection
remove(Object) - Method in class cascading.flow.hadoop.util.LazyCollection
remove() - Method in class cascading.flow.hadoop.util.TimedIterator
remove() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
remove() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
removeAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
removeAll(Collection<?>) - Method in class cascading.flow.hadoop.util.LazyCollection
RemoveMalformedHashJoinNodeTransformer - Class in cascading.flow.tez.planner.rule.transformer
RemoveMalformedHashJoinNodeTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.RemoveMalformedHashJoinNodeTransformer
RemoveMalformedHashJoinPipelineTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
RemoveMalformedHashJoinPipelineTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.RemoveMalformedHashJoinPipelineTransformer
removePropertiesFrom(Configuration, String...) - Static method in class cascading.flow.hadoop.util.HadoopUtil
removeStateFromDistCache(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
RemoveStreamedBranchTransformer - Class in cascading.flow.hadoop.planner.rule.transformer: RemoveStreamedBranchTransformer is disabled, enable when GraphFinder supports captured edges.
RemoveStreamedBranchTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.RemoveStreamedBranchTransformer
rename(Path, Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
reset(Tuple, Iterator<Tuple>[]) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
reset(Tuple, Iterator<Tuple>[]) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
reset(Iterator<Tuple>) - Method in class cascading.flow.hadoop.util.FalseCollection
reset(Iterator<Tuple>) - Method in class cascading.flow.hadoop.util.LazyCollection
reset(V) - Method in interface cascading.flow.hadoop.util.ResettableCollection
reset(Iterable<V>) - Method in class cascading.flow.hadoop.util.TimedIterator
reset(Iterator<V>) - Method in class cascading.flow.hadoop.util.TimedIterator
reset(byte[], int, int) - Method in class cascading.tuple.hadoop.io.BufferedInputStream
resetFileStatuses() - Method in class cascading.tap.hadoop.Hfs: Method resetFileStatuses removes the status cache, if any.
ResettableCollection<V> - Interface in cascading.flow.hadoop.util
resolvePaths(Configuration, Collection<String>, String, String, Map<String, Path>, Map<String, Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
resourceExists(Configuration) - Method in class cascading.tap.hadoop.Hfs
retainAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
retainAll(Collection<?>) - Method in class cascading.flow.hadoop.util.LazyCollection
retrieveSourceFields(FlowProcess<? extends Configuration>, 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(Map<String, LogicalInput>, Map<String, LogicalOutput>) - Method in class cascading.flow.tez.FlowProcessor
run(Object) - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
run(Object) - Method in class cascading.flow.tez.stream.element.TezGroupGate
run(Object) - Method in class cascading.flow.tez.stream.element.TezMergeGate
run(Object) - Method in class cascading.flow.tez.stream.element.TezSourceStage

S

SecondarySortKeyValuesReader - Class in cascading.flow.tez.util
SecondarySortKeyValuesReader(KeyValuesReader, Comparator<Tuple>) - Constructor for class cascading.flow.tez.util.SecondarySortKeyValuesReader
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, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
serializeBase64(T, Configuration, 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
set(String, String) - Method in class cascading.flow.hadoop.ConfigurationSetter
setCharsetName(String) - Method in class cascading.scheme.hadoop.TextLine
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
setConf(Configuration) - Method in class cascading.tuple.hadoop.util.HasherPartitioner
setConfigProperty(TezConfiguration, Object, Object) - Method in class cascading.flow.tez.Hadoop2TezFlow
setCounters(Map<String, Map<String, Long>>) - Method in class cascading.stats.tez.TezSliceStats
setDiagnostics(String) - Method in class cascading.stats.tez.TezSliceStats
setFinishTime(long) - Method in class cascading.stats.tez.TezSliceStats
setGrouping(Tuple) - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
setHadoopSerializations(List<String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps: Method setHadoopSerializations sets the Hadoop serialization classNames to be used as properties.
setIsInflow(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
setLastFetch(long) - Method in class cascading.stats.tez.TezSliceStats
setLocal(Configuration) - 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
setMRProperties(ProcessorContext, Configuration, boolean) - Static method in class cascading.flow.tez.util.TezUtil
setNewApi(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
setOutputCollector(OutputCollector) - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
setOutputPath(Configuration, Path) - Static method in class cascading.flow.hadoop.util.HadoopUtil
setRecordReader(RecordReader) - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
setSerializations(Configuration) - 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
setSourcePathForSplit(MRInput, MRReader, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
setSpillListener(Spillable.SpillListener) - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
setSpillStrategy(Spillable.SpillStrategy) - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
setStartTime(long) - Method in class cascading.stats.tez.TezSliceStats
setStatus(String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
setStatus(CascadingStats.Status) - Method in class cascading.stats.tez.TezSliceStats
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
setSubmitTime(long) - Method in class cascading.stats.tez.TezSliceStats
setSuccessfulAttemptID(String) - Method in class cascading.stats.tez.TezSliceStats
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.
setupJob(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil: should only be called if not in a Flow
setupTask(Configuration) - 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
setWriter(Writer) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
SHARED_GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitExpression
SHARED_GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitJoinExpression
SHARED_GROUP - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitHashJoinExpression
SHARED_HASHJOIN - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceHashJoinSameSourceExpression
SHARED_HASHJOIN - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceSplitToStreamedHashJoinExpression
SHARED_HASHJOIN_ACCUMULATED - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceSameSourceStreamedAccumulatedExpression
SHARED_HASHJOIN_STREAMED - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceSameSourceStreamedAccumulatedExpression
SHARED_JOIN - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitJoinExpression
SHARED_JOIN - Static variable in class cascading.flow.tez.planner.rule.expressiongraph.BalanceJoinSplitExpression
sink(FlowProcess<? extends Configuration>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.SequenceFile
sink(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
sink(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextLine
sink(FlowProcess<? extends Configuration>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.WritableSequenceFile
sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.SequenceFile
sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.TextLine
sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.WritableSequenceFile
sinkConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs
sinkPrepare(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
sinkPrepare(FlowProcess<? extends Configuration>, 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
size() - Method in class cascading.flow.hadoop.util.LazyCollection
sliceStatsMap - Variable in class cascading.stats.hadoop.BaseHadoopNodeStats
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.WritableSequenceFile
sourceCleanup(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
sourceCleanup(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
sourceConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.SequenceFile
sourceConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.TextLine
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.BaseDistCacheTap
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.GlobHfs
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.PartitionTap
sourceConfInitAddInputPath(Configuration, Path) - Method in class cascading.tap.hadoop.Hfs
sourceConfInitComplete(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs
sourceHandleInput(SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited
sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
spillCount() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
SPLICE - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitSpliceExpression
SplitJoinBoundariesNodeRePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
SplitJoinBoundariesNodeRePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.SplitJoinBoundariesNodeRePartitioner
start(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
start(Duct) - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
start(Duct) - Method in class cascading.flow.tez.stream.element.TezMergeGate
STATUS_GET_COUNTERS - Static variable in class cascading.stats.tez.util.TezStatsUtil
stepsAreLocal() - Method in class cascading.flow.tez.Hadoop2TezFlow
StreamedAccumulatedBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
StreamedAccumulatedBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.StreamedAccumulatedBoundariesExpressionGraph
StreamedAccumulatedBoundariesNodeRePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
StreamedAccumulatedBoundariesNodeRePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.StreamedAccumulatedBoundariesNodeRePartitioner
StreamedAccumulatedTapsExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expression
StreamedAccumulatedTapsExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsExpressionGraph
StreamedAccumulatedTapsPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
StreamedAccumulatedTapsPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedAccumulatedTapsPipelinePartitioner
StreamedAccumulatedTapsPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
StreamedAccumulatedTapsPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsPipelinePartitionExpression
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
StreamedOnlySourcesExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph: Captures the source when the pipeline only has a single source and its streamed.
StreamedOnlySourcesExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.StreamedOnlySourcesExpressionGraph
StreamedOnlySourcesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph: Captures the source when the pipeline only has a single source and its streamed.
StreamedOnlySourcesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.StreamedOnlySourcesExpressionGraph
StreamedOnlySourcesNodeRePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
StreamedOnlySourcesNodeRePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.StreamedOnlySourcesNodeRePartitioner
StreamedOnlySourcesPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
StreamedOnlySourcesPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedOnlySourcesPipelinePartitioner
StreamedOnlySourcesPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
StreamedOnlySourcesPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedOnlySourcesPipelinePartitionExpression
StreamedSelfJoinSourcesExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph: Captures the source when the pipeline only has a single source and its streamed.
StreamedSelfJoinSourcesExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.StreamedSelfJoinSourcesExpressionGraph
StreamedSelfJoinSourcesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph: Captures the source when the pipeline only has a single source and its streamed.
StreamedSelfJoinSourcesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.StreamedSelfJoinSourcesExpressionGraph
StreamedSelfJoinSourcesPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
StreamedSelfJoinSourcesPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedSelfJoinSourcesPipelinePartitioner
StreamedSelfJoinSourcesPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
StreamedSelfJoinSourcesPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedSelfJoinSourcesPipelinePartitionExpression
stringPath - Variable in class cascading.tap.hadoop.Hfs: Field stringPath
syncArtifacts() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
syncPaths(Configuration, Map<Path, Path>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil: Copies paths from one local path to a remote path.

T

TapBalanceCheckpointTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceCheckpointTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceCheckpointTransformer
TapBalanceGroupBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceGroupBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupBlockingHashJoinTransformer
TapBalanceGroupGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceGroupGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupGroupTransformer
TapBalanceGroupMergeGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceGroupMergeGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupMergeGroupTransformer
TapBalanceGroupNonBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceGroupNonBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupNonBlockingHashJoinTransformer
TapBalanceGroupSplitJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceGroupSplitJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitJoinTransformer
TapBalanceGroupSplitMergeGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceGroupSplitMergeGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitMergeGroupTransformer
TapBalanceGroupSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceGroupSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitTransformer
TapBalanceHashJoinBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceHashJoinBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceHashJoinBlockingHashJoinTransformer
TapBalanceHashJoinSameSourceTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceHashJoinSameSourceTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceHashJoinSameSourceTransformer
TapBalanceNonSafePipeSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceNonSafePipeSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceNonSafePipeSplitTransformer
TapBalanceNonSafeSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceNonSafeSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceNonSafeSplitTransformer
TapBalanceSameSourceStreamedAccumulatedTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
TapBalanceSameSourceStreamedAccumulatedTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceSameSourceStreamedAccumulatedTransformer
TapGroupTapPartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
TapGroupTapPartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.TapGroupTapPartitionExpression
TapGroupTapStepPartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
TapGroupTapStepPartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.TapGroupTapStepPartitioner
TapOutputCollector - Class in cascading.tap.hadoop.io
TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, String) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, String, long) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
TaskStatus - Class in cascading.stats.tez.util
TaskStatus(String) - Constructor for class cascading.stats.tez.util.TaskStatus
TaskStatus(String, String, long, long, long, String, Map<String, Map<String, Long>>, String) - Constructor for class cascading.stats.tez.util.TaskStatus
TempHfs - Class in cascading.tap.hadoop.util: Class TempHfs creates a temporary Tap instance for use internally.
TempHfs(Configuration, String, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs: Constructor TempHfs creates a new TempHfs instance.
TempHfs(Configuration, String, Class<? extends Scheme>) - Constructor for class cascading.tap.hadoop.util.TempHfs: Constructor TempDfs creates a new TempDfs instance.
TempHfs(Configuration, String, Class<? extends Scheme>, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs
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
TezBoundaryStage - Class in cascading.flow.tez.stream.element
TezBoundaryStage(FlowProcess, Boundary, IORole, Collection<LogicalOutput>) - Constructor for class cascading.flow.tez.stream.element.TezBoundaryStage
TezBoundaryStage(FlowProcess, Boundary, IORole, LogicalInput) - Constructor for class cascading.flow.tez.stream.element.TezBoundaryStage
TezCoGroupClosure - Class in cascading.flow.tez
TezCoGroupClosure(FlowProcess, int, Fields[], Fields[]) - Constructor for class cascading.flow.tez.TezCoGroupClosure
TezCoGroupGate - Class in cascading.flow.tez.stream.element
TezCoGroupGate(FlowProcess, CoGroup, IORole, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezCoGroupGate
TezCoGroupGate(FlowProcess, CoGroup, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezCoGroupGate
TezCounterCache<JobStatus> - Class in cascading.stats.tez
TezCounterCache(CascadingStats, Configuration) - Constructor for class cascading.stats.tez.TezCounterCache
TezGroupByClosure - Class in cascading.flow.tez
TezGroupByClosure(FlowProcess, Fields[], Fields[]) - Constructor for class cascading.flow.tez.TezGroupByClosure
TezGroupByGate - Class in cascading.flow.tez.stream.element
TezGroupByGate(FlowProcess, GroupBy, IORole, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezGroupByGate
TezGroupByGate(FlowProcess, GroupBy, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezGroupByGate
TezGroupGate - Class in cascading.flow.tez.stream.element
TezGroupGate(FlowProcess, Splice, IORole, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezGroupGate
TezGroupGate(FlowProcess, Splice, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezGroupGate
TezMergeGate - Class in cascading.flow.tez.stream.element
TezMergeGate(FlowProcess, Splice, IORole, Collection<LogicalOutput>) - Constructor for class cascading.flow.tez.stream.element.TezMergeGate
TezMergeGate(FlowProcess, Splice, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezMergeGate
TezNodeStats - Class in cascading.stats.tez
TezNodeStats(TezStepStats, FlowNode, ClientState, Configuration) - Constructor for class cascading.stats.tez.TezNodeStats
TezNodeStats.Kind - Enum in cascading.stats.tez
TezSinkStage - Class in cascading.flow.tez.stream.element
TezSinkStage(FlowProcess, Tap, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezSinkStage
TezSliceStats - Class in cascading.stats.tez
TezSliceStats.TezAttempt - Class in cascading.stats.tez
TezSliceStats.TezAttempt() - Constructor for class cascading.stats.tez.TezSliceStats.TezAttempt
TezSourceStage - Class in cascading.flow.tez.stream.element
TezSourceStage(FlowProcess, Tap, LogicalInput) - Constructor for class cascading.flow.tez.stream.element.TezSourceStage
TezStatsUtil - Class in cascading.stats.tez.util
TezStatsUtil() - Constructor for class cascading.stats.tez.util.TezStatsUtil
TezStepStats - Class in cascading.stats.tez
TezStepStats(FlowStep, ClientState) - Constructor for class cascading.stats.tez.TezStepStats: Constructor CascadingStats creates a new CascadingStats instance.
TezTimelineClient - Class in cascading.stats.tez.util
TezTimelineClient(ApplicationId, String, TezConfiguration, FrameworkClient, DAGClient) - Constructor for class cascading.stats.tez.util.TezTimelineClient
TezUtil - Class in cascading.flow.tez.util
TezUtil() - Constructor for class cascading.flow.tez.util.TezUtil
TimedIterator<V> - Class in cascading.flow.hadoop.util
TimedIterator(FlowProcess, Enum, Enum) - Constructor for class cascading.flow.hadoop.util.TimedIterator
TimedIterator(FlowProcess, Enum, Enum, int) - Constructor for class cascading.flow.hadoop.util.TimedIterator
timedIterators - Variable in class cascading.flow.tez.stream.element.TezCoGroupGate
timedIterators - Variable in class cascading.flow.tez.stream.element.TezGroupByGate
TIMELINE_CLIENT_CLASS - Static variable in class cascading.stats.tez.util.TezStatsUtil
TIMELINE_FETCH_LIMIT - Static variable in class cascading.stats.tez.TezNodeStats: Sets the fetch limit from the timeline server.
TimelineClient - Interface in cascading.stats.tez.util
timeout - Variable in class cascading.stats.hadoop.CounterCache
toArray() - Method in class cascading.flow.hadoop.util.FalseCollection
toArray(T[]) - Method in class cascading.flow.hadoop.util.FalseCollection
toArray() - Method in class cascading.flow.hadoop.util.LazyCollection
toArray(T[]) - Method in class cascading.flow.hadoop.util.LazyCollection
TopDownBoundariesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
TopDownBoundariesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.TopDownBoundariesNodePartitioner
TopDownConsecutiveBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
TopDownConsecutiveBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.TopDownConsecutiveBoundariesExpressionGraph
TopDownSplitBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
TopDownSplitBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.TopDownSplitBoundariesExpressionGraph
TopDownSplitBoundariesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
TopDownSplitBoundariesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.TopDownSplitBoundariesNodePartitioner
TopDownSplitJoinBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
TopDownSplitJoinBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.TopDownSplitJoinBoundariesExpressionGraph
toString() - Method in class cascading.stats.tez.TezSliceStats
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
TuplePartitioner - Class in cascading.tuple.tez.util: Class GroupingPartitioner is an implementation of Partitioner.
TuplePartitioner(Configuration) - Constructor for class cascading.tuple.tez.util.TuplePartitioner
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<? extends Configuration>) - 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.HadoopGroupGate
unwrapGrouping(Tuple) - Method in class cascading.flow.tez.stream.element.TezCoGroupGate
unwrapGrouping(Tuple) - Method in class cascading.flow.tez.stream.element.TezGroupByGate
update(String, String) - Method in class cascading.flow.hadoop.ConfigurationSetter
updateNodeStatus(FlowNodeStats) - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
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.tez.TezNodeStats.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.tez.TezNodeStats.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(Configuration) - Static method in class cascading.tap.hadoop.Hfs

W

waitForInputsReady(Map<String, LogicalInput>) - Method in class cascading.flow.tez.FlowProcessor
waitOnLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
wrapGroupingAndCollect(Duct, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
wrapGroupingAndCollect(Duct, Tuple, Tuple) - Method in class cascading.flow.tez.stream.element.TezCoGroupGate
wrapGroupingAndCollect(Duct, Tuple, Tuple) - Method in class cascading.flow.tez.stream.element.TezGroupByGate
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

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