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

A

accept(Tuple, Iterator<Tuple>[]) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
accept(Class<?>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization
 
accept(Class<?>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
accept(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
Method accept implements Serialization.accept(Class).
accepts(Class<T>) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
accepts(Class<T>) - Method in interface cascading.flow.hadoop.util.ObjectSerializer
 
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
 
addComparators(Configuration, String, Map<String, Fields>, BaseFlowStep, Group) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
addComparators(Configuration, String, Map<String, Fields>, Fields) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
addFields(Configuration, String, Map<Integer, Fields>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
addHadoopSerialization(String) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addHadoopSerialization adds a Hadoop serialization className to be used as properties.
addHadoopSerializations(List<String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addHadoopSerializations adds the Hadoop serialization classNames to be used as properties.
addInputFormat(JobConf, JobConf...) - Static method in class cascading.tap.hadoop.io.MultiInputFormat
Used to set the current JobConf with all sub jobs configurations.
addInputPath(Configuration, Path) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
addLocalCacheFiles(Configuration, URI) - Method in class cascading.tap.hadoop.BaseDistCacheTap
 
addLocalCacheFiles(Configuration, URI) - Method in class cascading.tap.hadoop.DistCacheTap
 
addPropertiesTo(Properties) - Method in class cascading.tap.hadoop.HfsProps
 
addPropertiesTo(Properties) - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
addSerialization(Map<Object, Object>, String) - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Adds the given className as a Hadoop IO serialization class.
addSerializationToken(Map<Object, Object>, int, String) - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Adds the given token and className pair as a serialization token property.
addSerializationToken(int, String) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addSerializationToken adds the given integer token and classNames as a serialization properties.
addSerializationTokens(Map<Integer, String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method addSerializationTokens adds the given integer tokens and classNames Map as a serialization properties.
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
 
append(Path, int, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
applies(PlannerContext, ElementGraph, Scope) - Method in class cascading.flow.hadoop.planner.rule.scopeexpression.EquivalentTapsScopeExpression
 
applySourceConfInitIdentifiers(FlowProcess<? extends Configuration>, Configuration, String...) - Method in class cascading.tap.hadoop.Hfs
 
areCountersAvailable(FlowNodeStats) - Method in class cascading.stats.hadoop.HadoopNodeCounterCache
 
areCountersAvailable(RunningJob) - Method in class cascading.stats.hadoop.HadoopStepCounterCache
 
areTypesIgnored() - Method in class cascading.tuple.hadoop.TupleSerialization
 
areTypesRequired() - Method in class cascading.tuple.hadoop.TupleSerialization
 
asJobConfInstance(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 

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
 
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
 
BaseDistCacheTap - Class in cascading.tap.hadoop
 
BaseDistCacheTap(Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.BaseDistCacheTap
 
BaseHadoopPlatform<Config extends Configuration> - Class in cascading.platform.hadoop
 
BaseHadoopPlatform() - Constructor for class cascading.platform.hadoop.BaseHadoopPlatform
 
BaseTupleComparator - Class in cascading.tuple.hadoop.util
 
BaseTupleComparator() - Constructor for class cascading.tuple.hadoop.util.BaseTupleComparator
 
BaseTupleComparator.RawComparison - Interface in cascading.tuple.hadoop.util
 
BigDecimalSerialization - Class in cascading.tuple.hadoop
Class BigDecimalSerialization is an implementation of Hadoop's Serialization interface for use by BigDecimal instances.
BigDecimalSerialization() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization
 
BigDecimalSerialization.BigDecimalDeserializer - Class in cascading.tuple.hadoop
 
BigDecimalSerialization.BigDecimalDeserializer() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
BigDecimalSerialization.BigDecimalSerializer - Class in cascading.tuple.hadoop
 
BigDecimalSerialization.BigDecimalSerializer() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
bind(StreamGraph) - Method in class cascading.flow.hadoop.stream.element.HadoopCoGroupGate
 
bind(StreamGraph) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
BufferedInputStream - Class in cascading.tuple.hadoop.io
 
BufferedInputStream() - Constructor for class cascading.tuple.hadoop.io.BufferedInputStream
 
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
 
BytesComparator - Class in cascading.tuple.hadoop.util
Class BytesComparator is used to compare arrays of bytes.
BytesComparator() - Constructor for class cascading.tuple.hadoop.util.BytesComparator
 
BytesSerialization - Class in cascading.tuple.hadoop
Class BytesSerialization is an implementation of Hadoop's Serialization interface for use by byte arrays (byte[]).
BytesSerialization() - Constructor for class cascading.tuple.hadoop.BytesSerialization
 
BytesSerialization.RawBytesDeserializer - Class in cascading.tuple.hadoop
 
BytesSerialization.RawBytesDeserializer() - Constructor for class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
BytesSerialization.RawBytesSerializer - Class in cascading.tuple.hadoop
 
BytesSerialization.RawBytesSerializer() - Constructor for class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 

C

callCopyConstructor(Class, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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.platform.hadoop - package cascading.platform.hadoop
 
cascading.scheme.hadoop - package cascading.scheme.hadoop
 
cascading.stats.hadoop - package cascading.stats.hadoop
 
cascading.tap.hadoop - package cascading.tap.hadoop
 
cascading.tap.hadoop.io - package cascading.tap.hadoop.io
 
cascading.tap.hadoop.util - package cascading.tap.hadoop.util
 
cascading.tuple.hadoop - package cascading.tuple.hadoop
 
cascading.tuple.hadoop.collect - package cascading.tuple.hadoop.collect
 
cascading.tuple.hadoop.io - package cascading.tuple.hadoop.io
 
cascading.tuple.hadoop.util - package cascading.tuple.hadoop.util
 
CASCADING_FLOW_EXECUTING - Static variable in class cascading.flow.hadoop.util.HadoopUtil
 
CASCADING_SOURCE_PATH - Static variable in class cascading.tap.hadoop.io.MultiInputSplit
 
checkPlatform(Configuration) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
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
 
cleanupJob(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
May only be called once.
cleanupTapMetaData(Configuration, Tap) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
Called from flow step to remove temp dirs
clear() - Method in class cascading.flow.hadoop.util.FalseCollection
 
clear() - Method in class cascading.flow.hadoop.util.LazyCollection
 
clear() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
clearGroups() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
close() - Method in class cascading.flow.hadoop.FlowReducer
 
close() - Method in class cascading.flow.hadoop.util.TimedIterator
 
close() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
close() - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
close() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
 
close() - Method in class cascading.tap.hadoop.io.RecordReaderIterator
 
close() - Method in class cascading.tap.hadoop.io.TapOutputCollector
 
close() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
close() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
close() - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
close() - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
close() - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
close() - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 
close() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
close() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
closure - Variable in class cascading.flow.hadoop.stream.HadoopGroupGate
 
CoGroupingComparator - Class in cascading.tuple.hadoop.util
Class GroupingComparator is an implementation of RawComparator.
CoGroupingComparator() - Constructor for class cascading.tuple.hadoop.util.CoGroupingComparator
 
CoGroupingPartitioner - Class in cascading.tuple.hadoop.util
Class GroupingPartitioner is an implementation of Partitioner.
CoGroupingPartitioner() - Constructor for class cascading.tuple.hadoop.util.CoGroupingPartitioner
 
collect(Object, Object) - Method in class cascading.tap.hadoop.io.TapOutputCollector
Method collect writes the given values to the Tap this instance encapsulates.
collect(Object, Object) - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
collections - Variable in class cascading.flow.hadoop.HadoopCoGroupClosure
Field groups
collector - Variable in class cascading.flow.hadoop.stream.HadoopGroupGate
 
COMBINE_INPUT_FILES - Static variable in class cascading.tap.hadoop.HfsProps
Field COMBINE_INPUT_FILES
COMBINE_INPUT_FILES_SAFE_MODE - Static variable in class cascading.tap.hadoop.HfsProps
Field COMBINE_INPUT_FILES_SAFEMODE
COMBINE_INPUT_FILES_SIZE_MAX - Static variable in class cascading.tap.hadoop.HfsProps
Field COMBINE_INPUT_FILES_SIZE_MAX
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
 
combinedInputMaxSize - Variable in class cascading.tap.hadoop.HfsProps
 
combinedInputSafeMode - Variable in class cascading.tap.hadoop.HfsProps
 
CombineFileRecordReaderWrapper<K,V> - Class in cascading.tap.hadoop.io
A wrapper class for a record reader that handles a single file split.
CombineFileRecordReaderWrapper(CombineFileSplit, Configuration, Reporter, Integer) - Constructor for class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
CombineInputPartitionTupleEntryIterator - Class in cascading.tap.hadoop.io
 
CombineInputPartitionTupleEntryIterator(FlowProcess<? extends Configuration>, Fields, Partition, String, TupleEntrySchemeIterator) - Constructor for class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
 
commitTask(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
copies all files from the taskoutputpath to the outputpath
compare(byte[], 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[], byte[]) - Method in class cascading.tuple.hadoop.util.BytesComparator
 
compare(BufferedInputStream, BufferedInputStream) - Method in class cascading.tuple.hadoop.util.BytesComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.CoGroupingComparator
 
compare(IndexTuple, IndexTuple) - Method in class cascading.tuple.hadoop.util.CoGroupingComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.DelegatingTupleElementComparator
 
compare(TupleInputStream, TupleInputStream) - Method in class cascading.tuple.hadoop.util.DelegatingTupleElementComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.GroupingComparator
 
compare(TuplePair, TuplePair) - Method in class cascading.tuple.hadoop.util.GroupingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.GroupingSortingComparator
 
compare(TuplePair, TuplePair) - Method in class cascading.tuple.hadoop.util.GroupingSortingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.IndexTupleCoGroupingComparator
 
compare(IndexTuple, IndexTuple) - Method in class cascading.tuple.hadoop.util.IndexTupleCoGroupingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.ReverseGroupingSortingComparator
 
compare(TuplePair, TuplePair) - Method in class cascading.tuple.hadoop.util.ReverseGroupingSortingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class cascading.tuple.hadoop.util.ReverseTupleComparator
 
compare(Tuple, Tuple) - Method in class cascading.tuple.hadoop.util.ReverseTupleComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TupleElementComparator
 
compare(TupleInputStream, TupleInputStream) - Method in class cascading.tuple.hadoop.util.TupleElementComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TupleElementStreamComparator
 
compare(HadoopTupleInputStream, HadoopTupleInputStream) - Method in class cascading.tuple.hadoop.util.TupleElementStreamComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TypedTupleElementComparator
 
compare(TupleInputStream, TupleInputStream) - Method in class cascading.tuple.hadoop.util.TypedTupleElementComparator
 
compare(Object, Object) - Method in class cascading.tuple.hadoop.util.TypedTupleElementStreamComparator
 
compare(HadoopTupleInputStream, HadoopTupleInputStream) - Method in class cascading.tuple.hadoop.util.TypedTupleElementStreamComparator
 
compareTuples(Comparator[], Tuple, Tuple) - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
compareTuples(Class[], Comparator[]) - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
complete(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
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.tap.hadoop.io.MultiInputSplit
 
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(C) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
copyConfiguration(Map<Object, Object>, C) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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.
copyJobConf(C) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
copyJobConf(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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.
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
 
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
create(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
 
create(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
 
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.hadoop.HadoopFlowConnector
 
createFlow(FlowDef) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
createFlowNodeGraph(JobConf) - Static method in class cascading.flow.hadoop.MapReduceFlowStep
 
createFlowPlanner() - Method in class cascading.flow.hadoop.HadoopFlowConnector
 
createFlowStep(JobConf, Tap) - Method in class cascading.flow.hadoop.MapReduceFlow
 
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.
createJobConf(Map<Object, Object>, JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
createKey() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
createKey() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
createKeySet() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
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
 
createPlatformInfo(Class, String, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
createProperties(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
createResource(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
createSinks(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
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.MapReduceFlow
 
createStepStats(ClientState) - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
createTraps(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
createTuple() - Method in class cascading.tuple.hadoop.io.IndexTupleDeserializer
 
createTuple() - Method in class cascading.tuple.hadoop.io.KeyIndexTupleDeserializer
 
createTuple() - Method in class cascading.tuple.hadoop.io.KeyTupleDeserializer
 
createTuple() - Method in class cascading.tuple.hadoop.io.TupleDeserializer
 
createTuple() - Method in class cascading.tuple.hadoop.io.TuplePairDeserializer
 
createTuple() - Method in class cascading.tuple.hadoop.io.ValueIndexTupleDeserializer
 
createTuple() - Method in class cascading.tuple.hadoop.io.ValueTupleDeserializer
 
createTupleCollection(Fields) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
createTupleCollection(Tuple) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
 
createTupleEntrySchemeCollector(FlowProcess<? extends Configuration>, Tap, String, long) - Method in class cascading.tap.hadoop.PartitionTap
 
createTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, Tap, String, RecordReader) - Method in class cascading.tap.hadoop.PartitionTap
 
createTupleInputStream(File) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
createTupleMap() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
createTupleOutputStream(File) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
createValue() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
createValue() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 

D

decodeBytes(String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
DEFAULT_CHARSET - Static variable in class cascading.scheme.hadoop.TextDelimited
 
DEFAULT_CHARSET - Static variable in class cascading.scheme.hadoop.TextLine
 
DEFAULT_SOURCE_FIELDS - Static variable in class cascading.scheme.hadoop.TextLine
Field DEFAULT_SOURCE_FIELDS
defaultCodecs - Static variable in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
DelegatingTupleElementComparator - Class in cascading.tuple.hadoop.util
 
DelegatingTupleElementComparator(TupleSerialization) - Constructor for class cascading.tuple.hadoop.util.DelegatingTupleElementComparator
 
delete(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
Deprecated.
delete(Path, boolean) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
deleteChildResource(FlowProcess<? extends Configuration>, String) - Method in class cascading.tap.hadoop.Hfs
 
deleteChildResource(Configuration, String) - Method in class cascading.tap.hadoop.Hfs
 
deleteResource(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
deleteSinkOnInit - Variable in class cascading.flow.hadoop.MapReduceFlow
Field deleteSinkOnInit
delimitedParser - Variable in class cascading.scheme.hadoop.TextDelimited
Field delimitedParser
deserialize(byte[], Class<T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
deserialize(byte[], Class<T>, boolean) - Method in interface cascading.flow.hadoop.util.ObjectSerializer
 
deserialize(BigDecimal) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
deserialize(byte[]) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
deserialize(IndexTuple) - Method in class cascading.tuple.hadoop.io.IndexTupleDeserializer
 
deserialize(Tuple) - Method in class cascading.tuple.hadoop.io.TupleDeserializer
 
deserialize(TuplePair) - Method in class cascading.tuple.hadoop.io.TuplePairDeserializer
 
deserializeBase64(String, Configuration, Class<T>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
This method deserializes the Base64 encoded String into an Object instance.
deserializeBase64(String, Configuration, Class<T>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
deserializeList(byte[], boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
deserializeMap(byte[], boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
DeserializerComparator<T> - Class in cascading.tuple.hadoop.util
Class DeserializerComparator is the base class for all Cascading comparator classes.
DeserializerComparator() - Constructor for class cascading.tuple.hadoop.util.DeserializerComparator
 
dfs - Static variable in class cascading.platform.hadoop.HadoopPlatform
 
Dfs - Class in cascading.tap.hadoop
Class Dfs is a Tap class that provides access to the Hadoop Distributed File System.
Dfs(Scheme, URI) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
Dfs(Scheme, URI, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
Dfs(Scheme, String) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
Dfs(Scheme, String, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs
Constructor Dfs creates a new Dfs instance.
diffConfigIntoMap(C, C) - Method in class cascading.flow.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

encodeBytes(byte[]) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
equals(Object) - Method in class cascading.flow.hadoop.util.LazyCollection
 
equals(Object) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
equals(Object) - Method in class cascading.tap.hadoop.GlobHfs
 
EquivalentTapsScopeExpression - Class in cascading.flow.hadoop.planner.rule.scopeexpression
 
EquivalentTapsScopeExpression() - Constructor for class cascading.flow.hadoop.planner.rule.scopeexpression.EquivalentTapsScopeExpression
 
exists(Path) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 

F

FalseCollection - Class in cascading.flow.hadoop.util
 
FalseCollection() - Constructor for class cascading.flow.hadoop.util.FalseCollection
 
fileInputToTaps(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
fileOutputToTaps(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
fileSys - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform
 
findMainClass(Class) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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.
flush() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
FSDigestInputStream - Class in cascading.tap.hadoop.io
Class FSDigestInputStream is an FSInputStream implementation that can verify a MessageDigest and will count the number of bytes read for use in progress status.
FSDigestInputStream(InputStream, String) - Constructor for class cascading.tap.hadoop.io.FSDigestInputStream
Constructor FSDigestInputStream creates a new FSDigestInputStream instance.
FSDigestInputStream(InputStream, MessageDigest, String) - Constructor for class cascading.tap.hadoop.io.FSDigestInputStream
Constructor FSDigestInputStream creates a new FSDigestInputStream instance.

G

get(String) - Method in class cascading.flow.hadoop.ConfigurationSetter
 
getAttempts() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getBlockSize(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
Method getBlockSize returns the blocksize specified by the underlying file system for this resource.
getBlockSize(Configuration) - Method in class cascading.tap.hadoop.Hfs
Method getBlockSize returns the blocksize specified by the underlying file system for this resource.
getBuffer() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
getByteComparison() - Method in class cascading.tuple.hadoop.util.BaseTupleComparator
 
getByteComparison() - Method in class cascading.tuple.hadoop.util.TupleComparator
 
getCharsetName() - Method in class cascading.scheme.hadoop.TextLine
 
getChildIdentifiers(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
 
getChildIdentifiers(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
getChildIdentifiers(FlowProcess<? extends Configuration>, int, boolean) - Method in class cascading.tap.hadoop.Hfs
 
getChildIdentifiers(Configuration, int, boolean) - Method in class cascading.tap.hadoop.Hfs
 
getClass(String) - Method in class cascading.tuple.hadoop.TupleSerialization
 
getClassNameFor(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
getCodec(FlowProcess<? extends Configuration>, String) - Static method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
getCombinedInputMaxSize() - Method in class cascading.tap.hadoop.HfsProps
 
getCombinedInputSafeMode(Configuration) - Static method in class cascading.tap.hadoop.Hfs
 
getCommonPaths(Map<String, Path>, Map<String, Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getComparator(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
getComparator(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
 
getComparatorFor(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
getConf() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getConf() - Method in class cascading.tuple.hadoop.util.HasherPartitioner
 
getConfig() - Method in class cascading.flow.hadoop.HadoopFlow
 
getConfig() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getConfig(Configuration, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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.hadoop.HadoopPlatform
 
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
 
getCurrentIdentifier(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.PartitionTap
 
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.
getCurrentTapSourcePath(JobConf) - Static method in class cascading.tap.hadoop.io.MultiInputSplit
Method getCurrentTapSourcePath finds and returns the current source Tap filename path, if any.
getDefaultComparator(Comparator, Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization
 
getDefaultComparator(Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization
 
getDefaultComparator() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getDefaultConfig() - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getDefaultFileSystem(Configuration) - Method in class cascading.tap.hadoop.Dfs
 
getDefaultFileSystem(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
getDefaultFileSystemURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs
Method getDefaultFileSystemURIScheme returns the URI scheme for the default Hadoop FileSystem.
getDefaultFS(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getDefaultIntermediateSchemeClass() - Method in class cascading.flow.hadoop.HadoopFlowConnector
 
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
 
getDelimiter() - Method in class cascading.scheme.hadoop.TextDelimited
Method getDelimiter returns the delimiter used to parse fields from the current line of text.
getDeserializer(Class<BigDecimal>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization
 
getDeserializer(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
getDeserializer(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
Method getDeserializer implements Serialization.getDeserializer(Class).
getDiagnostics() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getElementReader() - Method in class cascading.tuple.hadoop.TupleSerialization
Method getElementReader returns the elementReader of this TupleSerialization object.
getElementWriter() - Method in class cascading.tuple.hadoop.TupleSerialization
Method getElementWriter returns the elementWriter of this TupleSerialization object.
getEventId() - Method in class cascading.stats.hadoop.HadoopSliceStats.HadoopAttempt
 
getFieldComparatorsFrom(Configuration, String) - Static method in class cascading.tuple.hadoop.util.DeserializerComparator
 
getFields(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getFields(Configuration, String) - Static method in class cascading.tuple.hadoop.TupleSerialization
 
getFileStatus(Path) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
getFileSystem(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
getFileSystem(Configuration) - Method in class cascading.tap.hadoop.Lfs
 
getFirstOrdinal() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getFlowConnector(Map<Object, Object>) - Method in class cascading.platform.hadoop.HadoopPlatform
 
getFlowProcess() - Method in class cascading.flow.hadoop.HadoopFlow
 
getFlowProcess() - Method in class cascading.platform.hadoop.HadoopPlatform
 
getFlowStepFactory() - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getFullIdentifier(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
getGrouping() - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getGrouping() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
 
getGroupNames(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
 
getHadoopSerializations() - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
getHadoopTupleInputStream(BufferedInputStream, TupleSerialization.SerializationElementReader) - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
getHDFSShutdownHook() - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getHiddenTemporaryPath() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getID() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getIdentifier() - Method in class cascading.tap.hadoop.GlobHfs
 
getIdentifier() - Method in class cascading.tap.hadoop.Hfs
 
getIgnoreTypes() - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
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
 
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.
getJobConfs(Configuration, List<Map<String, String>>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getJobPollingInterval(JobConf) - Static method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
getJobStatusClient() - Method in class cascading.stats.hadoop.HadoopNodeCounterCache
 
getKeyFields() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getKeyFieldsMap() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getKeyTypeMap() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getKeyTypes() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getKind() - Method in class cascading.stats.hadoop.HadoopNodeStats
 
getKind() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getLength() - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
getLength() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
getLocalCacheFiles(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.BaseDistCacheTap
 
getLocalCacheFiles(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.DistCacheTap
 
getLocalFS(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getLocalModeScheme(Configuration, String) - Static method in class cascading.tap.hadoop.Hfs
 
getLocalModeScheme() - Method in class cascading.tap.hadoop.HfsProps
 
getLocations() - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
getLongComparator(boolean) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
getMapProgress() - Method in class cascading.stats.hadoop.HadoopStepStats
Returns the underlying Map tasks progress percentage.
getMaskedValueFields() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getMaskedValueTypeMap() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getMaxNumParallelSteps() - Method in class cascading.flow.hadoop.HadoopFlow
 
getMD5SumFor(Configuration, Path) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
getMD5SumFor(Configuration, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
getModifiedTime(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
getNextElement() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
getNumElements() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
getNumMapTasks(Map<Object, Object>) - Method in class cascading.platform.hadoop.HadoopPlatform
 
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.hadoop.HadoopPlatform
 
getNumReduceTasks() - Method in class cascading.stats.hadoop.HadoopStepStats
Method getNumReduceTasks returns the numReducerTasks from the Hadoop job file.
getOrdinals() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getOutput() - Method in class cascading.flow.hadoop.stream.element.HadoopSinkStage
 
getOutputCollector() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getOutputCollector() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
getOutputPath(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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
 
getPath() - Method in class cascading.tap.hadoop.Hfs
 
getPlannerInfo(String) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getPlatformInfo() - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getPlatformInfo() - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getPlatformInfo(Class, String, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
getPos() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
getPos() - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
getPos() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
getPosition() - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
getPreventBitWiseComparisons() - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
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
 
getProcessStepID() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getProcessStepID() - Method in class cascading.stats.hadoop.HadoopStepStats
Method getProcessStepID returns the Hadoop running job JobID.
getProgress() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
getProgress() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
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
 
getQuote() - Method in class cascading.scheme.hadoop.TextDelimited
Method getQuote returns the quote string, if any, used to encapsulate each field in a line to delimited text.
getReadersFor(TupleInputStream.ElementReader, Class[]) - Static method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
getRecordReader(InputSplit, JobConf, Reporter) - Method in class cascading.tap.hadoop.io.MultiInputFormat
Method getRecordReader delegates to the appropriate InputFormat.
getRecordReader() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
getReduceProgress() - Method in class cascading.stats.hadoop.HadoopStepStats
Returns the underlying Reduce tasks progress percentage.
getReplication(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
Method getReplication returns the replication specified by the underlying file system for this resource.
getReplication(Configuration) - Method in class cascading.tap.hadoop.Hfs
Method getReplication returns the replication specified by the underlying file system for this resource.
getReporter() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
getReporter() - Method in interface cascading.flow.hadoop.MapRed
 
getRequireTypes() - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
getSchemeClass() - Method in class cascading.tap.hadoop.util.TempHfs
 
getSerializationTokens(Map<Object, Object>) - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Returns the serialization tokens property.
getSerializationTokens() - Method in class cascading.tuple.hadoop.TupleSerializationProps
 
getSerializer(Class<BigDecimal>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization
 
getSerializer(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization
 
getSerializer(Class) - Method in class cascading.tuple.hadoop.TupleSerialization
Method getSerializer implements Serialization.getSerializer(Class).
getSinkCompression() - Method in class cascading.scheme.hadoop.TextLine
Method getSinkCompression returns the sinkCompression of this TextLine object.
getSize(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
 
getSize(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
getSortFields() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getSortFieldsMap() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getSortTypes() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getSpillStrategy() - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
Method getSpillStrategy returns a SpillStrategy instance that is passed to the underlying Spillable tuple collection.
getSplits(JobConf, int) - Method in class cascading.tap.hadoop.io.MultiInputFormat
Method getSplits delegates to the appropriate InputFormat.
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
 
getTaps() - Method in class cascading.tap.hadoop.GlobHfs
 
getTaskIDNum() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getTaskReport() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
getTemporaryDirectory() - Method in class cascading.tap.hadoop.HfsProps
 
getTempPath(Configuration) - Static method in class cascading.tap.hadoop.Hfs
 
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
 
getTupleSerialization() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
getTupleSerialization() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
getTypesFor(int) - Method in class cascading.tuple.hadoop.io.IndexTupleDeserializer
 
getTypesFor(int) - Method in class cascading.tuple.hadoop.io.IndexTupleSerializer
 
getTypesFor(int) - Method in class cascading.tuple.hadoop.io.KeyIndexTupleDeserializer
 
getTypesFor(int) - Method in class cascading.tuple.hadoop.io.ValueIndexTupleDeserializer
 
getTypesFor(Fields) - Method in class cascading.tuple.hadoop.TupleSerialization
 
getUri() - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
getURIScheme(Tap) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
getURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
getUseCombinedInput(Configuration) - Static method in class cascading.tap.hadoop.Hfs
 
getValueFields() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getValueFieldsMap() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getValueIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
getValueTypeMap() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getValueTypes() - Method in class cascading.tuple.hadoop.TupleSerialization
 
getWorkingDirectory() - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
getWrappedInputSplit() - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
getWritersFor(TupleOutputStream.ElementWriter, Class[]) - Static method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream
 
GlobHfs - Class in cascading.tap.hadoop
Class GlobHfs is a type of MultiSourceTap that accepts Hadoop style 'file globing' expressions so multiple files that match the given pattern may be used as the input sources for a given Flow.
GlobHfs(Scheme<Configuration, RecordReader, ?, ?, ?>, String) - Constructor for class cascading.tap.hadoop.GlobHfs
Constructor GlobHfs creates a new GlobHfs instance.
GlobHfs(Scheme<Configuration, RecordReader, ?, ?, ?>, String, PathFilter) - Constructor for class cascading.tap.hadoop.GlobHfs
Constructor GlobHfs creates a new GlobHfs instance.
globStatus(Path, PathFilter) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
 
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

Hadoop18TapUtil - Class in cascading.tap.hadoop.util
 
Hadoop18TapUtil() - Constructor for class cascading.tap.hadoop.util.Hadoop18TapUtil
 
HADOOP_IO_SERIALIZATIONS - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
 
HadoopCoGroupClosure - Class in cascading.flow.hadoop
Class CoGroupClosure is used internally to represent co-grouping results of multiple tuple streams.
HadoopCoGroupClosure(FlowProcess, int, Fields[], Fields[]) - Constructor for class cascading.flow.hadoop.HadoopCoGroupClosure
 
HadoopCoGroupClosure.Spill - Enum in cascading.flow.hadoop
 
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
 
HadoopFlowConnector - Class in cascading.flow.hadoop
Use the HadoopFlowConnector to link source and sink Tap instances with an assembly of Pipe instances into an executable HadoopFlow for execution on an Apache Hadoop cluster.
HadoopFlowConnector() - Constructor for class cascading.flow.hadoop.HadoopFlowConnector
Constructor HadoopFlowConnector creates a new HadoopFlowConnector instance.
HadoopFlowConnector(Map<Object, Object>) - Constructor for class cascading.flow.hadoop.HadoopFlowConnector
Constructor HadoopFlowConnector creates a new HadoopFlowConnector instance using the given Properties instance as default value for the underlying jobs.
HadoopFlowConnector(RuleRegistrySet) - Constructor for class cascading.flow.hadoop.HadoopFlowConnector
Constructor HadoopFlowConnector creates a new HadoopFlowConnector instance.
HadoopFlowConnector(Map<Object, Object>, RuleRegistrySet) - Constructor for class cascading.flow.hadoop.HadoopFlowConnector
Constructor HadoopFlowConnector creates a new HadoopFlowConnector instance using the given Properties instance as default value for the underlying jobs.
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(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
 
HadoopPlatform - Class in cascading.platform.hadoop
Class HadoopPlatform is automatically loaded and injected into a PlatformTestCase instance so that all *PlatformTest classes can be tested against Apache Hadoop.
HadoopPlatform() - Constructor for class cascading.platform.hadoop.HadoopPlatform
 
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
 
HadoopSpillableTupleList - Class in cascading.tuple.hadoop.collect
SpillableTupleList is a simple Iterable object that can store an unlimited number of Tuple instances by spilling excess to a temporary disk file.
HadoopSpillableTupleList(int, CompressionCodec, Configuration) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
Constructor SpillableTupleList creates a new SpillableTupleList instance using the given threshold value, and the first available compression codec, if any.
HadoopSpillableTupleList(int, TupleSerialization, CompressionCodec) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleList
 
HadoopSpillableTupleMap - Class in cascading.tuple.hadoop.collect
HadoopSpillableTupleMap is responsible for spilling values to disk if the map threshold is reached.
HadoopSpillableTupleMap(int, float, int, int, FlowProcess<? extends Configuration>) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap
 
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
 
HadoopTupleCollectionFactory - Class in cascading.tuple.hadoop.collect
 
HadoopTupleCollectionFactory() - Constructor for class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
 
HadoopTupleEntrySchemeCollector - Class in cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeCollector is a kind of TupleEntryCollector that writes tuples to the resource managed by a particular Tap instance.
HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
 
HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, OutputCollector) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
 
HadoopTupleEntrySchemeIterator - Class in cascading.tap.hadoop.io
 
HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, Tap, RecordReader) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
 
HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, Scheme, CloseableIterator<RecordReader>) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
 
HadoopTupleInputStream - Class in cascading.tuple.hadoop.io
 
HadoopTupleInputStream(InputStream, TupleInputStream.ElementReader) - Constructor for class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
HadoopTupleMapFactory - Class in cascading.tuple.hadoop.collect
 
HadoopTupleMapFactory() - Constructor for class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
 
HadoopTupleOutputStream - Class in cascading.tuple.hadoop.io
 
HadoopTupleOutputStream(OutputStream, TupleOutputStream.ElementWriter) - Constructor for class cascading.tuple.hadoop.io.HadoopTupleOutputStream
 
HadoopUtil - Class in cascading.flow.hadoop.util
 
HadoopUtil() - Constructor for class cascading.flow.hadoop.util.HadoopUtil
 
hashCode() - Method in class cascading.flow.hadoop.util.LazyCollection
 
hashCode() - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
hashCode() - Method in class cascading.tap.hadoop.GlobHfs
 
hashCode(byte[]) - Method in class cascading.tuple.hadoop.util.BytesComparator
 
HASHER_PARTITIONER_USE_LEGACY_HASH - Static variable in class cascading.tuple.hadoop.util.HasherPartitioner
 
HasherPartitioner - Class in cascading.tuple.hadoop.util
Super class of all Hadoop partitioners.
HasherPartitioner() - Constructor for class cascading.tuple.hadoop.util.HasherPartitioner
 
hasNext() - Method in class cascading.flow.hadoop.util.TimedIterator
 
hasNext() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
 
hasNext() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
Method hasNext returns true if there more Tuple instances available.
hasReducer(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopMRUtil
 
Hfs - Class in cascading.tap.hadoop
Class Hfs is the base class for all Hadoop file system access.
Hfs() - Constructor for class cascading.tap.hadoop.Hfs
 
Hfs(Scheme<Configuration, RecordReader, OutputCollector, ?, ?>) - Constructor for class cascading.tap.hadoop.Hfs
 
Hfs(Scheme<Configuration, RecordReader, OutputCollector, ?, ?>, String) - Constructor for class cascading.tap.hadoop.Hfs
Constructor Hfs creates a new Hfs instance.
Hfs(Scheme<Configuration, RecordReader, OutputCollector, ?, ?>, String, SinkMode) - Constructor for class cascading.tap.hadoop.Hfs
Constructor Hfs creates a new Hfs instance.
HfsProps - Class in cascading.tap.hadoop
Class HfsProps is a fluent helper for setting various Hadoop FS level properties that some Flow may or may not be required to have set.
HfsProps() - Constructor for class cascading.tap.hadoop.HfsProps
 
hfsProps() - Static method in class cascading.tap.hadoop.HfsProps
Creates a new HfsProps instance.
HTTP_SCHEME - Static variable in class cascading.tap.hadoop.io.HttpFileSystem
Field HTTP_SCHEME
HttpFileSystem - Class in cascading.tap.hadoop.io
Class HttpFileSystem provides a basic read-only FileSystem for accessing remote HTTP and HTTPS data.
HttpFileSystem() - Constructor for class cascading.tap.hadoop.io.HttpFileSystem
 
HTTPS_SCHEME - Static variable in class cascading.tap.hadoop.io.HttpFileSystem
Field HTTPS_SCHEME

I

IGNORE_TYPES - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
 
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
 
IndexTupleDeserializer<T extends IndexTuple> - Class in cascading.tuple.hadoop.io
 
IndexTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.IndexTupleDeserializer
 
IndexTupleSerializer<T extends IndexTuple> - Class in cascading.tuple.hadoop.io
 
IndexTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.IndexTupleSerializer
 
INDIVIDUAL_INPUT_FORMAT - Static variable in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
property that indicates how individual input format is to be interpreted
initConfig(Map<Object, Object>, 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
 
initialize(URI, Configuration) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
initialize() - Method in class cascading.tap.hadoop.io.TapOutputCollector
 
initialize(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
 
initialize(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory
 
initializeFrom(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
initLists() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
initLog4j(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
initLog4j(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
instantiateSerializer(Configuration, Class<T>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
internalBlockOnStop() - Method in class cascading.flow.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
 
isDirectory(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs
 
isDirectory(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
isEmpty(int) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
isEmpty(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
isEmpty() - Method in class cascading.flow.hadoop.util.FalseCollection
 
isEmpty() - Method in class cascading.flow.hadoop.util.LazyCollection
 
isHadoopLocalMode(JobConf) - Method in class cascading.flow.hadoop.HadoopFlowStep
 
isHDFSAvailable() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
isInflow(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
isLocal(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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
 
isSymmetrical() - Method in class cascading.scheme.hadoop.TextDelimited
 
isTemporary() - Method in class cascading.tap.hadoop.util.TempHfs
 
isUseCombinedInput() - Method in class cascading.tap.hadoop.HfsProps
 
isUseCombinedInputSafeMode() - Method in class cascading.tap.hadoop.HfsProps
 
isYARN(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
iterator() - Method in class cascading.flow.hadoop.util.FalseCollection
 
iterator() - Method in class cascading.flow.hadoop.util.LazyCollection
 
iterators(TimedIterator<V>...) - Static method in class cascading.flow.hadoop.util.TimedIterator
 

J

JavaObjectSerializer - Class in cascading.flow.hadoop.util
Class JavaObjectSerializer is the default implementation of ObjectSerializer.
JavaObjectSerializer() - Constructor for class cascading.flow.hadoop.util.JavaObjectSerializer
 
jobClient - Variable in class cascading.flow.hadoop.planner.HadoopFlowStepJob
Field jobClient

K

keepAlive() - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
KeyIndexTupleDeserializer - Class in cascading.tuple.hadoop.io
 
KeyIndexTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.KeyIndexTupleDeserializer
 
KeyIndexTupleSerializer - Class in cascading.tuple.hadoop.io
 
KeyIndexTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.KeyIndexTupleSerializer
 
KeyTupleDeserializer - Class in cascading.tuple.hadoop.io
 
KeyTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.KeyTupleDeserializer
 
KeyTupleSerializer - Class in cascading.tuple.hadoop.io
 
KeyTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.KeyTupleSerializer
 
keyType - Variable in class cascading.scheme.hadoop.WritableSequenceFile
 
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
 
Lfs - Class in cascading.tap.hadoop
Class Lfs is a Tap class that provides access to the Local File System via Hadoop.
Lfs(Scheme, String) - Constructor for class cascading.tap.hadoop.Lfs
Constructor Lfs creates a new Lfs instance.
Lfs(Scheme, String, SinkMode) - Constructor for class cascading.tap.hadoop.Lfs
Constructor Lfs creates a new Lfs instance.
lhsBuffer - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
lhsStream - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
listStatus(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
LOCAL_MODE_SCHEME - Static variable in class cascading.tap.hadoop.HfsProps
Fields LOCAL_MODE_SCHEME *
localModeScheme - Variable in class cascading.tap.hadoop.HfsProps
 
logger - Variable in class cascading.platform.hadoop.BaseHadoopPlatform
 

M

makeEncodedString(Object[]) - Method in class cascading.scheme.hadoop.TextLine
 
makeIterator(int, Iterator) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
makeNameFromPath(Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.MapReduceFlow
 
makeStepGraph(JobConf) - Method in class cascading.flow.hadoop.MapReduceFlow
 
makeTemporaryPathDirString(String) - Method in class cascading.tap.hadoop.Hfs
 
makeTempPath(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
 
makeTempTap(String, String) - Method in class cascading.flow.hadoop.planner.HadoopPlanner
 
makeURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
MalformedJoinExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph
 
MalformedJoinExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.MalformedJoinExpressionGraph
 
MapRed - Interface in cascading.flow.hadoop
A helper interface to allow a mapred.* package implementation instances to be exposed for internal use.
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(String, String, JobConf, Tap) - Constructor for class cascading.flow.hadoop.MapReduceFlowStep
 
MapReduceFlowStep(String, String, ElementGraph, FlowNodeGraph, JobConf) - Constructor for class cascading.flow.hadoop.MapReduceFlowStep
 
MapReduceHadoopRuleRegistry - Class in cascading.flow.hadoop.planner
 
MapReduceHadoopRuleRegistry() - Constructor for class cascading.flow.hadoop.planner.MapReduceHadoopRuleRegistry
 
MeasuredOutputCollector - Class in cascading.tap.hadoop.util
 
MeasuredOutputCollector(FlowProcess, Enum) - Constructor for class cascading.tap.hadoop.util.MeasuredOutputCollector
 
MeasuredOutputCollector(FlowProcess, Enum, OutputCollector) - Constructor for class cascading.tap.hadoop.util.MeasuredOutputCollector
 
MeasuredRecordReader - Class in cascading.tap.hadoop.util
 
MeasuredRecordReader(FlowProcess, Enum) - Constructor for class cascading.tap.hadoop.util.MeasuredRecordReader
 
MERGE - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitMergeGroupExpression
 
mergeConf(J, Map<String, String>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
mergeMapIntoConfig(JobConf, Map<String, String>) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
mkdirs(Path, FsPermission) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
mr - Static variable in class cascading.platform.hadoop.HadoopPlatform
 
MultiInputFormat - Class in cascading.tap.hadoop.io
Class MultiInputFormat accepts multiple InputFormat class declarations allowing a single MR job to read data from incompatible file types.
MultiInputFormat() - Constructor for class cascading.tap.hadoop.io.MultiInputFormat
 
MultiInputSplit - Class in cascading.tap.hadoop.io
Class MultiInputSplit is used by MultiInputFormat
MultiInputSplit(InputSplit, Map<String, String>) - Constructor for class cascading.tap.hadoop.io.MultiInputSplit
 
MultiInputSplit() - Constructor for class cascading.tap.hadoop.io.MultiInputSplit
This constructor is used internally by Hadoop.
MultiRecordReaderIterator - Class in cascading.tap.hadoop.io
Class TapIterator is an implementation of CloseableIterator.
MultiRecordReaderIterator(FlowProcess<? extends Configuration>, Tap) - Constructor for class cascading.tap.hadoop.io.MultiRecordReaderIterator
Constructor TapIterator creates a new TapIterator instance.
MultiTapGroupNodePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
 
MultiTapGroupNodePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.MultiTapGroupNodePartitioner
 

N

needsTaskCommit(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
 
newConfig(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
 
next(K, V) - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
 
next() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
 
next() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
Method next returns the next Tuple.
next(Object, Object) - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
NoGroupTapExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph
 
NoGroupTapExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.NoGroupTapExpressionGraph
 
numSelfJoins - Variable in class cascading.flow.hadoop.HadoopCoGroupClosure
 

O

OBJECT_SERIALIZER_PROPERTY - Static variable in interface cascading.flow.hadoop.util.ObjectSerializer
 
ObjectSerializer - Interface in cascading.flow.hadoop.util
Class ObjectSerializer is an experimental interface for allowing custom java.lang.Object subclass serialization other than via the java.io.Serializable interface.
open(Path, int) - Method in class cascading.tap.hadoop.io.HttpFileSystem
 
open(InputStream) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer
 
open(OutputStream) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
open(InputStream) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer
 
open(OutputStream) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 
openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.BaseDistCacheTap
 
openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.Hfs
 
openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.PartitionTap
 
openForWrite(FlowProcess<? extends Configuration>, OutputCollector) - Method in class cascading.tap.hadoop.Hfs
 
openSystemIntermediateForWrite() - Method in class cascading.flow.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
 
outgoingScopeFor(Set<Scope>) - Method in class cascading.tap.hadoop.util.TempHfs
 

P

pack(Object, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
PART_TASK_PATTERN - Static variable in class cascading.tap.hadoop.io.TapOutputCollector
 
PART_TASK_SEQ_PATTERN - Static variable in class cascading.tap.hadoop.io.TapOutputCollector
 
PartitionTap - Class in cascading.tap.hadoop
Class PartitionTap can be used to write tuple streams out to files and sub-directories based on the values in the current Tuple instance.
PartitionTap(Hfs, Partition) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, int) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, SinkMode) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, SinkMode, boolean) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
PartitionTap(Hfs, Partition, SinkMode, boolean, int) - Constructor for class cascading.tap.hadoop.PartitionTap
Constructor PartitionTap creates a new PartitionTap instance using the given parent Hfs Tap as the base path and default Scheme, and the partition.
performRawComparison() - Method in class cascading.tuple.hadoop.util.DeserializerComparator
 
PLATFORM_NAME - Static variable in class cascading.flow.hadoop.planner.HadoopPlanner
 
prepare() - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
presentSinkFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
presentSinkFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextLine
 
presentSourceFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
presentSourceFields(FlowProcess<? extends Configuration>, Tap, Fields) - Method in class cascading.scheme.hadoop.TextLine
 
preventBitWiseComparison(boolean) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method preventBitWiseComparison will enable/disable bitwise comparisons of grouping keys during ordered partitioning (GroupBy and CoGroup).
properties - Static variable in class cascading.platform.hadoop.BaseHadoopPlatform
 

R

read() - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
read(byte[], int, int) - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
read(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
read(Class, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
 
readFields(DataInput) - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
readIndexTuple(IndexTuple) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readNullVInt() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readNullVLong() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readStateFromDistCache(JobConf, String, String) - Static method in class cascading.flow.hadoop.util.HadoopMRUtil
 
readString() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readToken() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readType(int) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readType(Class) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readVInt() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
readVLong() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream
 
receive(Duct, TupleEntry) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
RecordReaderIterator - Class in cascading.tap.hadoop.io
RecordReaderIterator is a utility class for handing off a single RecordReader instance via the Iterator.
RecordReaderIterator(RecordReader) - Constructor for class cascading.tap.hadoop.io.RecordReaderIterator
 
reduce(Object, Iterator, OutputCollector, Reporter) - Method in class cascading.flow.hadoop.FlowReducer
 
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
 
remove() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator
 
remove() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator
 
removeAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
removeAll(Collection<?>) - Method in class cascading.flow.hadoop.util.LazyCollection
 
RemoveMalformedHashJoinPipelineTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
RemoveMalformedHashJoinPipelineTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.RemoveMalformedHashJoinPipelineTransformer
 
removePropertiesFrom(Configuration, String...) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
removeStateFromDistCache(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
RemoveStreamedBranchTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
RemoveStreamedBranchTransformer is disabled, enable when GraphFinder supports captured edges.
RemoveStreamedBranchTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.RemoveStreamedBranchTransformer
 
rename(Path, Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
reportLocalError(Throwable) - Static method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
Internal method to report errors that happen on hadoop local mode.
REQUIRE_TYPES - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
 
reset(Tuple, Iterator<Tuple>[]) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
reset(Tuple, Iterator<Tuple>[]) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
reset(Iterator<Tuple>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
reset(Iterator<Tuple>) - Method in class cascading.flow.hadoop.util.LazyCollection
 
reset(V) - Method in interface cascading.flow.hadoop.util.ResettableCollection
 
reset(Iterable<V>) - Method in class cascading.flow.hadoop.util.TimedIterator
 
reset(Iterator<V>) - Method in class cascading.flow.hadoop.util.TimedIterator
 
reset(byte[], int, int) - Method in class cascading.tuple.hadoop.io.BufferedInputStream
 
resetFileStatuses() - Method in class cascading.tap.hadoop.Hfs
Method resetFileStatuses removes the status cache, if any.
ResettableCollection<V> - Interface in cascading.flow.hadoop.util
 
resolvePaths(Configuration, Collection<String>, String, String, Map<String, Path>, Map<String, Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
resourceExists(Configuration) - Method in class cascading.tap.hadoop.Hfs
 
retainAll(Collection<?>) - Method in class cascading.flow.hadoop.util.FalseCollection
 
retainAll(Collection<?>) - Method in class cascading.flow.hadoop.util.LazyCollection
 
retrieveSourceFields(FlowProcess<? extends Configuration>, Tap) - Method in class cascading.scheme.hadoop.TextDelimited
 
ReverseGroupingSortingComparator - Class in cascading.tuple.hadoop.util
Class ReverseTuplePairComparator is an implementation of RawComparator.
ReverseGroupingSortingComparator() - Constructor for class cascading.tuple.hadoop.util.ReverseGroupingSortingComparator
 
ReverseTupleComparator - Class in cascading.tuple.hadoop.util
 
ReverseTupleComparator() - Constructor for class cascading.tuple.hadoop.util.ReverseTupleComparator
 
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 "_".
seek(long) - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
seekToNewSource(long) - Method in class cascading.tap.hadoop.io.FSDigestInputStream
 
SequenceFile - Class in cascading.scheme.hadoop
A SequenceFile is a type of Scheme, which is a flat file consisting of binary key/value pairs.
SequenceFile() - Constructor for class cascading.scheme.hadoop.SequenceFile
Protected for use by TempDfs and other subclasses.
SequenceFile(Fields) - Constructor for class cascading.scheme.hadoop.SequenceFile
Creates a new SequenceFile instance that stores the given field names.
SERIALIZATION_COMPARISON_BITWISE_PREVENT - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
 
SERIALIZATION_TOKENS - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
 
SerializationToken - Annotation Type in cascading.tuple.hadoop
Annotation SerializationToken enables TupleInputStream and TupleOutputStream to substitute Integer values for a class name when writing out nested objects inside a Tuple.
serialize(T, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
serialize(T, boolean) - Method in interface cascading.flow.hadoop.util.ObjectSerializer
 
serialize(BigDecimal) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer
 
serialize(byte[]) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer
 
serialize(T) - Method in class cascading.tuple.hadoop.io.IndexTupleSerializer
 
serialize(TuplePair) - Method in class cascading.tuple.hadoop.io.TuplePairSerializer
 
serialize(Tuple) - Method in class cascading.tuple.hadoop.io.TupleSerializer
 
serializeBase64(T, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
serializeBase64(T, Configuration, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
serializeList(List<T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
serializeMap(Map<String, T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer
 
set(String, String) - Method in class cascading.flow.hadoop.ConfigurationSetter
 
setCharsetName(String) - Method in class cascading.scheme.hadoop.TextLine
 
setCombinedInputMaxSize(Map<Object, Object>, Long) - Static method in class cascading.tap.hadoop.HfsProps
Method setCombinedInputMaxSize sets the maximum input split size to be used.
setCombinedInputMaxSize(long) - Method in class cascading.tap.hadoop.HfsProps
Method setCombinedInputMaxSize sets the maximum input split size to be used.
setConf(Configuration) - Method in class cascading.tuple.hadoop.TupleSerialization
 
setConf(Configuration) - Method in class cascading.tuple.hadoop.util.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
 
setHadoopSerializations(List<String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method setHadoopSerializations sets the Hadoop serialization classNames to be used as properties.
setIgnoreTypes(Boolean) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method setIgnoreTypes forces the TupleSerialization class to ignore any and all declared types causing the serialization to write each type or SerializationToken per Tuple element.
setIsInflow(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
setLastFetch(long) - Method in class cascading.stats.hadoop.HadoopSliceStats
 
setLocal(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
setLocalModeScheme(Map<Object, Object>, String) - Static method in class cascading.tap.hadoop.HfsProps
Method setLocalModeScheme provides a means to change the scheme value used to detect when a MapReduce job should be run in Hadoop local mode.
setLocalModeScheme(String) - Method in class cascading.tap.hadoop.HfsProps
Method setLocalModeScheme provides a means to change the scheme value used to detect when a MapReduce job should be run in Hadoop local mode.
setMD5SumFor(Configuration, Path, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
setMD5SumFor(Configuration, String, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem
 
setNewApi(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
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.hadoop.HadoopPlatform
 
setNumReducers(int) - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
setNumReduceTasks(Map<Object, Object>, int) - Method in class cascading.platform.hadoop.HadoopPlatform
 
setOutputCollector(OutputCollector) - Method in class cascading.flow.hadoop.HadoopFlowProcess
 
setOutputCollector(OutputCollector) - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
 
setOutputPath(Configuration, Path) - Static method in class cascading.flow.hadoop.util.HadoopUtil
 
setRecordReader(RecordReader) - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
 
setReporter(Reporter) - Method in class cascading.flow.hadoop.HadoopFlowProcess
Method setReporter sets the reporter of this HadoopFlowProcess object.
setRequireTypes(Boolean) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method setRequireTypes forces TupleSerialization to fail if field types are not declared.
setSerializations(Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization
Adds this class as a Hadoop Serialization class.
setSerializationTokens(Map<Integer, String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps
Method setSerializationTokens sets the given integer tokens and classNames Map as a serialization properties.
setSinkCompression(TextLine.Compress) - Method in class cascading.scheme.hadoop.TextLine
Method setSinkCompression sets the sinkCompression of this TextLine object.
setSinkFields(Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
setSourceFields(Fields) - Method in class cascading.scheme.hadoop.TextDelimited
 
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
 
setStringPath(String) - Method in class cascading.tap.hadoop.Dfs
 
setStringPath(String) - Method in class cascading.tap.hadoop.Hfs
 
setStringPath(String) - Method in class cascading.tap.hadoop.Lfs
 
setTemporaryDirectory(Map<Object, Object>, String) - Static method in class cascading.tap.hadoop.HfsProps
Method setTemporaryDirectory sets the temporary directory on the given properties object.
setTemporaryDirectory(String) - Method in class cascading.tap.hadoop.HfsProps
Method setTemporaryDirectory sets the temporary directory for use on the underlying filesystem.
setUp() - Method in class cascading.platform.hadoop.HadoopPlatform
 
setupJob(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
should only be called if not in a Flow
setupTask(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil
 
setUriScheme(URI) - Method in class cascading.tap.hadoop.Hfs
 
setUseCombinedInput(Map<Object, Object>, Boolean) - Static method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInput provides a means to indicate whether to leverage CombineFileInputFormat for the input format.
setUseCombinedInput(boolean) - Method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInput provides a means to indicate whether to leverage CombineFileInputFormat for the input format.
setUseCombinedInputSafeMode(Map<Object, Object>, Boolean) - Static method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInputSafeMode toggles safe mode when using CombineFileInputFormat.
setUseCombinedInputSafeMode(boolean) - Method in class cascading.tap.hadoop.HfsProps
Method setUseCombinedInputSafeMode toggles safe mode when using CombineFileInputFormat.
setWorkingDirectory(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem
 
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_HASHJOIN - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceHashJoinSameSourceExpression
 
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
 
sink(FlowProcess<? extends Configuration>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.SequenceFile
 
sink(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
 
sink(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextLine
 
sink(FlowProcess<? extends Configuration>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.SequenceFile
 
sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.TextLine
 
sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
sinkConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs
 
sinkPrepare(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
 
sinkPrepare(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextLine
 
size() - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
 
size() - Method in class cascading.flow.hadoop.HadoopGroupByClosure
 
size() - Method in class cascading.flow.hadoop.util.FalseCollection
 
size() - Method in class cascading.flow.hadoop.util.LazyCollection
 
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
 
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited
 
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.WritableSequenceFile
 
sourceCleanup(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
 
sourceCleanup(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
sourceConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.SequenceFile
 
sourceConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.TextLine
 
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.BaseDistCacheTap
 
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.GlobHfs
 
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs
 
sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.PartitionTap
 
sourceConfInitAddInputPath(Configuration, Path) - Method in class cascading.tap.hadoop.Hfs
 
sourceConfInitComplete(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs
 
sourceHandleInput(SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile
 
sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited
 
sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine
 
spillCount() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
 
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
 
StreamedAccumulatedTapsPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
 
StreamedAccumulatedTapsPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedAccumulatedTapsPipelinePartitioner
 
StreamedAccumulatedTapsPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
 
StreamedAccumulatedTapsPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsPipelinePartitionExpression
 
StreamedFileSystem - Class in cascading.tap.hadoop.io
Class StreamedFileSystem is a base class for FileSystem implementations that manage remote resources.
StreamedFileSystem() - Constructor for class cascading.tap.hadoop.io.StreamedFileSystem
 
StreamedOnlySourcesExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph
Captures the source when the pipeline only has a single source and its streamed.
StreamedOnlySourcesExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.StreamedOnlySourcesExpressionGraph
 
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
 
stringPath - Variable in class cascading.tap.hadoop.Hfs
Field stringPath
syncPaths(Configuration, Map<Path, Path>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil
Copies paths from one local path to a remote path.

T

TapBalanceCheckpointTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceCheckpointTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceCheckpointTransformer
 
TapBalanceGroupBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupBlockingHashJoinTransformer
 
TapBalanceGroupGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupGroupTransformer
 
TapBalanceGroupMergeGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupMergeGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupMergeGroupTransformer
 
TapBalanceGroupNonBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupNonBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupNonBlockingHashJoinTransformer
 
TapBalanceGroupSplitJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupSplitJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitJoinTransformer
 
TapBalanceGroupSplitMergeGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupSplitMergeGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitMergeGroupTransformer
 
TapBalanceGroupSplitMergeTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupSplitMergeTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitMergeTransformer
 
TapBalanceGroupSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceGroupSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitTransformer
 
TapBalanceHashJoinBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceHashJoinBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceHashJoinBlockingHashJoinTransformer
 
TapBalanceHashJoinSameSourceTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceHashJoinSameSourceTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceHashJoinSameSourceTransformer
 
TapBalanceNonSafePipeSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceNonSafePipeSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceNonSafePipeSplitTransformer
 
TapBalanceNonSafeSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceNonSafeSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceNonSafeSplitTransformer
 
TapBalanceSameSourceStreamedAccumulatedTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
 
TapBalanceSameSourceStreamedAccumulatedTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceSameSourceStreamedAccumulatedTransformer
 
TapGroupTapPartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
 
TapGroupTapPartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.TapGroupTapPartitionExpression
 
TapGroupTapStepPartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
 
TapGroupTapStepPartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.TapGroupTapStepPartitioner
 
TapOutputCollector - Class in cascading.tap.hadoop.io
 
TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
 
TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, String) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
 
TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, String, long) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector
 
tearDown() - Method in class cascading.platform.hadoop.BaseHadoopPlatform
 
TempHfs - Class in cascading.tap.hadoop.util
Class TempHfs creates a temporary Tap instance for use internally.
TempHfs(Configuration, String, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs
Constructor TempHfs creates a new TempHfs instance.
TempHfs(Configuration, String, Class<? extends Scheme>) - Constructor for class cascading.tap.hadoop.util.TempHfs
Constructor TempDfs creates a new TempDfs instance.
TempHfs(Configuration, String, Class<? extends Scheme>, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs
 
TEMPORARY_DIRECTORY - Static variable in class cascading.tap.hadoop.HfsProps
Field TEMPORARY_DIRECTORY
TEMPORARY_PATH - Static variable in class cascading.tap.hadoop.util.Hadoop18TapUtil
The Hadoop temporary path used to prevent collisions
temporaryDirectory - Variable in class cascading.tap.hadoop.HfsProps
 
TextDelimited - Class in cascading.scheme.hadoop
Class TextDelimited is a sub-class of TextLine.
TextDelimited() - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(TextLine.Compress, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(TextLine.Compress, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.
TextDelimited(TextLine.Compress, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.
TextDelimited(Fields) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance with TAB as the default delimiter.
TextDelimited(Fields, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String, Class[], boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, Class[], boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, String, Class[]) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, boolean, String, Class[], boolean) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, boolean, String, Class[], boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited
Constructor TextDelimited creates a new TextDelimited instance.
TextLine - Class in cascading.scheme.hadoop
A TextLine is a type of Scheme for plain text files.
TextLine() - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance that sources "offset" and "line" fields, and sinks all incoming fields, where "offset" is the byte offset in the input file.
TextLine(int) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance that sources "offset" and "line" fields, and sinks all incoming fields, where "offset" is the byte offset in the input file.
TextLine(TextLine.Compress) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance that sources "offset" and "line" fields, and sinks all incoming fields, where "offset" is the byte offset in the input file.
TextLine(Fields, Fields) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, Fields, String) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, Fields, int) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress, String) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress, int) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields, Fields, TextLine.Compress, int, String) - Constructor for class cascading.scheme.hadoop.TextLine
Constructor TextLine creates a new TextLine instance.
TextLine(Fields) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, String) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine(Fields, int) - Constructor for class cascading.scheme.hadoop.TextLine
Creates a new TextLine instance.
TextLine.Compress - Enum in cascading.scheme.hadoop
 
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(Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.MapReduceFlow
 
toSourceTap(Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.MapReduceFlow
 
toString() - Method in class cascading.stats.hadoop.HadoopSliceStats
 
toString() - Method in class cascading.tap.hadoop.GlobHfs
 
toString() - Method in class cascading.tap.hadoop.util.TempHfs
 
TupleComparator - Class in cascading.tuple.hadoop.util
 
TupleComparator() - Constructor for class cascading.tuple.hadoop.util.TupleComparator
 
TupleDeserializer - Class in cascading.tuple.hadoop.io
 
TupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.TupleDeserializer
 
TupleElementComparator - Class in cascading.tuple.hadoop.util
 
TupleElementComparator() - Constructor for class cascading.tuple.hadoop.util.TupleElementComparator
 
TupleElementComparator(Comparator) - Constructor for class cascading.tuple.hadoop.util.TupleElementComparator
 
TupleElementStreamComparator - Class in cascading.tuple.hadoop.util
 
TupleElementStreamComparator(StreamComparator) - Constructor for class cascading.tuple.hadoop.util.TupleElementStreamComparator
 
TuplePairDeserializer - Class in cascading.tuple.hadoop.io
 
TuplePairDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.TuplePairDeserializer
 
TuplePairSerializer - Class in cascading.tuple.hadoop.io
 
TuplePairSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.TuplePairSerializer
 
TupleSerialization - Class in cascading.tuple.hadoop
Class TupleSerialization is an implementation of Hadoop's Serialization interface.
TupleSerialization() - Constructor for class cascading.tuple.hadoop.TupleSerialization
Constructor TupleSerialization creates a new TupleSerialization instance.
TupleSerialization(FlowProcess<? extends Configuration>) - Constructor for class cascading.tuple.hadoop.TupleSerialization
 
TupleSerialization(Configuration) - Constructor for class cascading.tuple.hadoop.TupleSerialization
Constructor TupleSerialization creates a new TupleSerialization instance.
tupleSerialization - Variable in class cascading.tuple.hadoop.util.DeserializerComparator
 
TupleSerialization.SerializationElementReader - Class in cascading.tuple.hadoop
 
TupleSerialization.SerializationElementReader(TupleSerialization) - Constructor for class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader
Constructor SerializationElementReader creates a new SerializationElementReader instance.
TupleSerialization.SerializationElementWriter - Class in cascading.tuple.hadoop
 
TupleSerialization.SerializationElementWriter(TupleSerialization) - Constructor for class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
TupleSerializationProps - Class in cascading.tuple.hadoop
Class TupleSerializationProps is a fluent interface for building properties to be passed to a FlowConnector before creating new Flow instances.
TupleSerializationProps() - Constructor for class cascading.tuple.hadoop.TupleSerializationProps
 
tupleSerializationProps() - Static method in class cascading.tuple.hadoop.TupleSerializationProps
Creates a new TupleSerializationProps instance.
TupleSerializer - Class in cascading.tuple.hadoop.io
 
TupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.TupleSerializer
 
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
 
typeMap - Variable in class cascading.tuple.hadoop.io.IndexTupleDeserializer
 
typeMap - Variable in class cascading.tuple.hadoop.io.IndexTupleSerializer
 

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
 
updateNodeStatus(FlowNodeStats) - Method in class cascading.flow.hadoop.planner.HadoopFlowStepJob
 
useCombinedInput - Variable in class cascading.tap.hadoop.HfsProps
 

V

validateInput(JobConf) - Method in class cascading.tap.hadoop.io.MultiInputFormat
 
ValueIndexTupleDeserializer - Class in cascading.tuple.hadoop.io
 
ValueIndexTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.ValueIndexTupleDeserializer
 
ValueIndexTupleSerializer - Class in cascading.tuple.hadoop.io
 
ValueIndexTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.ValueIndexTupleSerializer
 
valueOf(String) - Static method in enum cascading.flow.hadoop.HadoopCoGroupClosure.Spill
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum cascading.flow.hadoop.stream.HadoopMemoryJoinGate.Spill
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum cascading.scheme.hadoop.TextLine.Compress
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum cascading.stats.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.scheme.hadoop.TextLine.Compress
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum cascading.stats.hadoop.HadoopSliceStats.Kind
Returns an array containing the constants of this enum type, in the order they are declared.
ValueTupleDeserializer - Class in cascading.tuple.hadoop.io
 
ValueTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.ValueTupleDeserializer
 
ValueTupleSerializer - Class in cascading.tuple.hadoop.io
 
ValueTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.ValueTupleSerializer
 
valueType - Variable in class cascading.scheme.hadoop.WritableSequenceFile
 
verify(Fields) - Method in class cascading.scheme.hadoop.TextLine
 
verifyNoDuplicates(Configuration) - Static method in class cascading.tap.hadoop.Hfs
 

W

waitOnLatch() - Method in class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
 
wrapGroupingAndCollect(Duct, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.element.HadoopCoGroupGate
 
wrapGroupingAndCollect(Duct, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.element.HadoopGroupByGate
 
wrapGroupingAndCollect(Duct, Tuple, Tuple) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
 
wrapInput(RecordReader) - Method in class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
 
wrapOutput(OutputCollector) - Method in class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
 
WRITABLE_TOKEN - Static variable in class cascading.tuple.hadoop.io.HadoopTupleOutputStream
Field WRITABLE_TOKEN
WritableSequenceFile - Class in cascading.scheme.hadoop
Class WritableSequenceFile is a sub-class of SequenceFile that reads and writes values of the given writableType Class, instead of Tuple instances used by default in SequenceFile.
WritableSequenceFile(Fields, Class<? extends Writable>) - Constructor for class cascading.scheme.hadoop.WritableSequenceFile
Constructor WritableSequenceFile creates a new WritableSequenceFile instance.
WritableSequenceFile(Fields, Class<? extends Writable>, Class<? extends Writable>) - Constructor for class cascading.scheme.hadoop.WritableSequenceFile
Constructor WritableSequenceFile creates a new WritableSequenceFile instance.
write(DataOutput) - Method in class cascading.tap.hadoop.io.MultiInputSplit
 
write(DataOutputStream, Object) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
write(DataOutputStream, Class<?>, Object) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter
 
writeHeader(SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited
 
writeIndexTuple(IndexTuple) - Method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream
 
writeIntInternal(int) - Method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream
 
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 Concurrent, Inc. All Rights Reserved.