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

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