- 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
-
- getDiagnostics() - Method in class cascading.stats.hadoop.HadoopSliceStats
-
- getElementGraph() - Method in class cascading.flow.hadoop.MapReduceFlowStep
-
- 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(Configuration) - Method in class cascading.tap.hadoop.Hfs
-
- 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
-
- getFlowNodeGraph() - Method in class cascading.flow.hadoop.MapReduceFlowStep
-
- 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.
- getJobConf() - Method in class cascading.flow.hadoop.MapReduceFlowStep
-
- 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.
- getOrCreateFlowStepGraph() - Method in class cascading.flow.hadoop.MultiMapReduceFlow
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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() - Constructor for class cascading.flow.hadoop.HadoopFlowStep
-
- HadoopFlowStep(String, int) - Constructor for class cascading.flow.hadoop.HadoopFlowStep
-
- HadoopFlowStep(ElementGraph, FlowNodeGraph) - Constructor for class cascading.flow.hadoop.HadoopFlowStep
-
- HadoopFlowStepJob - Class in cascading.flow.hadoop.planner
-
- HadoopFlowStepJob(ClientState, BaseFlowStep<JobConf>, JobConf) - Constructor for class cascading.flow.hadoop.planner.HadoopFlowStepJob
-
- HadoopGroupByClosure - Class in cascading.flow.hadoop
-
Class GroupClosure is used internally to represent groups of tuples during grouping.
- HadoopGroupByClosure(FlowProcess, Fields[], Fields[]) - Constructor for class cascading.flow.hadoop.HadoopGroupByClosure
-
- HadoopGroupByGate - Class in cascading.flow.hadoop.stream.element
-
- HadoopGroupByGate(FlowProcess, GroupBy, IORole) - Constructor for class cascading.flow.hadoop.stream.element.HadoopGroupByGate
-
- HadoopGroupGate - Class in cascading.flow.hadoop.stream
-
- HadoopGroupGate(FlowProcess, Splice, IORole) - Constructor for class cascading.flow.hadoop.stream.HadoopGroupGate
-
- HadoopMapStreamGraph - Class in cascading.flow.hadoop.stream.graph
-
- HadoopMapStreamGraph(HadoopFlowProcess, FlowNode, Tap) - Constructor for class cascading.flow.hadoop.stream.graph.HadoopMapStreamGraph
-
- HadoopMemoryJoinGate - Class in cascading.flow.hadoop.stream
-
- HadoopMemoryJoinGate(FlowProcess<? extends Configuration>, HashJoin) - Constructor for class cascading.flow.hadoop.stream.HadoopMemoryJoinGate
-
- HadoopMemoryJoinGate.Spill - Enum in cascading.flow.hadoop.stream
-
- HadoopMRUtil - Class in cascading.flow.hadoop.util
-
- HadoopMRUtil() - Constructor for class cascading.flow.hadoop.util.HadoopMRUtil
-
- HadoopNodeCounterCache - Class in cascading.stats.hadoop
-
- HadoopNodeCounterCache(FlowNodeStats, Configuration) - Constructor for class cascading.stats.hadoop.HadoopNodeCounterCache
-
- HadoopNodeStats - Class in cascading.stats.hadoop
-
- HadoopNodeStats(HadoopStepStats, Configuration, HadoopSliceStats.Kind, FlowNode, ClientState) - Constructor for class cascading.stats.hadoop.HadoopNodeStats
-
Constructor CascadingStats creates a new CascadingStats instance.
- HadoopPlanner - Class in cascading.flow.hadoop.planner
-
Class HadoopPlanner is the core Hadoop MapReduce planner used by default through a FlowConnector
sub-class.
- HadoopPlanner() - Constructor for class cascading.flow.hadoop.planner.HadoopPlanner
-
- 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
- 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.BaseMapReduceFlow
-
- makeStepGraph(JobConf) - Method in class cascading.flow.hadoop.BaseMapReduceFlow
-
- 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
-
- MAP - Static variable in class cascading.flow.hadoop.MapReduceFlowStep
-
- 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(HadoopFlow, JobConf) - Constructor for class cascading.flow.hadoop.MapReduceFlowStep
-
- MapReduceFlowStep(HadoopFlow, String, JobConf, Tap) - Constructor for class cascading.flow.hadoop.MapReduceFlowStep
-
- MapReduceHadoopRuleRegistry - Class in cascading.flow.hadoop.planner
-
- MapReduceHadoopRuleRegistry() - Constructor for class cascading.flow.hadoop.planner.MapReduceHadoopRuleRegistry
-
- 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.
- MultiMapReduceFlow - Class in cascading.flow.hadoop
-
Class MultiMapReduceFlow is a
HadoopFlow
subclass that supports custom MapReduce jobs
pre-configured via one or more
JobConf
objects.
- MultiMapReduceFlow(String, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow
-
Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.
- MultiMapReduceFlow(Map<Object, Object>, String, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow
-
Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.
- MultiMapReduceFlow(Map<Object, Object>, String, Map<String, String>, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow
-
Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.
- MultiMapReduceFlow(Map<Object, Object>, String, Map<String, String>, boolean, JobConf, JobConf...) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow
-
Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.
- MultiMapReduceFlow(PlatformInfo, Map<Object, Object>, String) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow
-
Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.
- MultiMapReduceFlow(PlatformInfo, Map<Object, Object>, String, Map<String, String>) - Constructor for class cascading.flow.hadoop.MultiMapReduceFlow
-
Constructor MultiMapReduceFlow creates a new MultiMapReduceFlow instance.
- 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
-
- 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
-
- 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
-
- setUseCombinedInputSafeMode(boolean) - Method in class cascading.tap.hadoop.HfsProps
-
- 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_GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitTriangleExpression
-
- SHARED_HASHJOIN_ACCUMULATED - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceSameSourceStreamedAccumulatedExpression
-
- SHARED_HASHJOIN_STREAMED - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceSameSourceStreamedAccumulatedExpression
-
- SHARED_JOIN - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitJoinExpression
-
- SHARED_LHS - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitTriangleExpression
-
- SHARED_RHS - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitTriangleExpression
-
- SHUFFLE - Static variable in class cascading.flow.hadoop.MapReduceFlowStep
-
- 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
-
Deprecated.
- sourceConfInitAddInputPaths(Configuration, Iterable<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
-
- spawnSteps() - Method in class cascading.flow.hadoop.MultiMapReduceFlow
-
- spillCount() - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
-
- start(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
-
- stepsAreLocal() - Method in class cascading.flow.hadoop.HadoopFlow
-
- StreamedAccumulatedTapsExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedAccumulatedTapsExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsExpressionGraph
-
- StreamedAccumulatedTapsHashJoinExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedAccumulatedTapsHashJoinExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsHashJoinExpressionGraph
-
- StreamedAccumulatedTapsHashJoinPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
-
This rule accounts for a Tap marked as both streamed and accumulated, but is streamed in one pipeline and
accumulated in another pipeline.
- StreamedAccumulatedTapsHashJoinPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedAccumulatedTapsHashJoinPipelinePartitioner
-
- StreamedAccumulatedTapsHashJoinPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedAccumulatedTapsHashJoinPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsHashJoinPipelinePartitionExpression
-
- StreamedAccumulatedTapsPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
-
- StreamedAccumulatedTapsPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedAccumulatedTapsPipelinePartitioner
-
- StreamedAccumulatedTapsPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedAccumulatedTapsPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsPipelinePartitionExpression
-
- 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.
- TapBalanceCheckpointTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceCheckpointTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceCheckpointTransformer
-
- TapBalanceGroupBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupBlockingHashJoinTransformer
-
- TapBalanceGroupGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupGroupTransformer
-
- TapBalanceGroupMergeGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupMergeGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupMergeGroupTransformer
-
- TapBalanceGroupNonBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupNonBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupNonBlockingHashJoinTransformer
-
- TapBalanceGroupSplitJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupSplitJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitJoinTransformer
-
- TapBalanceGroupSplitMergeGroupTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupSplitMergeGroupTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitMergeGroupTransformer
-
- TapBalanceGroupSplitMergeTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupSplitMergeTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitMergeTransformer
-
- TapBalanceGroupSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceGroupSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitTransformer
-
- TapBalanceGroupSplitTriangleTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
Captures a split where one side of the split hits a pipe that joins with the pipe on the other side of the split
- TapBalanceGroupSplitTriangleTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceGroupSplitTriangleTransformer
-
- TapBalanceHashJoinBlockingHashJoinTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceHashJoinBlockingHashJoinTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceHashJoinBlockingHashJoinTransformer
-
- TapBalanceHashJoinSameSourceTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceHashJoinSameSourceTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceHashJoinSameSourceTransformer
-
- TapBalanceNonSafePipeSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceNonSafePipeSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceNonSafePipeSplitTransformer
-
- TapBalanceNonSafeSplitTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceNonSafeSplitTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceNonSafeSplitTransformer
-
- TapBalanceSameSourceStreamedAccumulatedTransformer - Class in cascading.flow.hadoop.planner.rule.transformer
-
- TapBalanceSameSourceStreamedAccumulatedTransformer() - Constructor for class cascading.flow.hadoop.planner.rule.transformer.TapBalanceSameSourceStreamedAccumulatedTransformer
-
- TapGroupTapPartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
-
- TapGroupTapPartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.TapGroupTapPartitionExpression
-
- TapGroupTapStepPartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
-
- TapGroupTapStepPartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.TapGroupTapStepPartitioner
-
- 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
-
- testExists(Flow, Hfs) - Method in class cascading.flow.hadoop.FailOnMissingSuccessFlowListener
-
- 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(JobConf, Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.BaseMapReduceFlow
-
- toSourceTap(JobConf, Map<String, Tap>, Path) - Method in class cascading.flow.hadoop.BaseMapReduceFlow
-
- toString() - Method in class cascading.stats.hadoop.HadoopSliceStats
-
- 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
-