A B C D E F G H I 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
 
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
 
AccumulatedTapOnHashJoinExpression - Class in cascading.flow.hadoop.planner.rule.expression
 
AccumulatedTapOnHashJoinExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.AccumulatedTapOnHashJoinExpression
 
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
 
addLocalCacheFiles(Configuration, URI) - Method in class cascading.tap.hadoop.DistCacheTap
 
addResource(Map<String, LocalResource>, Map<String, String>, String, FileStatus, Path, LocalResourceType) - Static method in class cascading.flow.tez.util.TezUtil
 
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
 
asJobConf(Configuration) - Static method in class cascading.flow.tez.util.TezUtil
Attempting to localize all new JobConf calls

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
 
BalanceGroupSplitMergeExpression - Class in cascading.flow.hadoop.planner.rule.expression
 
BalanceGroupSplitMergeExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeExpression
 
BalanceGroupSplitMergeGroupExpression - Class in cascading.flow.hadoop.planner.rule.expression
 
BalanceGroupSplitMergeGroupExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
 
BalanceGroupSplitNotTapExpression - Class in cascading.flow.tez.planner.rule.expression
 
BalanceGroupSplitNotTapExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitNotTapExpression
 
BalanceGroupSplitSpliceExpression - Class in cascading.flow.tez.planner.rule.expression
 
BalanceGroupSplitSpliceExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitSpliceExpression
 
BalanceGroupSplitTriangleExpression - Class in cascading.flow.hadoop.planner.rule.expression
 
BalanceGroupSplitTriangleExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitTriangleExpression
 
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
 
BalanceSplitSplitToStreamedHashJoinExpression - Class in cascading.flow.tez.planner.rule.expression
 
BalanceSplitSplitToStreamedHashJoinExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceSplitSplitToStreamedHashJoinExpression
 
BalanceSplitToStreamedHashJoinExpression - Class in cascading.flow.tez.planner.rule.expression
 
BalanceSplitToStreamedHashJoinExpression() - Constructor for class cascading.flow.tez.planner.rule.expression.BalanceSplitToStreamedHashJoinExpression
 
BaseTupleComparator - Class in cascading.tuple.hadoop.util
 
BaseTupleComparator() - Constructor for class cascading.tuple.hadoop.util.BaseTupleComparator
 
BaseTupleComparator.RawComparison - Interface in cascading.tuple.hadoop.util
 
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
 
BottomUpConsecutiveBoundariesTriangleExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
 
BottomUpConsecutiveBoundariesTriangleExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.BottomUpConsecutiveBoundariesTriangleExpressionGraph
 
BottomUpJoinedBoundariesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
 
BottomUpJoinedBoundariesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.BottomUpJoinedBoundariesNodePartitioner
 
BottomUpJoinedBoundariesTriangleNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
 
BottomUpJoinedBoundariesTriangleNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.BottomUpJoinedBoundariesTriangleNodePartitioner
 
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
 
BoundaryBalanceGroupSplitTransformer - Class in cascading.flow.tez.planner.rule.transformer
 
BoundaryBalanceGroupSplitTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceGroupSplitTransformer
 
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
 
BoundaryBalanceSplitSplitToStreamedHashJoinTransformer - Class in cascading.flow.tez.planner.rule.transformer
Inserts Boundary after split that joins back into a HashJoin by way of another split.
BoundaryBalanceSplitSplitToStreamedHashJoinTransformer() - Constructor for class cascading.flow.tez.planner.rule.transformer.BoundaryBalanceSplitSplitToStreamedHashJoinTransformer
 
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
 
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
 

C

canPerformRawComparisons() - Method in class cascading.tuple.hadoop.util.BaseTupleComparator
 
canPerformRawComparisons() - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
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.stats.hadoop - package cascading.stats.hadoop
 
cascading.tap.hadoop - package cascading.tap.hadoop
 
cascading.tuple.hadoop.util - package cascading.tuple.hadoop.util
 
cascading.tuple.tez.util - package cascading.tuple.tez.util
 
CASCADING_LOCAL_RESOURCES - Static variable in class cascading.tap.hadoop.DistCacheTap
 
CASCADING_REMOTE_RESOURCES - Static variable in class cascading.tap.hadoop.DistCacheTap
 
clean(TezConfiguration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
 
cleanup() - Method in class cascading.flow.tez.stream.element.TezSinkStage
 
clear() - Method in class cascading.flow.hadoop.util.FalseCollection
 
clear() - Method in class cascading.flow.hadoop.util.LazyCollection
 
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
 
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
 
collections - Variable in class cascading.flow.hadoop.HadoopCoGroupClosure
Field groups
collector - Variable in class cascading.flow.hadoop.stream.HadoopGroupGate
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.BaseTupleComparator
 
compare(Tuple, Tuple) - Method in class cascading.tuple.hadoop.util.BaseTupleComparator
 
compare(byte[], int, int, byte[], int, int) - Method in interface cascading.tuple.hadoop.util.BaseTupleComparator.RawComparison
 
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(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
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TypedTupleElementComparator
 
compare(TupleInputStream, TupleInputStream) - Method in class cascading.tuple.hadoop.util.TypedTupleElementComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TypedTupleElementStreamComparator
 
compare(HadoopTupleInputStream, HadoopTupleInputStream) - Method in class cascading.tuple.hadoop.util.TypedTupleElementStreamComparator
 
compareTuples(Comparator[], Tuple, Tuple) - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
compareTuples(Class[], Comparator[]) - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
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
 
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(Map<Object, Object>, Configuration) - Static method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
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
 
create(ElementGraph, FlowElement) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner.IntermediateBoundaryElementFactory
 
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
 
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
 
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
 
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
 
createTupleCollection(Fields) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
createTupleCollection(Fields) - Method in class cascading.flow.tez.TezCoGroupClosure
 
createTupleMap() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
createVertex(FlowProcess<TezConfiguration>, TezConfiguration, FlowNode) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
 

D

DelegatingTupleElementComparator - Class in cascading.tuple.hadoop.util
 
DelegatingTupleElementComparator(TupleSerialization) - Constructor for class cascading.tuple.hadoop.util.DelegatingTupleElementComparator
 
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
 
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

equals(Object) - Method in class cascading.flow.hadoop.util.LazyCollection
 

F

FalseCollection - Class in cascading.flow.hadoop.util
 
FalseCollection() - Constructor for class cascading.flow.hadoop.util.FalseCollection
 
FlowProcessor - Class in cascading.flow.tez
 
FlowProcessor(ProcessorContext) - Constructor for class cascading.flow.tez.FlowProcessor
 

G

get(String) - Method in class cascading.flow.hadoop.ConfigurationSetter
 
getAllLocalResources() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
 
getByteComparison() - Method in class cascading.tuple.hadoop.util.BaseTupleComparator
 
getByteComparison() - Method in class cascading.tuple.hadoop.util.TupleComparator
 
getConf() - Method in class cascading.tuple.hadoop.util.HasherPartitioner
 
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
 
getCounterValue(Enum) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
 
getCounterValue(String, String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
 
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.
getCurrentUser() - Static method in class cascading.flow.tez.util.TezUtil
 
getCurrentValues() - Method in class cascading.flow.tez.util.SecondarySortKeyValuesReader
 
getDefaultConfig() - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
getDefaultIntermediateSchemeClass() - Method in class cascading.flow.tez.Hadoop2TezFlowConnector
 
getDefaultURIScheme(Tap) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
getEdgeSinkID(LogicalOutput, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
 
getEdgeSourceID(LogicalInput, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
 
getFieldComparatorsFrom(Configuration, String) - Static method in class cascading.tuple.hadoop.util.DeserializerComparator
 
getFlowProcess() - Method in class cascading.flow.tez.Hadoop2TezFlow
 
getFlowStagingPath() - Method in class cascading.flow.tez.Hadoop2TezFlow
 
getFlowStepFactory() - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
getGrouping() - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getGrouping() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
 
getGroupTuple(Tuple) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
getGroupTuple(Tuple) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getHadoopTupleInputStream(BufferedInputStream, TupleSerialization.SerializationElementReader) - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
getInputConfiguration(LogicalInput) - Static method in class cascading.flow.tez.util.TezUtil
 
getIntProperty(String, int) - Method in class cascading.stats.hadoop.HadoopCounterCache
 
getIterator(int) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
getIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getJobPollingInterval(Configuration) - Static method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
 
getLocalCacheFiles(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.DistCacheTap
 
getMaxNumParallelSteps() - Method in class cascading.flow.tez.Hadoop2TezFlow
 
getNumProcessSlices() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
 
getOutput() - Method in class cascading.flow.tez.stream.element.TezSinkStage
 
getOutputConfiguration(LogicalOutput) - Static method in class cascading.flow.tez.util.TezUtil
 
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
 
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
 
getPlannerInfo(String) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
getPlatformInfo() - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
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
 
getReporter() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
Method getReporter returns the reporter of this HadoopFlowProcess object.
getStreamComparison() - Method in class cascading.tuple.hadoop.util.BaseTupleComparator
 
getStreamedHead() - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
 
getThrowable() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
 
getTotalSliceCPUMilliSeconds() - Method in class cascading.flow.tez.Hadoop2TezFlow
 
getURIScheme(Tap) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
getValueIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getValueIterator(int) - Method in class cascading.flow.tez.TezGroupByClosure
 
GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
 
GROUP - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitSpliceExpression
 
groupComparators - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
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

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, 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
 
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
 
HadoopCounterCache<JobStatus,Counters> - Class in cascading.stats.hadoop
 
HadoopCounterCache(CascadingStats, Configuration) - Constructor for class cascading.stats.hadoop.HadoopCounterCache
 
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
 
handleEvents(List<Event>) - Method in class cascading.flow.tez.FlowProcessor
 
hashCode() - Method in class cascading.flow.hadoop.util.LazyCollection
 
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
 

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
 
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
 
initLists() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
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
 
isCounterStatusInitialized() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
 
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
 
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
 
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
 

K

keepAlive() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
 
keyTypes - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 

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
 
lhsBuffer - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
lhsStream - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
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

makeIterator(int, Iterator) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
makeTempTap(String, String) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
 
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
 
MERGE - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
 
mergeMapIntoConfig(TezConfiguration, Map<String, String>) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
 
MultiTapGroupNodePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
 
MultiTapGroupNodePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.MultiTapGroupNodePartitioner
 

N

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
 
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

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
 

P

performRawComparison() - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
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
 

R

receive(Duct, int, TupleEntry) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
receive(Duct, int, TupleEntry) - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
 
receive(Duct, int, TupleEntry) - Method in class cascading.flow.tez.stream.element.TezMergeGate
 
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
 
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
 
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
 
ReplaceAccumulateTapWithDistCacheTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
The ReplaceAccumulateTapWithDistCacheTransformer will decorate all temp or checkpoint taps on the accumulated side of a HashJoin with a DistCacheTap instance that wraps the original Tap instance.
ReplaceAccumulateTapWithDistCacheTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.ReplaceAccumulateTapWithDistCacheTransformer
 
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
 
ResettableCollection<V> - Interface in cascading.flow.hadoop.util
 
retainAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
retainAll(Collection<?>) - Method in class cascading.flow.hadoop.util.LazyCollection
 
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
 
rhsBuffer - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
rhsStream - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
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
 
set(String, String) - Method in class cascading.flow.hadoop.ConfigurationSetter
 
setConf(Configuration) - Method in class cascading.tuple.hadoop.util.BaseTupleComparator
 
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
 
setGrouping(Tuple) - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
 
setMRProperties(ProcessorContext, Configuration, boolean) - Static method in class cascading.flow.tez.util.TezUtil
 
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
 
setStatus(String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
 
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.hadoop.planner.rule.expression.BalanceGroupSplitTriangleExpression
 
SHARED_GROUP - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitHashJoinExpression
 
SHARED_GROUP - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitNotTapExpression
 
SHARED_HASHJOIN - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceSplitSplitToStreamedHashJoinExpression
 
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
 
SHARED_LHS - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitTriangleExpression
 
SHARED_RHS - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitTriangleExpression
 
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
 
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
 
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
 
StreamedAccumulatedTapsHashJoinExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expression
 
StreamedAccumulatedTapsHashJoinExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsHashJoinExpressionGraph
 
StreamedAccumulatedTapsHashJoinPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
This rule accounts for a Tap marked as both streamed and accumulated, but is streamed in one pipeline and accumulated in another pipeline.
StreamedAccumulatedTapsHashJoinPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedAccumulatedTapsHashJoinPipelinePartitioner
 
StreamedAccumulatedTapsHashJoinPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
 
StreamedAccumulatedTapsHashJoinPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsHashJoinPipelinePartitionExpression
 
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
 
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
 
syncArtifacts() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
 

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
 
TapBalanceGroupSplitMergeTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupSplitMergeTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitMergeTransformer
 
TapBalanceGroupSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitTransformer
 
TapBalanceGroupSplitTriangleTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
Captures a split where one side of the split hits a pipe that joins with the pipe on the other side of the split
TapBalanceGroupSplitTriangleTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitTriangleTransformer
 
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
 
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
 
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
 
TezSinkStage - Class in cascading.flow.tez.stream.element
 
TezSinkStage(FlowProcess, Tap, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezSinkStage
 
TezSourceStage - Class in cascading.flow.tez.stream.element
 
TezSourceStage(FlowProcess, Tap, LogicalInput) - Constructor for class cascading.flow.tez.stream.element.TezSourceStage
 
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
 
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
 
TupleComparator - Class in cascading.tuple.hadoop.util
 
TupleComparator() - Constructor for class cascading.tuple.hadoop.util.TupleComparator
 
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
 
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 - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
TypedTupleElementComparator - Class in cascading.tuple.hadoop.util
 
TypedTupleElementComparator() - Constructor for class cascading.tuple.hadoop.util.TypedTupleElementComparator
 
TypedTupleElementComparator(Class, Comparator) - Constructor for class cascading.tuple.hadoop.util.TypedTupleElementComparator
 
TypedTupleElementStreamComparator - Class in cascading.tuple.hadoop.util
 
TypedTupleElementStreamComparator(Class, StreamComparator) - Constructor for class cascading.tuple.hadoop.util.TypedTupleElementStreamComparator
 

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
 

V

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.
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.

W

waitForInputsReady(Map<String, LogicalInput>) - Method in class cascading.flow.tez.FlowProcessor
 
waitOnLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
wrapGroupingAndCollect(Duct, int, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
wrapGroupingAndCollect(Duct, int, Tuple, Tuple) - Method in class cascading.flow.tez.stream.element.TezGroupGate
 
A B C D E F G H I K L M N O P R S T U V W 

Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.