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

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

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

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

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

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

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.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.hadoop.planner.rule.expression.BalanceHashJoinSameSourceExpression

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

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

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

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, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

wrapGroupingAndCollect(Duct, 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