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

A

accept(Tuple, Iterator<Tuple>[]) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

accumulate(Set<Hfs>, Tap) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

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

addAttempt(TaskCompletionEvent) - Method in class cascading.stats.hadoop.HadoopNodeStats

addAttempt(TaskCompletionEvent) - Method in class cascading.stats.hadoop.HadoopSliceStats

addFlowStep(MapReduceFlowStep) - Method in class cascading.flow.hadoop.MultiMapReduceFlow

addLocalCacheFiles(Configuration, URI) - Method in class cascading.tap.hadoop.DistCacheTap

addTaskStats(TaskReport[], boolean) - Method in class cascading.stats.hadoop.HadoopNodeStats

addToClassPath(Configuration, List<String>) - Static method in class cascading.flow.hadoop.util.HadoopMRUtil

Add to class path.

AdjacentTempToTapExpression - Class in cascading.flow.hadoop.planner.rule.expression

AdjacentTempToTapExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.AdjacentTempToTapExpression

applies(PlannerContext, ElementGraph, Scope) - Method in class cascading.flow.hadoop.planner.rule.scopeexpression.EquivalentTapsScopeExpression

areCountersAvailable(FlowNodeStats) - Method in class cascading.stats.hadoop.HadoopNodeCounterCache

areCountersAvailable(RunningJob) - Method in class cascading.stats.hadoop.HadoopStepCounterCache

attachFlowStep(JobConf) - Method in class cascading.flow.hadoop.MultiMapReduceFlow

B

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

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

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

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

BaseHadoopPlatform<Config extends Configuration> - Class in cascading.platform.hadoop

BaseHadoopPlatform() - Constructor for class cascading.platform.hadoop.BaseHadoopPlatform

BaseMapReduceFlow - Class in cascading.flow.hadoop

BaseMapReduceFlow(PlatformInfo, Map<Object, Object>, JobConf, String, Map<String, String>, boolean) - Constructor for class cascading.flow.hadoop.BaseMapReduceFlow

BaseMapReduceFlow(PlatformInfo, Map<Object, Object>, String, Map<String, String>, boolean) - Constructor for class cascading.flow.hadoop.BaseMapReduceFlow

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

bind(StreamGraph) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

blockingContinuePollingSteps() - Method in class cascading.flow.hadoop.MultiMapReduceFlow

build() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure

buildGraph() - Method in class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph

buildGraph() - Method in class cascading.flow.hadoop.stream.graph.HadoopReduceStreamGraph

C

canPerformRawComparisons() - Method in class cascading.tuple.hadoop.util.BaseTupleComparator

canPerformRawComparisons() - Method in class cascading.tuple.hadoop.util.DeserializerComparator

captureChildDetailInternal() - Method in class cascading.stats.hadoop.HadoopNodeStats

captureDetail(CascadingStats.Type) - Method in class cascading.stats.hadoop.HadoopStepStats

Method captureDetail captures statistics task details and completion events.

cascading.flow.hadoop - package cascading.flow.hadoop

cascading.flow.hadoop.planner - package cascading.flow.hadoop.planner

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.scopeexpression - package cascading.flow.hadoop.planner.rule.scopeexpression

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.stream.element - package cascading.flow.hadoop.stream.element

cascading.flow.hadoop.stream.graph - package cascading.flow.hadoop.stream.graph

cascading.flow.hadoop.util - package cascading.flow.hadoop.util

cascading.flow.hadoop2 - package cascading.flow.hadoop2

cascading.platform.hadoop - package cascading.platform.hadoop

cascading.platform.hadoop2 - package cascading.platform.hadoop2

cascading.stats.hadoop - package cascading.stats.hadoop

cascading.tap.hadoop - package cascading.tap.hadoop

cascading.tuple.hadoop.util - package cascading.tuple.hadoop.util

checkPlatform(Configuration) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

checkPlatform(Configuration) - Method in class cascading.flow.hadoop2.Hadoop2MR1Planner

clean(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep

Method clean removes any temporary files used by this FlowStep instance.

cleanIntermediateData(JobConf, Tap) - Method in class cascading.flow.hadoop.HadoopFlowStep

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

close() - Method in class cascading.flow.hadoop.util.TimedIterator

closure - Variable in class cascading.flow.hadoop.stream.HadoopGroupGate

CoGroupingComparator - Class in cascading.tuple.hadoop.util

Class GroupingComparator is an implementation of RawComparator.

CoGroupingComparator() - Constructor for class cascading.tuple.hadoop.util.CoGroupingComparator

CoGroupingPartitioner - Class in cascading.tuple.hadoop.util

Class GroupingPartitioner is an implementation of Partitioner.

CoGroupingPartitioner() - Constructor for class cascading.tuple.hadoop.util.CoGroupingPartitioner

collections - Variable in class cascading.flow.hadoop.HadoopCoGroupClosure

Field groups

collector - Variable in class cascading.flow.hadoop.stream.HadoopGroupGate

CombineAdjacentTapTransformer - Class in cascading.flow.hadoop.planner.rule.transformer

CombineAdjacentTapTransformer is currently unsupported but listed in the default rule registry.

CombineAdjacentTapTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.CombineAdjacentTapTransformer

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() - Method in class cascading.flow.hadoop.MultiMapReduceFlow

complete(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

configRuleRegistryDefaults(RuleRegistry) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

configuration - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform

ConfigurationSetter - Class in cascading.flow.hadoop

ConfigurationSetter(Configuration) - Constructor for class cascading.flow.hadoop.ConfigurationSetter

configure(JobConf) - Method in class cascading.flow.hadoop.FlowMapper

configure(JobConf) - Method in class cascading.flow.hadoop.FlowReducer

configure(JobConf) - Method in class cascading.tuple.hadoop.util.CoGroupingPartitioner

configure(JobConf) - Method in class cascading.tuple.hadoop.util.GroupingPartitioner

configure(JobConf) - Method in class cascading.tuple.hadoop.util.GroupingSortingPartitioner

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

copyConfiguration(Map<Object, Object>, Configuration) - Static method in class cascading.flow.hadoop2.Hadoop2MR1Planner

Method copyJobConf adds the given JobConf values to the given properties object.

copyFromLocal(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

copyJobConf(Map<Object, Object>, JobConf) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner

Method copyJobConf adds the given JobConf values to the given properties object.

copyProperties(JobConf, Map<Object, Object>) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner

Method copyProperties adds the given Map values to the given JobConf object.

copyProperties(Configuration, Map<Object, Object>) - Static method in class cascading.flow.hadoop2.Hadoop2MR1Planner

Method copyProperties adds the given Map values to the given JobConf object.

copyToDistributedCache() - Method in class cascading.flow.hadoop.HadoopFlow

copyToLocal(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

copyWith(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowProcess

countDownLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate

createClosure() - Method in class cascading.flow.hadoop.stream.element.HadoopCoGroupGate

createClosure() - Method in class cascading.flow.hadoop.stream.element.HadoopGroupByGate

createClosure() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

createCoGroupGate(CoGroup, IORole) - Method in class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph

createCoGroupGate(CoGroup, IORole) - Method in class cascading.flow.hadoop.stream.graph.HadoopReduceStreamGraph

createDefaultRuleRegistrySet() - Method in class cascading.flow.hadoop2.Hadoop2MR1FlowConnector

createElementDirectedGraph() - Method in class cascading.flow.hadoop.MapReduceFlowStep

createFlow(FlowDef) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

createFlowNodeGraph(List<ElementGraph>) - Method in class cascading.flow.hadoop.MapReduceFlowStep

createFlowPlanner() - Method in class cascading.flow.hadoop2.Hadoop2MR1FlowConnector

createFlowStep(JobConf, Tap) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

createFlowStepJob(ClientState, FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep

createGroupByGate(GroupBy, IORole) - Method in class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph

createGroupByGate(GroupBy, IORole) - Method in class cascading.flow.hadoop.stream.graph.HadoopReduceStreamGraph

createHashJoinGate(HashJoin) - Method in class cascading.flow.hadoop.stream.graph.HadoopReduceStreamGraph

createInitializedConfig(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep

createInitializedConfig(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.MapReduceFlowStep

createIterator(IndexTuple, Iterator<IndexTuple>) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure

createJobConf(Map<Object, Object>) - Static method in class cascading.flow.hadoop.planner.HadoopPlanner

Method createJobConf returns a new JobConf instance using the values in the given properties argument.

createKeySet() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate

createMapOperation() - Method in class cascading.flow.hadoop.MapReduceFlowStep

createMapReduceFlowStep(JobConf) - Method in class cascading.flow.hadoop.MultiMapReduceFlow

createNonBlockingJoinGate(HashJoin) - Method in class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph

createOutputCollector() - Method in class cascading.flow.hadoop.stream.element.HadoopCoGroupGate

createOutputCollector() - Method in class cascading.flow.hadoop.stream.element.HadoopGroupByGate

createOutputCollector() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

createReduceOperation() - Method in class cascading.flow.hadoop.MapReduceFlowStep

createShuffleOperation() - Method in class cascading.flow.hadoop.MapReduceFlowStep

createSinks(JobConf) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

createSinkStage(Tap) - Method in class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph

createSinkStage(Tap) - Method in class cascading.flow.hadoop.stream.graph.HadoopReduceStreamGraph

createSources(JobConf) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

createStepStats(ClientState) - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

createTap(JobConf, Path, SinkMode) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

createTap(JobConf, Path, SinkMode) - Method in class cascading.flow.hadoop.MultiMapReduceFlow

createTraps(JobConf) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

createTupleCollection(Fields) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure

createTupleMap() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate

D

DelegatingTupleElementComparator - Class in cascading.tuple.hadoop.util

DelegatingTupleElementComparator(TupleSerialization) - Constructor for class cascading.tuple.hadoop.util.DelegatingTupleElementComparator

deleteSinkOnInit - Variable in class cascading.flow.hadoop.BaseMapReduceFlow

Field deleteSinkOnInit

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

DistCacheTap - Class in cascading.tap.hadoop

Class DistCacheTap is a Tap decorator for Hfs and can be used to move a file to the DistributedCache on read when accessed cluster side.

DistCacheTap(Hfs) - Constructor for class cascading.tap.hadoop.DistCacheTap

Constructs a new DistCacheTap instance with the given Hfs.

DualStreamedAccumulatedExpression - Class in cascading.flow.hadoop.planner.rule.expression

DualStreamedAccumulatedExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.DualStreamedAccumulatedExpression

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.hadoop.planner.HadoopFlowStepJob

E

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

EquivalentTapsScopeExpression - Class in cascading.flow.hadoop.planner.rule.scopeexpression

EquivalentTapsScopeExpression() - Constructor for class cascading.flow.hadoop.planner.rule.scopeexpression.EquivalentTapsScopeExpression

F

FailOnMissingSuccessFlowListener - Class in cascading.flow.hadoop

Class FailOnMissingSuccessFlowListener is a FlowListener that tests that all sources to a Flow have a _SUCCESS file before allowing the Flow to execute.

FailOnMissingSuccessFlowListener() - Constructor for class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

FalseCollection - Class in cascading.flow.hadoop.util

FalseCollection() - Constructor for class cascading.flow.hadoop.util.FalseCollection

fileInputToTaps(JobConf) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

fileOutputToTaps(JobConf) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

fileSys - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform

FlowMapper - Class in cascading.flow.hadoop

Class FlowMapper is the Hadoop Mapper implementation.

FlowMapper() - Constructor for class cascading.flow.hadoop.FlowMapper

Constructor FlowMapper creates a new FlowMapper instance.

FlowReducer - Class in cascading.flow.hadoop

Class FlowReducer is the Hadoop Reducer implementation.

FlowReducer() - Constructor for class cascading.flow.hadoop.FlowReducer

Constructor FlowReducer creates a new FlowReducer instance.

G

get(String) - Method in class cascading.flow.hadoop.ConfigurationSetter

getAttempts() - Method in class cascading.stats.hadoop.HadoopSliceStats

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

getConfig() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getConfigAsProperties() - Method in class cascading.flow.hadoop.HadoopFlow

getConfigAsProperties() - Method in class cascading.flow.hadoop.HadoopFlowStep

getConfigCopy() - Method in class cascading.flow.hadoop.HadoopFlow

getConfigCopy() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getConfiguration() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getConfiguration() - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

getCounterGroups() - Method in class cascading.stats.hadoop.HadoopSliceStats

getCounters(FlowNodeStats) - Method in class cascading.stats.hadoop.HadoopNodeCounterCache

getCounters() - Method in class cascading.stats.hadoop.HadoopSliceStats

getCounters(RunningJob) - Method in class cascading.stats.hadoop.HadoopStepCounterCache

getCountersFor(Map<String, Map<String, Long>>, String) - Method in class cascading.stats.hadoop.HadoopNodeCounterCache

getCountersFor(String) - Method in class cascading.stats.hadoop.HadoopSliceStats

getCountersFor(Class<? extends Enum>) - Method in class cascading.stats.hadoop.HadoopSliceStats

getCountersFor(Counters, String) - Method in class cascading.stats.hadoop.HadoopStepCounterCache

getCounterValue(Enum) - Method in class cascading.flow.hadoop.HadoopFlowProcess

getCounterValue(String, String) - Method in class cascading.flow.hadoop.HadoopFlowProcess

getCounterValue(Map<String, Map<String, Long>>, Enum) - Method in class cascading.stats.hadoop.HadoopNodeCounterCache

getCounterValue(Map<String, Map<String, Long>>, String, String) - Method in class cascading.stats.hadoop.HadoopNodeCounterCache

getCounterValue(Enum) - Method in class cascading.stats.hadoop.HadoopSliceStats

getCounterValue(String, String) - Method in class cascading.stats.hadoop.HadoopSliceStats

getCounterValue(Counters, Enum) - Method in class cascading.stats.hadoop.HadoopStepCounterCache

getCounterValue(Counters, String, String) - Method in class cascading.stats.hadoop.HadoopStepCounterCache

getCurrentNumMappers() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getCurrentNumReducers() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getCurrentSliceNum() - Method in class cascading.flow.hadoop.HadoopFlowProcess

Method getCurrentTaskNum returns the task number of this task.

getDefaultConfig() - Method in class cascading.flow.hadoop.planner.HadoopPlanner

getDefaultIntermediateSchemeClass() - Method in class cascading.flow.hadoop2.Hadoop2MR1FlowConnector

getDefaultURIScheme(Tap) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

getDelimitedFile(Fields, boolean, String, String, Class[], String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getDelimitedFile(Fields, boolean, boolean, String, String, Class[], String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getDelimitedFile(String, String, FieldTypeResolver, String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getDiagnostics() - Method in class cascading.stats.hadoop.HadoopSliceStats

getElementGraph() - Method in class cascading.flow.hadoop.MapReduceFlowStep

getEventId() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

getFieldComparatorsFrom(Configuration, String) - Static method in class cascading.tuple.hadoop.util.DeserializerComparator

getFlowConnector(Map<Object, Object>) - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

getFlowNodeGraph() - Method in class cascading.flow.hadoop.MapReduceFlowStep

getFlowProcess() - Method in class cascading.flow.hadoop.HadoopFlow

getFlowProcess() - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

getFlowStepFactory() - Method in class cascading.flow.hadoop.planner.HadoopPlanner

getGrouping() - Method in class cascading.flow.hadoop.HadoopGroupByClosure

getGrouping() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection

getGroupNames(Map<String, Map<String, Long>>) - Method in class cascading.stats.hadoop.HadoopNodeCounterCache

getGroupNames(Counters) - Method in class cascading.stats.hadoop.HadoopStepCounterCache

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

getHiddenTemporaryPath() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getID() - Method in class cascading.stats.hadoop.HadoopSliceStats

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

getJob(RunningJob) - Static method in class cascading.stats.hadoop.HadoopStepStats

getJobClient() - Method in class cascading.stats.hadoop.HadoopStepStats

Method getJobClient returns the Hadoop JobClient managing this Hadoop job.

getJobConf() - Method in class cascading.flow.hadoop.HadoopFlowProcess

Method getJobConf returns the jobConf of this HadoopFlowProcess object.

getJobConf() - Method in class cascading.flow.hadoop.MapReduceFlowStep

getJobPollingInterval(JobConf) - Static method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

getJobStatusClient() - Method in class cascading.stats.hadoop.HadoopNodeCounterCache

getKind() - Method in class cascading.stats.hadoop.HadoopNodeStats

getKind() - Method in class cascading.stats.hadoop.HadoopSliceStats

getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.hadoop.HadoopSliceStats

getLocalCacheFiles(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.DistCacheTap

getLongComparator(boolean) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getMapProgress() - Method in class cascading.stats.hadoop.HadoopStepStats

Returns the underlying Map tasks progress percentage.

getMaxNumParallelSteps() - Method in class cascading.flow.hadoop.HadoopFlow

getName() - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

getNumMapTasks(Map<Object, Object>) - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

getNumMapTasks() - Method in class cascading.stats.hadoop.HadoopStepStats

Method getNumMapTasks returns the numMapTasks from the Hadoop job file.

getNumProcessSlices() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getNumReduceTasks(Map<Object, Object>) - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

getNumReduceTasks() - Method in class cascading.stats.hadoop.HadoopStepStats

Method getNumReduceTasks returns the numReducerTasks from the Hadoop job file.

getOrCreateFlowStepGraph() - Method in class cascading.flow.hadoop.MultiMapReduceFlow

getOutput() - Method in class cascading.flow.hadoop.stream.element.HadoopSinkStage

getOutputCollector() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getParent(LazyCollection) - Static method in class cascading.flow.hadoop.util.LazyCollection

getParentStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats

getPartition(IndexTuple, Tuple, int) - Method in class cascading.tuple.hadoop.util.CoGroupingPartitioner

getPartition(Tuple, Tuple, int) - Method in class cascading.tuple.hadoop.util.GroupingPartitioner

getPartition(TuplePair, Tuple, int) - Method in class cascading.tuple.hadoop.util.GroupingSortingPartitioner

getPartitionTap(Tap, Partition, int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getPlannerInfo(String) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

getPlannerInfo(String) - Method in class cascading.flow.hadoop2.Hadoop2MR1Planner

getPlatformInfo() - Method in class cascading.flow.hadoop.planner.HadoopPlanner

getProcessAttemptID() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

getProcessDuration() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

getProcessFinishTime() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProcessHostname() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

getProcessNodeID() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProcessProgress() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProcessSliceID() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProcessStartTime() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProcessStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProcessStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

getProcessStatusURL() - Method in class cascading.stats.hadoop.HadoopStepStats

getProcessStepID() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProcessStepID() - Method in class cascading.stats.hadoop.HadoopStepStats

getProgress() - Method in class cascading.stats.hadoop.HadoopSliceStats

getProperties() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getProperty(String) - Method in class cascading.flow.hadoop.HadoopFlow

Method getProperty returns the value associated with the given key from the underlying properties system.

getProperty(String) - Method in class cascading.flow.hadoop.HadoopFlowProcess

getPropertyKeys() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getReduceProgress() - Method in class cascading.stats.hadoop.HadoopStepStats

Returns the underlying Reduce tasks progress percentage.

getReporter() - Method in class cascading.flow.hadoop.HadoopFlowProcess

getStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats

getStatus() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

getStatusURL() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

getStatusURL() - Method in class cascading.stats.hadoop.HadoopStepStats

Deprecated.

see HadoopStepStats.getProcessStatusURL()

getStreamComparison() - Method in class cascading.tuple.hadoop.util.BaseTupleComparator

getStreamedHead() - Method in class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph

getStringComparator(boolean) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getTap(Scheme, String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getTaskIDNum() - Method in class cascading.stats.hadoop.HadoopSliceStats

getTaskReport() - Method in class cascading.stats.hadoop.HadoopSliceStats

getTestConfigDefScheme() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getTestFailScheme() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getTextFile(Fields, Fields, String, SinkMode) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

getThrowable() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

getTotalSliceCPUMilliSeconds() - Method in class cascading.flow.hadoop.HadoopFlow

getURIScheme(Tap) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

getValueIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure

GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression

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

GroupingPartitioner - Class in cascading.tuple.hadoop.util

Class GroupingPartitioner is an implementation of Partitioner.

GroupingPartitioner() - Constructor for class cascading.tuple.hadoop.util.GroupingPartitioner

GroupingSortingComparator - Class in cascading.tuple.hadoop.util

Class TuplePairComparator is an implementation of RawComparator.

GroupingSortingComparator() - Constructor for class cascading.tuple.hadoop.util.GroupingSortingComparator

GroupingSortingPartitioner - Class in cascading.tuple.hadoop.util

Class GroupingSortingPartitioner is an implementation of Partitioner.

GroupingSortingPartitioner() - Constructor for class cascading.tuple.hadoop.util.GroupingSortingPartitioner

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

Hadoop2MR1FlowConnector - Class in cascading.flow.hadoop2

Use the Hadoop2MR1FlowConnector to link source and sink Tap instances with an assembly of Pipe instances into an executable HadoopFlow for execution on an Apache Hadoop cluster.

Hadoop2MR1FlowConnector() - Constructor for class cascading.flow.hadoop2.Hadoop2MR1FlowConnector

Constructor FlowConnector creates a new FlowConnector instance.

Hadoop2MR1FlowConnector(Map<Object, Object>) - Constructor for class cascading.flow.hadoop2.Hadoop2MR1FlowConnector

Constructor FlowConnector creates a new FlowConnector instance using the given Properties instance as default value for the underlying jobs.

Hadoop2MR1FlowConnector(RuleRegistrySet) - Constructor for class cascading.flow.hadoop2.Hadoop2MR1FlowConnector

Constructor HadoopFlowConnector creates a new HadoopFlowConnector instance.

Hadoop2MR1FlowConnector(Map<Object, Object>, RuleRegistrySet) - Constructor for class cascading.flow.hadoop2.Hadoop2MR1FlowConnector

Constructor HadoopFlowConnector creates a new HadoopFlowConnector instance using the given Properties instance as default value for the underlying jobs.

Hadoop2MR1Planner - Class in cascading.flow.hadoop2

Class Hadoop2MR1Planner is the core Hadoop MapReduce planner used by default through the Hadoop2MR1FlowConnector.

Hadoop2MR1Planner() - Constructor for class cascading.flow.hadoop2.Hadoop2MR1Planner

Hadoop2MR1Platform - Class in cascading.platform.hadoop2

Class Hadoop2Platform is automatically loaded and injected into a PlatformTestCase instance so that all *PlatformTest classes can be tested against Apache Hadoop 2.x.

Hadoop2MR1Platform() - Constructor for class cascading.platform.hadoop2.Hadoop2MR1Platform

HadoopCoGroupClosure - Class in cascading.flow.hadoop

Class CoGroupClosure is used internally to represent co-grouping results of multiple tuple streams.

HadoopCoGroupClosure(FlowProcess, int, Fields[], Fields[]) - Constructor for class cascading.flow.hadoop.HadoopCoGroupClosure

HadoopCoGroupClosure.Spill - Enum in cascading.flow.hadoop

HadoopCoGroupGate - Class in cascading.flow.hadoop.stream.element

HadoopCoGroupGate(FlowProcess, CoGroup, IORole) - Constructor for class cascading.flow.hadoop.stream.element.HadoopCoGroupGate

HadoopCounterCache<JobStatus,Counters> - Class in cascading.stats.hadoop

HadoopCounterCache(CascadingStats, Configuration) - Constructor for class cascading.stats.hadoop.HadoopCounterCache

HadoopFlow - Class in cascading.flow.hadoop

Class HadoopFlow is the Apache Hadoop specific implementation of a Flow.

HadoopFlow() - Constructor for class cascading.flow.hadoop.HadoopFlow

HadoopFlow(PlatformInfo, Map<Object, Object>, JobConf, String, Map<String, String>) - Constructor for class cascading.flow.hadoop.HadoopFlow

HadoopFlow(PlatformInfo, Map<Object, Object>, JobConf, FlowDef) - Constructor for class cascading.flow.hadoop.HadoopFlow

HadoopFlowProcess - Class in cascading.flow.hadoop

Class HadoopFlowProcess is an implementation of FlowProcess for Hadoop.

HadoopFlowProcess() - Constructor for class cascading.flow.hadoop.HadoopFlowProcess

HadoopFlowProcess(Configuration) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess

HadoopFlowProcess(JobConf) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess

HadoopFlowProcess(FlowSession, JobConf) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess

HadoopFlowProcess(FlowSession, JobConf, boolean) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess

Constructor HadoopFlowProcess creates a new HadoopFlowProcess instance.

HadoopFlowProcess(HadoopFlowProcess, JobConf) - Constructor for class cascading.flow.hadoop.HadoopFlowProcess

HadoopFlowStep - Class in cascading.flow.hadoop

HadoopFlowStep() - Constructor for class cascading.flow.hadoop.HadoopFlowStep

HadoopFlowStep(String, int) - Constructor for class cascading.flow.hadoop.HadoopFlowStep

HadoopFlowStep(ElementGraph, FlowNodeGraph) - Constructor for class cascading.flow.hadoop.HadoopFlowStep

HadoopFlowStepJob - Class in cascading.flow.hadoop.planner

HadoopFlowStepJob(ClientState, BaseFlowStep<JobConf>, JobConf) - Constructor for class cascading.flow.hadoop.planner.HadoopFlowStepJob

HadoopGroupByClosure - Class in cascading.flow.hadoop

Class GroupClosure is used internally to represent groups of tuples during grouping.

HadoopGroupByClosure(FlowProcess, Fields[], Fields[]) - Constructor for class cascading.flow.hadoop.HadoopGroupByClosure

HadoopGroupByGate - Class in cascading.flow.hadoop.stream.element

HadoopGroupByGate(FlowProcess, GroupBy, IORole) - Constructor for class cascading.flow.hadoop.stream.element.HadoopGroupByGate

HadoopGroupGate - Class in cascading.flow.hadoop.stream

HadoopGroupGate(FlowProcess, Splice, IORole) - Constructor for class cascading.flow.hadoop.stream.HadoopGroupGate

HadoopMapStreamGraph - Class in cascading.flow.hadoop.stream.graph

HadoopMapStreamGraph(HadoopFlowProcess, FlowNode, Tap) - Constructor for class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph

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

HadoopMRUtil - Class in cascading.flow.hadoop.util

HadoopMRUtil() - Constructor for class cascading.flow.hadoop.util.HadoopMRUtil

HadoopNodeCounterCache - Class in cascading.stats.hadoop

HadoopNodeCounterCache(FlowNodeStats, Configuration) - Constructor for class cascading.stats.hadoop.HadoopNodeCounterCache

HadoopNodeStats - Class in cascading.stats.hadoop

HadoopNodeStats(HadoopStepStats, Configuration, HadoopSliceStats.Kind, FlowNode, ClientState) - Constructor for class cascading.stats.hadoop.HadoopNodeStats

Constructor CascadingStats creates a new CascadingStats instance.

HadoopPlanner - Class in cascading.flow.hadoop.planner

Class HadoopPlanner is the core Hadoop MapReduce planner used by default through a FlowConnector sub-class.

HadoopPlanner() - Constructor for class cascading.flow.hadoop.planner.HadoopPlanner

HadoopReduceStreamGraph - Class in cascading.flow.hadoop.stream.graph

HadoopReduceStreamGraph(HadoopFlowProcess, FlowNode, FlowElement) - Constructor for class cascading.flow.hadoop.stream.graph.HadoopReduceStreamGraph

HadoopSinkStage - Class in cascading.flow.hadoop.stream.element

HadoopSinkStage(FlowProcess, Tap) - Constructor for class cascading.flow.hadoop.stream.element.HadoopSinkStage

HadoopSliceStats - Class in cascading.stats.hadoop

Class HadoopTaskStats tracks individual task stats.

HadoopSliceStats.HadoopAttempt - Class in cascading.stats.hadoop

HadoopSliceStats.HadoopAttempt(TaskCompletionEvent) - Constructor for class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt

HadoopSliceStats.Kind - Enum in cascading.stats.hadoop

HadoopStepCounterCache - Class in cascading.stats.hadoop

HadoopStepCounterCache(CascadingStats, Configuration) - Constructor for class cascading.stats.hadoop.HadoopStepCounterCache

HadoopStepStats - Class in cascading.stats.hadoop

Class HadoopStepStats provides Hadoop specific statistics and methods to underlying Hadoop facilities.

HadoopStepStats(FlowStep<JobConf>, ClientState) - Constructor for class cascading.stats.hadoop.HadoopStepStats

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

hasNext() - Method in class cascading.flow.hadoop.util.TimedIterator

hasReducer(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopMRUtil

I

increment(Enum, long) - Method in class cascading.flow.hadoop.HadoopFlowProcess

increment(String, String, long) - Method in class cascading.flow.hadoop.HadoopFlowProcess

IndexTupleCoGroupingComparator - Class in cascading.tuple.hadoop.util

IndexTupleCoGroupingComparator() - Constructor for class cascading.tuple.hadoop.util.IndexTupleCoGroupingComparator

initConfig(Map<Object, Object>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlow

initFromProperties(Map<Object, Object>) - Method in class cascading.flow.hadoop.HadoopFlow

initFromSink(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep

initFromSources(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep

initFromTraps(FlowProcess<JobConf>, JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep

initialize(FlowConnector, Map<Object, Object>) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

initializeFrom(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow

initializeFrom(List<JobConf>) - Method in class cascading.flow.hadoop.MultiMapReduceFlow

initLists() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure

internalBlockOnStop() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

internalClean(boolean) - Method in class cascading.flow.hadoop.HadoopFlow

internalIsStartedRunning() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

internalJobId() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

internalNonBlockingIsComplete() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

internalNonBlockingIsSuccessful() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

internalNonBlockingStart() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

internalNonBlockingSubmit() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

internalShutdown() - Method in class cascading.flow.hadoop.HadoopFlow

internalStart() - Method in class cascading.flow.hadoop.HadoopFlow

isCounterStatusInitialized() - Method in class cascading.flow.hadoop.HadoopFlowProcess

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

isHadoopLocalMode(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep

isHDFSAvailable() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

isMapper() - Method in class cascading.flow.hadoop.HadoopFlowProcess

Method isMapper returns true if this part of the FlowProcess is a MapReduce mapper.

isMapReduce() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

isPreserveTemporaryFiles() - Method in class cascading.flow.hadoop.HadoopFlow

Method isPreserveTemporaryFiles returns false if temporary files will be cleaned when this Flow completes.

isRemoteExecution() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

isSuccessful() - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

iterate(Set<Hfs>, MultiSourceTap) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

iterator() - Method in class cascading.flow.hadoop.util.FalseCollection

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

iterators(TimedIterator<V>...) - Static method in class cascading.flow.hadoop.util.TimedIterator

J

jobClient - Variable in class cascading.flow.hadoop.planner.HadoopFlowStepJob

Field jobClient

K

keepAlive() - Method in class cascading.flow.hadoop.HadoopFlowProcess

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

logger - Variable in class cascading.platform.hadoop.BaseHadoopPlatform

M

makeIterator(int, Iterator) - Method in class cascading.flow.hadoop.HadoopGroupByClosure

makeNameFromPath(Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

makeStepGraph(JobConf) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

makeTempTap(String, String) - Method in class cascading.flow.hadoop.planner.HadoopPlanner

MalformedJoinExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph

MalformedJoinExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.MalformedJoinExpressionGraph

MAP - Static variable in class cascading.flow.hadoop.MapReduceFlowStep

MapReduceFlow - Class in cascading.flow.hadoop

Class MapReduceFlow is a HadoopFlow subclass that supports custom MapReduce jobs pre-configured via the JobConf object.

MapReduceFlow(JobConf) - Constructor for class cascading.flow.hadoop.MapReduceFlow

Constructor MapReduceFlow creates a new MapReduceFlow instance.

MapReduceFlow(JobConf, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow

Constructor MapReduceFlow creates a new MapReduceFlow instance.

MapReduceFlow(String, JobConf) - Constructor for class cascading.flow.hadoop.MapReduceFlow

Constructor MapReduceFlow creates a new MapReduceFlow instance.

MapReduceFlow(String, JobConf, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow

Constructor MapReduceFlow creates a new MapReduceFlow instance.

MapReduceFlow(Properties, String, JobConf, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow

Constructor MapReduceFlow creates a new MapReduceFlow instance.

MapReduceFlow(Properties, String, JobConf, Map<String, String>, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow

Constructor MapReduceFlow creates a new MapReduceFlow instance.

MapReduceFlow(Properties, String, JobConf, Map<String, String>, boolean, boolean) - Constructor for class cascading.flow.hadoop.MapReduceFlow

Constructor MapReduceFlow creates a new MapReduceFlow instance.

MapReduceFlowStep - Class in cascading.flow.hadoop

Class MapReduceFlowStep wraps a JobConf and allows it to be executed as a Flow.

MapReduceFlowStep(HadoopFlow, JobConf) - Constructor for class cascading.flow.hadoop.MapReduceFlowStep

MapReduceFlowStep(HadoopFlow, String, JobConf, Tap) - Constructor for class cascading.flow.hadoop.MapReduceFlowStep

MapReduceHadoopRuleRegistry - Class in cascading.flow.hadoop.planner

MapReduceHadoopRuleRegistry() - Constructor for class cascading.flow.hadoop.planner.MapReduceHadoopRuleRegistry

MERGE - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression

mergeMapIntoConfig(JobConf, Map<String, String>) - Method in class cascading.flow.hadoop.HadoopFlowProcess

MultiMapReduceFlow - Class in cascading.flow.hadoop

Class MultiMapReduceFlow is a HadoopFlow subclass that supports custom MapReduce jobs pre-configured via one or more JobConf objects.

MultiMapReduceFlow(String, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow

Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.

MultiMapReduceFlow(Map<Object, Object>, String, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow

Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.

MultiMapReduceFlow(Map<Object, Object>, String, Map<String, String>, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow

Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.

MultiMapReduceFlow(Map<Object, Object>, String, Map<String, String>, boolean, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow

Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.

MultiMapReduceFlow(PlatformInfo, Map<Object, Object>, String) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow

Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.

MultiMapReduceFlow(PlatformInfo, Map<Object, Object>, String, Map<String, String>) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow

Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.

MultiTapGroupNodePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner

MultiTapGroupNodePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.MultiTapGroupNodePartitioner

N

newConfig(JobConf) - Method in class cascading.flow.hadoop.HadoopFlow

newInstance(String) - Method in class cascading.flow.hadoop.HadoopFlowProcess

next() - Method in class cascading.flow.hadoop.util.TimedIterator

NoGroupTapExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph

NoGroupTapExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.NoGroupTapExpressionGraph

notifyComplete() - Method in class cascading.flow.hadoop.MultiMapReduceFlow

numSelfJoins - Variable in class cascading.flow.hadoop.HadoopCoGroupClosure

O

onCompleted(Flow) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

onStarting(Flow) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

onStopping(Flow) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

onThrowable(Flow, Throwable) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

openSystemIntermediateForWrite() - Method in class cascading.flow.hadoop.HadoopFlowProcess

openTapForRead(Tap) - Method in class cascading.flow.hadoop.HadoopFlowProcess

openTapForWrite(Tap) - Method in class cascading.flow.hadoop.HadoopFlowProcess

openTrapForWrite(Tap) - Method in class cascading.flow.hadoop.HadoopFlowProcess

P

performRawComparison() - Method in class cascading.tuple.hadoop.util.DeserializerComparator

PLATFORM_NAME - Static variable in class cascading.flow.hadoop.planner.HadoopPlanner

PLATFORM_NAME - Static variable in class cascading.flow.hadoop2.Hadoop2MR1Planner

prepare() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

properties - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform

R

readStateFromDistCache(JobConf, String, String) - Static method in class cascading.flow.hadoop.util.HadoopMRUtil

receive(Duct, int, TupleEntry) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

reduce(Object, Iterator, OutputCollector, Reporter) - Method in class cascading.flow.hadoop.FlowReducer

REDUCE - Static variable in class cascading.flow.hadoop.MapReduceFlowStep

registerHadoopShutdownHook() - Method in class cascading.flow.hadoop.HadoopFlow

remoteExists(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

remoteRemove(String, boolean) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

remove(Object) - Method in class cascading.flow.hadoop.util.FalseCollection

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

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

reportLocalError(Throwable) - Static method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

Internal method to report errors that happen on hadoop local mode.

reset(Tuple, Iterator<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(RecordReader, OutputCollector, Reporter) - Method in class cascading.flow.hadoop.FlowMapper

runningJob - Variable in class cascading.flow.hadoop.planner.HadoopFlowStepJob

Field runningJob

S

safeFileName(String) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

Replaces characters, that are not allowed by HDFS with an "_".

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(JobConf, Object, Object) - Method in class cascading.flow.hadoop.HadoopFlow

setGrouping(Tuple) - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection

setLastFetch(long) - Method in class cascading.stats.hadoop.HadoopSliceStats

setNumGatherPartitions(int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

setNumMappers(int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

setNumMapTasks(Map<Object, Object>, int) - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

setNumReducers(int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform

setNumReduceTasks(Map<Object, Object>, int) - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

setOutputCollector(OutputCollector) - Method in class cascading.flow.hadoop.HadoopFlowProcess

setReporter(Reporter) - Method in class cascading.flow.hadoop.HadoopFlowProcess

Method setReporter sets the reporter of this HadoopFlowProcess object.

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

setUp() - Method in class cascading.platform.hadoop2.Hadoop2MR1Platform

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

SHUFFLE - Static variable in class cascading.flow.hadoop.MapReduceFlowStep

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

spawnSteps() - Method in class cascading.flow.hadoop.MultiMapReduceFlow

spillCount() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection

start(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

stepsAreLocal() - Method in class cascading.flow.hadoop.HadoopFlow

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

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

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

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

tearDown() - Method in class cascading.platform.hadoop.BaseHadoopPlatform

testExists(Flow, Hfs) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener

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

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

toSinkTap(JobConf, Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

toSourceTap(JobConf, Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.BaseMapReduceFlow

toString() - Method in class cascading.stats.hadoop.HadoopSliceStats

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

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

unwrapGrouping(Tuple) - Method in class cascading.flow.hadoop.stream.element.HadoopGroupByGate

unwrapGrouping(Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

update(String, String) - Method in class cascading.flow.hadoop.ConfigurationSetter

update(CascadingStats.Status, HadoopSliceStats.Kind, TaskReport, long) - Method in class cascading.stats.hadoop.HadoopSliceStats

updateFlowStepGraph(FlowStepGraph, Collection<MapReduceFlowStep>) - Method in class cascading.flow.hadoop.MultiMapReduceFlow

updateNodeStatus(FlowNodeStats) - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob

updateWithFlowSteps(Collection<MapReduceFlowStep>) - Method in class cascading.flow.hadoop.MultiMapReduceFlow

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.

valueOf(String) - Static method in enum cascading.stats.hadoop.HadoopSliceStats.Kind

Returns the enum constant of this type with the specified name.

values() - Static method in enum cascading.flow.hadoop.HadoopCoGroupClosure.Spill

Returns an array containing the constants of this enum type, in the order they are declared.

values - Variable in class cascading.flow.hadoop.HadoopGroupByClosure

values() - Static method in enum cascading.flow.hadoop.stream.HadoopMemoryJoinGate.Spill

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum cascading.stats.hadoop.HadoopSliceStats.Kind

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitOnLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate

wrapGroupingAndCollect(Duct, int, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.element.HadoopCoGroupGate

wrapGroupingAndCollect(Duct, int, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.element.HadoopGroupByGate

wrapGroupingAndCollect(Duct, int, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate

writeStateToDistCache(JobConf, String, String, String) - Static method in class cascading.flow.hadoop.util.HadoopMRUtil

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