- get(String) - Method in class cascading.flow.hadoop.ConfigurationSetter
-
- getAllLocalResources() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
-
- getAttempts() - Method in class cascading.stats.tez.TezSliceStats
-
- 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
-
- 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
-
- getChildren() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
- getChildWith(String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
- 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(Configuration, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- getConfig() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- getConfig() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- getConfigAsProperties() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- getConfigAsProperties() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
-
- getConfigCopy() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- getConfigCopy() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- getConfiguration() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
Method getJobConf returns the jobConf of this HadoopFlowProcess object.
- getContext() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- getCounterGroups() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
Method getCounterGroups returns all of the Hadoop counter groups.
- getCounterGroups() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
-
Method getCounterGroups returns all of the Hadoop counter groups.
- getCounterGroups() - Method in class cascading.stats.hadoop.CounterCache
-
- getCounterGroups() - Method in class cascading.stats.tez.TezSliceStats
-
- getCounterGroupsMatching(String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
Method getCounterGroupsMatching returns all the Hadoop counter groups that match the give regex pattern.
- getCounterGroupsMatching(String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
-
Method getCounterGroupsMatching returns all the Hadoop counter groups that match the give regex pattern.
- getCounterGroupsMatching(String) - Method in class cascading.stats.hadoop.CounterCache
-
- getCounters(JobStatus) - Method in class cascading.stats.hadoop.CounterCache
-
- getCounters() - Method in class cascading.stats.tez.TezSliceStats
-
- getCounters() - Method in class cascading.stats.tez.util.TaskStatus
-
- getCountersFor(String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
Method getCountersFor returns the Hadoop counters for the given group.
- getCountersFor(String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
-
Method getCountersFor returns the Hadoop counters for the given group.
- getCountersFor(Counters, String) - Method in class cascading.stats.hadoop.CounterCache
-
- getCountersFor(String) - Method in class cascading.stats.hadoop.CounterCache
-
- getCountersFor(TezCounters, String) - Method in class cascading.stats.tez.TezCounterCache
-
- getCountersFor(String) - Method in class cascading.stats.tez.TezSliceStats
-
- getCountersFor(Class<? extends Enum>) - Method in class cascading.stats.tez.TezSliceStats
-
- getCounterValue(Enum) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- getCounterValue(String, String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- getCounterValue(Enum) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
Method getCounterValue returns the Hadoop counter value for the given counter enum.
- getCounterValue(String, String) - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
Method getCounterValue returns the Hadoop counter value for the given group and counter name.
- getCounterValue(Enum) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
-
Method getCounterValue returns the Hadoop counter value for the given counter enum.
- getCounterValue(String, String) - Method in class cascading.stats.hadoop.BaseHadoopStepStats
-
Method getCounterValue returns the Hadoop counter value for the given group and counter name.
- getCounterValue(Counters, Enum) - Method in class cascading.stats.hadoop.CounterCache
-
- getCounterValue(Counters, String, String) - Method in class cascading.stats.hadoop.CounterCache
-
- getCounterValue(Enum) - Method in class cascading.stats.hadoop.CounterCache
-
- getCounterValue(String, String) - Method in class cascading.stats.hadoop.CounterCache
-
- getCounterValue(TezCounters, Enum) - Method in class cascading.stats.tez.TezCounterCache
-
- getCounterValue(TezCounters, String, String) - Method in class cascading.stats.tez.TezCounterCache
-
- getCounterValue(Enum) - Method in class cascading.stats.tez.TezSliceStats
-
- getCounterValue(String, String) - Method in class cascading.stats.tez.TezSliceStats
-
- getCurrentIdentifier(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.PartitionTap
-
- getCurrentKey() - Method in class cascading.flow.tez.util.SecondarySortKeyValuesReader
-
- getCurrentSliceNum() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
Method getCurrentTaskNum returns the task number of this task.
- getCurrentTapSourcePath(JobConf) - Static method in class cascading.tap.hadoop.io.MultiInputSplit
-
Method getCurrentTapSourcePath finds and returns the current source Tap filename path, if any.
- getCurrentUser() - Static method in class cascading.flow.tez.util.TezUtil
-
- getCurrentValues() - Method in class cascading.flow.tez.util.SecondarySortKeyValuesReader
-
- getDAGClient() - Method in class cascading.stats.tez.util.TezTimelineClient
-
- getDAGStatus(Set<StatusGetOpts>) - Method in class cascading.stats.tez.util.TezTimelineClient
-
- getDagStatusWithCounters(DAGClient) - Static method in class cascading.stats.tez.util.TezStatsUtil
-
- 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.tez.planner.Hadoop2TezPlanner
-
- 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.tez.Hadoop2TezFlowConnector
-
- getDefaultURIScheme(Tap) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
-
- 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.tez.TezSliceStats
-
- getDiagnostics() - Method in class cascading.stats.tez.util.TaskStatus
-
- getEdgeSinkID(LogicalOutput, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
-
- getEdgeSourceID(LogicalInput, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
-
- 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.
- getEndTime() - Method in class cascading.stats.tez.util.TaskStatus
-
- getEventId() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
-
- getFailedTaskCount() - Method in class cascading.stats.tez.TezNodeStats
-
- getFieldComparatorsFrom(Configuration, String) - Static method in class cascading.tuple.hadoop.util.DeserializerComparator
-
- 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
-
- getFlowProcess() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- getFlowStagingPath() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- getFrameworkClient() - Method in class cascading.stats.tez.util.TezTimelineClient
-
- 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(Counters) - Method in class cascading.stats.hadoop.CounterCache
-
- getGroupNames(TezCounters) - Method in class cascading.stats.tez.TezCounterCache
-
- 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
-
- getHDFSShutdownHook() - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- getID() - Method in class cascading.stats.tez.TezSliceStats
-
- getIdentifier() - Method in class cascading.tap.hadoop.GlobHfs
-
- getIdentifier() - Method in class cascading.tap.hadoop.Hfs
-
- getInputConfiguration(LogicalInput) - Static method in class cascading.flow.tez.util.TezUtil
-
- getIterator(int) - Method in class cascading.flow.hadoop.HadoopCoGroupClosure
-
- getIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
-
- getJobConfs(Configuration, List<Map<String, String>>) - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- getJobPollingInterval(Configuration) - Static method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
-
- getJobStatusClient() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
-
Method getRunningJob returns the Hadoop
RunningJob
managing this Hadoop job.
- getJobStatusClient() - Method in class cascading.stats.hadoop.CounterCache
-
- getJsonObject(JSONArray, int) - Method in class cascading.stats.tez.util.TezTimelineClient
-
- getKilledTaskCount() - Method in class cascading.stats.tez.TezNodeStats
-
- getKind() - Method in class cascading.stats.tez.TezNodeStats
-
- getKind() - Method in class cascading.stats.tez.TezSliceStats
-
- getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.hadoop.BaseHadoopNodeStats
-
- getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.hadoop.BaseHadoopStepStats
-
- getLastSuccessfulCounterFetchTime() - Method in class cascading.stats.tez.TezSliceStats
-
- getLastSuccessfulFetch() - Method in class cascading.stats.hadoop.CounterCache
-
- 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
-
- getMaxNumParallelSteps() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- 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
-
- getNumProcessSlices() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- getOutput() - Method in class cascading.flow.tez.stream.element.TezSinkStage
-
- getOutputCollector() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector
-
- getOutputConfiguration(LogicalOutput) - Static method in class cascading.flow.tez.util.TezUtil
-
- getOutputPath(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- getOutputPath(Configuration) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
-
- getParallelism(FlowNode, JobConf) - Method in class cascading.flow.tez.Hadoop2TezFlowStep
-
- getParent(LazyCollection) - Static method in class cascading.flow.hadoop.util.LazyCollection
-
- getParentStatus() - Method in class cascading.stats.tez.TezSliceStats
-
- getPartition(Object, Object, int) - Method in class cascading.tuple.tez.util.CoGroupingPartitioner
-
- getPartition(Object, Object, int) - Method in class cascading.tuple.tez.util.GroupingSortingPartitioner
-
- getPartition(Object, Object, int) - Method in class cascading.tuple.tez.util.TuplePartitioner
-
- getPath() - Method in class cascading.tap.hadoop.Hfs
-
- getPlannerInfo(String) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
-
- getPlatformInfo() - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- getPlatformInfo(Class, String, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- getPlatformInfo() - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
-
- getPlatformVersion() - Static method in class cascading.stats.tez.util.TezStatsUtil
-
- 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
-
- getProcessAttemptID() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
-
- getProcessDuration() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
-
- getProcessFinishTime() - Method in class cascading.stats.tez.TezSliceStats
-
- getProcessProgress() - Method in class cascading.stats.tez.TezSliceStats
-
- getProcessRunTime() - Method in class cascading.stats.tez.TezSliceStats
-
- getProcessSliceID() - Method in class cascading.stats.tez.TezSliceStats
-
- getProcessStartTime() - Method in class cascading.stats.tez.TezSliceStats
-
- getProcessStatus() - Method in class cascading.stats.tez.TezSliceStats
-
- getProcessStatus() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
-
- getProcessStepID() - Method in class cascading.stats.tez.TezSliceStats
-
- getProgress() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper
-
- getProgress() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader
-
- getProperty(String) - Method in class cascading.flow.tez.Hadoop2TezFlow
-
Method getProperty returns the value associated with the given key from the underlying properties system.
- getProperty(String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- getPropertyKeys() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- 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.
- 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
-
- getRemoveJsonObject(JSONArray, int, boolean) - Method in class cascading.stats.tez.util.TezTimelineClient
-
- 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 interface cascading.flow.hadoop.MapRed
-
- getReporter() - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
Method getReporter returns the reporter of this HadoopFlowProcess object.
- getRunningTaskCount() - Method in class cascading.stats.tez.TezNodeStats
-
- getScheduledTime() - Method in class cascading.stats.tez.util.TaskStatus
-
- 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
-
- 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.
- getStartTime() - Method in class cascading.stats.tez.util.TaskStatus
-
- getStatus() - Method in class cascading.stats.tez.TezSliceStats
-
- getStatus() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
-
- getStatus() - Method in class cascading.stats.tez.util.TaskStatus
-
- getStatusURL() - Method in class cascading.stats.tez.TezSliceStats.TezAttempt
-
- getStreamedHead() - Method in class cascading.flow.tez.stream.graph.Hadoop2TezStreamGraph
-
- getSucceededTaskCount() - Method in class cascading.stats.tez.TezNodeStats
-
- getSuccessfulAttemptID() - Method in class cascading.stats.tez.util.TaskStatus
-
- getTaps() - Method in class cascading.tap.hadoop.GlobHfs
-
- getTaskID() - Method in class cascading.stats.tez.util.TaskStatus
-
- getTemporaryDirectory() - Method in class cascading.tap.hadoop.HfsProps
-
- getTempPath(Configuration) - Static method in class cascading.tap.hadoop.Hfs
-
- getThrowable() - Method in class cascading.flow.tez.planner.Hadoop2TezFlowStepJob
-
- getTotalSliceCPUMilliSeconds() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- getTotalTaskCount() - Method in class cascading.stats.tez.TezNodeStats
-
- getTrackingURL(TezClient, DAGClient) - Static method in class cascading.stats.tez.util.TezStatsUtil
-
- getUri() - Method in class cascading.tap.hadoop.io.HttpFileSystem
-
- getURIScheme(Tap) - Method in class cascading.flow.tez.planner.Hadoop2TezPlanner
-
- getURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs
-
- getUseCombinedInput(Configuration) - Static method in class cascading.tap.hadoop.Hfs
-
- getValueIterator(int) - Method in class cascading.flow.hadoop.HadoopGroupByClosure
-
- getValueIterator(int) - Method in class cascading.flow.tez.TezGroupByClosure
-
- getVertexChild(String) - Method in class cascading.stats.tez.util.TezTimelineClient
-
- getVertexChild(String) - Method in interface cascading.stats.tez.util.TimelineClient
-
- getVertexChildren(String, int, String) - Method in class cascading.stats.tez.util.TezTimelineClient
-
- getVertexChildren(String, int, String) - Method in interface cascading.stats.tez.util.TimelineClient
-
- getVertexID(String) - Method in class cascading.stats.tez.util.TezTimelineClient
-
- getVertexID(String) - Method in interface cascading.stats.tez.util.TimelineClient
-
- getVertexStatus(String, Set<StatusGetOpts>) - Method in class cascading.stats.tez.util.TezTimelineClient
-
- getWorkingDirectory() - Method in class cascading.tap.hadoop.io.StreamedFileSystem
-
- getWrappedInputSplit() - Method in class cascading.tap.hadoop.io.MultiInputSplit
-
- 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
-
- GROUP - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitSpliceExpression
-
- grouping - Variable in class cascading.flow.hadoop.HadoopGroupByClosure
-
- GroupingComparator - Class in cascading.tuple.hadoop.util
-
- GroupingComparator() - Constructor for class cascading.tuple.hadoop.util.GroupingComparator
-
- GroupingSortingComparator - Class in cascading.tuple.hadoop.util
-
- GroupingSortingComparator() - Constructor for class cascading.tuple.hadoop.util.GroupingSortingComparator
-
- GroupingSortingPartitioner - Class in cascading.tuple.tez.util
-
Class GroupingPartitioner is an implementation of
Partitioner
.
- GroupingSortingPartitioner(Configuration) - Constructor for class cascading.tuple.tez.util.GroupingSortingPartitioner
-
- GroupMergeToTapBoundaryExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
-
- GroupMergeToTapBoundaryExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.GroupMergeToTapBoundaryExpressionGraph
-
- GroupTapNodePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
-
- GroupTapNodePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.GroupTapNodePartitioner
-
- GroupTapPartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
-
- GroupTapPartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.GroupTapPartitionExpression
-
- SecondarySortKeyValuesReader - Class in cascading.flow.tez.util
-
- SecondarySortKeyValuesReader(KeyValuesReader, Comparator<Tuple>) - Constructor for class cascading.flow.tez.util.SecondarySortKeyValuesReader
-
- 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_TOKENS - Static variable in class cascading.tuple.hadoop.TupleSerializationProps
-
- SerializationToken - Annotation Type in cascading.tuple.hadoop
-
- 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(IndexTuple) - 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.DeserializerComparator
-
- setConf(Configuration) - Method in class cascading.tuple.hadoop.util.GroupingSortingComparator
-
- setConf(Configuration) - Method in class cascading.tuple.hadoop.util.HasherPartitioner
-
- setConfigProperty(TezConfiguration, Object, Object) - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- setCounters(Map<String, Map<String, Long>>) - Method in class cascading.stats.tez.TezSliceStats
-
- setDiagnostics(String) - Method in class cascading.stats.tez.TezSliceStats
-
- setFinishTime(long) - Method in class cascading.stats.tez.TezSliceStats
-
- 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.
- setIsInflow(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- setLastFetch(long) - Method in class cascading.stats.tez.TezSliceStats
-
- 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
-
- setMRProperties(ProcessorContext, Configuration, boolean) - Static method in class cascading.flow.tez.util.TezUtil
-
- setNewApi(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil
-
- 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
-
- 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
-
- setSourcePathForSplit(MRInput, MRReader, Configuration) - Static method in class cascading.flow.tez.util.TezUtil
-
- setSpillListener(Spillable.SpillListener) - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
-
- setSpillStrategy(Spillable.SpillStrategy) - Method in class cascading.flow.hadoop.util.LazySpillableTupleCollection
-
- setStartTime(long) - Method in class cascading.stats.tez.TezSliceStats
-
- setStatus(String) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- setStatus(CascadingStats.Status) - Method in class cascading.stats.tez.TezSliceStats
-
- 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
-
- setSubmitTime(long) - Method in class cascading.stats.tez.TezSliceStats
-
- setSuccessfulAttemptID(String) - Method in class cascading.stats.tez.TezSliceStats
-
- 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.
- 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
-
- setWriter(Writer) - Method in class cascading.flow.tez.Hadoop2TezFlowProcess
-
- SHARED_GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitExpression
-
- SHARED_GROUP - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitJoinExpression
-
- SHARED_GROUP - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitHashJoinExpression
-
- SHARED_HASHJOIN - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceHashJoinSameSourceExpression
-
- SHARED_HASHJOIN - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceSplitToStreamedHashJoinExpression
-
- SHARED_HASHJOIN_ACCUMULATED - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceSameSourceStreamedAccumulatedExpression
-
- SHARED_HASHJOIN_STREAMED - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceSameSourceStreamedAccumulatedExpression
-
- SHARED_JOIN - Static variable in class cascading.flow.hadoop.planner.rule.expression.BalanceGroupSplitJoinExpression
-
- SHARED_JOIN - Static variable in class cascading.flow.tez.planner.rule.expressiongraph.BalanceJoinSplitExpression
-
- 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
-
- sliceStatsMap - Variable in class cascading.stats.hadoop.BaseHadoopNodeStats
-
- 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
-
- SPLICE - Static variable in class cascading.flow.tez.planner.rule.expression.BalanceGroupSplitSpliceExpression
-
- SplitJoinBoundariesNodeRePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
-
- SplitJoinBoundariesNodeRePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.SplitJoinBoundariesNodeRePartitioner
-
- start(Duct) - Method in class cascading.flow.hadoop.stream.HadoopGroupGate
-
- start(Duct) - Method in class cascading.flow.tez.stream.element.TezBoundaryStage
-
- start(Duct) - Method in class cascading.flow.tez.stream.element.TezMergeGate
-
- STATUS_GET_COUNTERS - Static variable in class cascading.stats.tez.util.TezStatsUtil
-
- stepsAreLocal() - Method in class cascading.flow.tez.Hadoop2TezFlow
-
- StreamedAccumulatedBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
-
- StreamedAccumulatedBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.StreamedAccumulatedBoundariesExpressionGraph
-
- StreamedAccumulatedBoundariesNodeRePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
-
- StreamedAccumulatedBoundariesNodeRePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.StreamedAccumulatedBoundariesNodeRePartitioner
-
- StreamedAccumulatedTapsExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedAccumulatedTapsExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsExpressionGraph
-
- StreamedAccumulatedTapsPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
-
- StreamedAccumulatedTapsPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedAccumulatedTapsPipelinePartitioner
-
- StreamedAccumulatedTapsPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedAccumulatedTapsPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedAccumulatedTapsPipelinePartitionExpression
-
- 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
-
- StreamedOnlySourcesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
-
Captures the source when the pipeline only has a single source and its streamed.
- StreamedOnlySourcesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.StreamedOnlySourcesExpressionGraph
-
- StreamedOnlySourcesNodeRePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
-
- StreamedOnlySourcesNodeRePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.StreamedOnlySourcesNodeRePartitioner
-
- StreamedOnlySourcesPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
-
- StreamedOnlySourcesPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedOnlySourcesPipelinePartitioner
-
- StreamedOnlySourcesPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedOnlySourcesPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedOnlySourcesPipelinePartitionExpression
-
- StreamedSelfJoinSourcesExpressionGraph - Class in cascading.flow.hadoop.planner.rule.expressiongraph
-
Captures the source when the pipeline only has a single source and its streamed.
- StreamedSelfJoinSourcesExpressionGraph() - Constructor for class cascading.flow.hadoop.planner.rule.expressiongraph.StreamedSelfJoinSourcesExpressionGraph
-
- StreamedSelfJoinSourcesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
-
Captures the source when the pipeline only has a single source and its streamed.
- StreamedSelfJoinSourcesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.StreamedSelfJoinSourcesExpressionGraph
-
- StreamedSelfJoinSourcesPipelinePartitioner - Class in cascading.flow.hadoop.planner.rule.partitioner
-
- StreamedSelfJoinSourcesPipelinePartitioner() - Constructor for class cascading.flow.hadoop.planner.rule.partitioner.StreamedSelfJoinSourcesPipelinePartitioner
-
- StreamedSelfJoinSourcesPipelinePartitionExpression - Class in cascading.flow.hadoop.planner.rule.expression
-
- StreamedSelfJoinSourcesPipelinePartitionExpression() - Constructor for class cascading.flow.hadoop.planner.rule.expression.StreamedSelfJoinSourcesPipelinePartitionExpression
-
- stringPath - Variable in class cascading.tap.hadoop.Hfs
-
Field stringPath
- syncArtifacts() - Method in class cascading.flow.tez.Hadoop2TezFlowStep
-
- 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
-
- 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
-
- TaskStatus - Class in cascading.stats.tez.util
-
- TaskStatus(String) - Constructor for class cascading.stats.tez.util.TaskStatus
-
- TaskStatus(String, String, long, long, long, String, Map<String, Map<String, Long>>, String) - Constructor for class cascading.stats.tez.util.TaskStatus
-
- 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
-
- TezBoundaryStage - Class in cascading.flow.tez.stream.element
-
- TezBoundaryStage(FlowProcess, Boundary, IORole, Collection<LogicalOutput>) - Constructor for class cascading.flow.tez.stream.element.TezBoundaryStage
-
- TezBoundaryStage(FlowProcess, Boundary, IORole, LogicalInput) - Constructor for class cascading.flow.tez.stream.element.TezBoundaryStage
-
- TezCoGroupClosure - Class in cascading.flow.tez
-
- TezCoGroupClosure(FlowProcess, int, Fields[], Fields[]) - Constructor for class cascading.flow.tez.TezCoGroupClosure
-
- TezCoGroupGate - Class in cascading.flow.tez.stream.element
-
- TezCoGroupGate(FlowProcess, CoGroup, IORole, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezCoGroupGate
-
- TezCoGroupGate(FlowProcess, CoGroup, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezCoGroupGate
-
- TezCounterCache<JobStatus> - Class in cascading.stats.tez
-
- TezCounterCache(CascadingStats, Configuration) - Constructor for class cascading.stats.tez.TezCounterCache
-
- TezGroupByClosure - Class in cascading.flow.tez
-
- TezGroupByClosure(FlowProcess, Fields[], Fields[]) - Constructor for class cascading.flow.tez.TezGroupByClosure
-
- TezGroupByGate - Class in cascading.flow.tez.stream.element
-
- TezGroupByGate(FlowProcess, GroupBy, IORole, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezGroupByGate
-
- TezGroupByGate(FlowProcess, GroupBy, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezGroupByGate
-
- TezGroupGate - Class in cascading.flow.tez.stream.element
-
- TezGroupGate(FlowProcess, Splice, IORole, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezGroupGate
-
- TezGroupGate(FlowProcess, Splice, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezGroupGate
-
- TezMergeGate - Class in cascading.flow.tez.stream.element
-
- TezMergeGate(FlowProcess, Splice, IORole, Collection<LogicalOutput>) - Constructor for class cascading.flow.tez.stream.element.TezMergeGate
-
- TezMergeGate(FlowProcess, Splice, IORole, SortedListMultiMap<Integer, LogicalInput>) - Constructor for class cascading.flow.tez.stream.element.TezMergeGate
-
- TezNodeStats - Class in cascading.stats.tez
-
- TezNodeStats(TezStepStats, FlowNode, ClientState, Configuration) - Constructor for class cascading.stats.tez.TezNodeStats
-
- TezNodeStats.Kind - Enum in cascading.stats.tez
-
- TezSinkStage - Class in cascading.flow.tez.stream.element
-
- TezSinkStage(FlowProcess, Tap, LogicalOutput) - Constructor for class cascading.flow.tez.stream.element.TezSinkStage
-
- TezSliceStats - Class in cascading.stats.tez
-
- TezSliceStats.TezAttempt - Class in cascading.stats.tez
-
- TezSliceStats.TezAttempt() - Constructor for class cascading.stats.tez.TezSliceStats.TezAttempt
-
- TezSourceStage - Class in cascading.flow.tez.stream.element
-
- TezSourceStage(FlowProcess, Tap, LogicalInput) - Constructor for class cascading.flow.tez.stream.element.TezSourceStage
-
- TezStatsUtil - Class in cascading.stats.tez.util
-
- TezStatsUtil() - Constructor for class cascading.stats.tez.util.TezStatsUtil
-
- TezStepStats - Class in cascading.stats.tez
-
- TezStepStats(FlowStep, ClientState) - Constructor for class cascading.stats.tez.TezStepStats
-
Constructor CascadingStats creates a new CascadingStats instance.
- TezTimelineClient - Class in cascading.stats.tez.util
-
- TezTimelineClient(ApplicationId, String, TezConfiguration, FrameworkClient, DAGClient) - Constructor for class cascading.stats.tez.util.TezTimelineClient
-
- TezUtil - Class in cascading.flow.tez.util
-
- TezUtil() - Constructor for class cascading.flow.tez.util.TezUtil
-
- TimedIterator<V> - Class in cascading.flow.hadoop.util
-
- TimedIterator(FlowProcess, Enum, Enum) - Constructor for class cascading.flow.hadoop.util.TimedIterator
-
- TimedIterator(FlowProcess, Enum, Enum, int) - Constructor for class cascading.flow.hadoop.util.TimedIterator
-
- timedIterators - Variable in class cascading.flow.tez.stream.element.TezCoGroupGate
-
- timedIterators - Variable in class cascading.flow.tez.stream.element.TezGroupByGate
-
- TIMELINE_CLIENT_CLASS - Static variable in class cascading.stats.tez.util.TezStatsUtil
-
- TIMELINE_FETCH_LIMIT - Static variable in class cascading.stats.tez.TezNodeStats
-
Sets the fetch limit from the timeline server.
- TimelineClient - Interface in cascading.stats.tez.util
-
- timeout - Variable in class cascading.stats.hadoop.CounterCache
-
- toArray() - Method in class cascading.flow.hadoop.util.FalseCollection
-
- toArray(T[]) - Method in class cascading.flow.hadoop.util.FalseCollection
-
- toArray() - Method in class cascading.flow.hadoop.util.LazyCollection
-
- toArray(T[]) - Method in class cascading.flow.hadoop.util.LazyCollection
-
- TopDownBoundariesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
-
- TopDownBoundariesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.TopDownBoundariesNodePartitioner
-
- TopDownConsecutiveBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
-
- TopDownConsecutiveBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.TopDownConsecutiveBoundariesExpressionGraph
-
- TopDownSplitBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
-
- TopDownSplitBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.TopDownSplitBoundariesExpressionGraph
-
- TopDownSplitBoundariesNodePartitioner - Class in cascading.flow.tez.planner.rule.partitioner
-
- TopDownSplitBoundariesNodePartitioner() - Constructor for class cascading.flow.tez.planner.rule.partitioner.TopDownSplitBoundariesNodePartitioner
-
- TopDownSplitJoinBoundariesExpressionGraph - Class in cascading.flow.tez.planner.rule.expressiongraph
-
- TopDownSplitJoinBoundariesExpressionGraph() - Constructor for class cascading.flow.tez.planner.rule.expressiongraph.TopDownSplitJoinBoundariesExpressionGraph
-
- toString() - Method in class cascading.stats.tez.TezSliceStats
-
- 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
-
- TuplePartitioner - Class in cascading.tuple.tez.util
-
Class GroupingPartitioner is an implementation of
Partitioner
.
- TuplePartitioner(Configuration) - Constructor for class cascading.tuple.tez.util.TuplePartitioner
-
- TupleSerialization - 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.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
-