- close() - Method in class org.apache.tez.runtime.library.input.OrderedGroupedKVInput
-
- close() - Method in class org.apache.tez.runtime.library.input.UnorderedKVInput
-
- close() - Method in class org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput
-
- close() - Method in class org.apache.tez.runtime.library.output.UnorderedKVOutput
-
- close() - Method in class org.apache.tez.runtime.library.output.UnorderedPartitionedKVOutput
-
- close() - Method in class org.apache.tez.runtime.library.processor.SimpleProcessor
-
- compare(byte[], int, int, byte[], int, int) - Method in class org.apache.tez.runtime.library.common.comparator.TezBytesComparator
-
Compare the buffers in serialized form.
- completedProcessing - Variable in class org.apache.tez.runtime.library.api.KeyValueReader
-
- completedProcessing - Variable in class org.apache.tez.runtime.library.api.KeyValuesReader
-
- computeRouting() - Method in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
- ConcatenatedMergedKeyValueInput - Class in org.apache.tez.runtime.library.input
-
Implements a MergedLogicalInput
that merges the incoming inputs
(e.g.
- ConcatenatedMergedKeyValueInput(MergedInputContext, List<Input>) - Constructor for class org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValueInput
-
- ConcatenatedMergedKeyValuesInput - Class in org.apache.tez.runtime.library.input
-
Implements a MergedLogicalInput
that merges the incoming inputs
(e.g.
- ConcatenatedMergedKeyValuesInput(MergedInputContext, List<Input>) - Constructor for class org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValuesInput
-
- conf - Variable in class org.apache.tez.runtime.library.input.OrderedGroupedKVInput
-
- conf - Variable in class org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput
-
- configureInput() - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
Configure the specific input
- configureInput() - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
Configure the specific input
- configureInput() - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
Configure the specific input
- configureOutput() - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
Configure the specific output
- configureOutput() - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
Configure the specific output
- configureOutput() - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
Configure the specific output
- createConfigBuilder(Configuration) - Static method in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
Create a VertexManagerPluginDescriptor
builder that can be used to
configure the plugin.
- createConfigBuilder(Configuration) - Static method in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
Create a VertexManagerPluginDescriptor
builder that can be used to
configure the plugin.
- createDefaultBroadcastEdgeProperty() - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig
-
This is a convenience method for the typical usage of this edge, and creates an instance of
EdgeProperty
which is likely to be used.
- createDefaultCustomEdgeProperty(EdgeManagerPluginDescriptor) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig
-
This is a convenience method for creating an Edge descriptor based on the specified
EdgeManagerDescriptor.
- createDefaultCustomEdgeProperty(EdgeManagerPluginDescriptor) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig
-
This is a convenience method for creating an Edge descriptor based on the specified
EdgeManagerDescriptor.
- createDefaultCustomEdgeProperty(EdgeManagerPluginDescriptor) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig
-
This is a convenience method for creating an Edge descriptor based on the specified
EdgeManagerDescriptor.
- createDefaultEdgeProperty() - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig
-
This is a convenience method for the typical usage of this edge, and creates an instance of
EdgeProperty
which is likely to be used.
- createDefaultEdgeProperty() - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig
-
This is a convenience method for the typical usage of this edge, and creates an instance of
EdgeProperty
which is likely to be used.
- createDefaultOneToOneEdgeProperty() - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig
-
This is a convenience method for the typical usage of this edge, and creates an instance of
EdgeProperty
which is likely to be used.
- createValuesIterator() - Method in class org.apache.tez.runtime.library.input.OrderedGroupedKVInput
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.SpecificBuilder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.SpecificBuilder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.SpecificBuilder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.SpecificBuilder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
- setAdditionalConfiguration(String, String) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificBuilder
-
- setAdditionalConfiguration(Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificBuilder
-
- setAvailableBufferSize(int) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
- setAvailableBufferSize(int) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificBuilder
-
- setCombiner(String) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setCombiner(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setCombiner(String) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setCombiner(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setCombiner(String) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setCombiner(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setCombiner(String) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setCombiner(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
- setCompression(boolean, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
- setConf(Configuration) - Method in class org.apache.tez.runtime.library.resources.WeightedScalingMemoryDistributor
-
- setConstituentInputIsReady(Input) - Method in class org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValueInput
-
- setConstituentInputIsReady(Input) - Method in class org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValuesInput
-
- setConstituentInputIsReady(Input) - Method in class org.apache.tez.runtime.library.input.OrderedGroupedMergedKVInput
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.SpecificBuilder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.SpecificBuilder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
- setFromConfiguration(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificBuilder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.SpecificBuilder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.SpecificBuilder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
- setFromConfigurationUnfiltered(Configuration) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificBuilder
-
- setKeyComparatorClass(String) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
Set the key comparator class
- setKeyComparatorClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
Set the key comparator class and it's associated configuration.
- setKeyComparatorClass(String) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
Set the key comparator class
- setKeyComparatorClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
Set the key comparator class and it's associated configuration.
- setKeyComparatorClass(String) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
Set the key comparator class
- setKeyComparatorClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
Set the key comparator class and it's associated configuration.
- setKeySerializationClass(String, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
Set serialization class and the relevant comparator to be used for sorting.
- setKeySerializationClass(String, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
Set serialization class and the relevant comparator to be used for sorting.
- setKeySerializationClass(String, String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
Set serialization class and the relevant comparator to be used for sorting.
- setKeySerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for key/value and
the corresponding comparator class to be used as key comparator.
- setKeySerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for key/value and
the corresponding comparator class to be used as key comparator.
- setKeySerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for keys.
- setKeySerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for keys.
- setKeySerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for keys.
- setMaxSingleMemorySegmentFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setMaxSingleMemorySegmentFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setMaxSingleMemorySegmentFraction(float) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setMaxSingleMemorySegmentFraction(float) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.SpecificBuilder
-
- setMemToMemMerger(boolean) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setMemToMemMerger(boolean) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setMergeFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setMergeFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setMergeFraction(float) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setMergeFraction(float) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.SpecificBuilder
-
- setPostMergeBufferFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setPostMergeBufferFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setShuffleBufferFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
- setShuffleBufferFraction(float) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificBuilder
-
- setShuffleBufferFraction(float) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
- setShuffleBufferFraction(float) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.SpecificBuilder
-
- setSortBufferSize(int) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setSortBufferSize(int) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setSorter(OrderedPartitionedKVOutputConfig.SorterImpl) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setSorter(OrderedPartitionedKVOutputConfig.SorterImpl) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setSorterNumThreads(int) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
- setSorterNumThreads(int) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificBuilder
-
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.Builder
-
Serialization class to be used for serializing values.
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVEdgeConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for values.
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for values.
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVEdgeConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for values.
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for values.
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for values.
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVEdgeConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for values.
- setValueSerializationClass(String, Map<String, String>) - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.Builder
-
Set serialization class responsible for providing serializer/deserializer for values.
- shuffle - Variable in class org.apache.tez.runtime.library.input.OrderedGroupedKVInput
-
- ShuffleVertexManager - Class in org.apache.tez.dag.library.vertexmanager
-
Starts scheduling tasks when number of completed source tasks crosses
slowStartMinSrcCompletionFraction
and schedules all tasks
when slowStartMaxSrcCompletionFraction
is reached
- ShuffleVertexManager(VertexManagerPluginContext) - Constructor for class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
- SimpleProcessor - Class in org.apache.tez.runtime.library.processor
-
Implements an AbstractLogicalIOProcessor
and provides empty
implementations of most methods and handles input/output initialization.
- SimpleProcessor(ProcessorContext) - Constructor for class org.apache.tez.runtime.library.processor.SimpleProcessor
-
- sorter - Variable in class org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput
-
- start() - Method in class org.apache.tez.runtime.library.input.OrderedGroupedKVInput
-
- start() - Method in class org.apache.tez.runtime.library.input.UnorderedKVInput
-
- start() - Method in class org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput
-
- start() - Method in class org.apache.tez.runtime.library.output.UnorderedKVOutput
-
- start() - Method in class org.apache.tez.runtime.library.output.UnorderedPartitionedKVOutput
-
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_DESIRED_TASK_INPUT_SIZE - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
The desired size of input per task.
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_DESIRED_TASK_INPUT_SIZE_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_ENABLE_AUTO_PARALLEL - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
Enables automatic parallelism determination for the vertex.
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_ENABLE_AUTO_PARALLEL_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_MAX_SRC_FRACTION - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
In case of a ScatterGather connection, once this fraction of source tasks
have completed, all tasks on the current vertex can be scheduled.
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_MAX_SRC_FRACTION_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_MIN_SRC_FRACTION - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
In case of a ScatterGather connection, the fraction of source tasks which
should complete before tasks for the current vertex are scheduled
- TEZ_FAIR_SHUFFLE_VERTEX_MANAGER_MIN_SRC_FRACTION_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager
-
- TEZ_RUNTIME_CLEANUP_FILES_ON_INTERRUPT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Used only for internal testing.
- TEZ_RUNTIME_CLEANUP_FILES_ON_INTERRUPT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_COMBINE_MIN_SPILLS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_COMBINE_MIN_SPILLS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_COMBINER_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Specifies a combiner class (primarily for Shuffle)
- TEZ_RUNTIME_COMPRESS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_COMPRESS_CODEC - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_CONVERT_USER_PAYLOAD_TO_HISTORY_TEXT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Value: Boolean
Whether to publish configuration information to History logger.
- TEZ_RUNTIME_CONVERT_USER_PAYLOAD_TO_HISTORY_TEXT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_EMPTY_PARTITION_INFO_VIA_EVENTS_ENABLED - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_EMPTY_PARTITION_INFO_VIA_EVENTS_ENABLED_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_ENABLE_FINAL_MERGE_IN_OUTPUT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Expert level setting.
- TEZ_RUNTIME_ENABLE_FINAL_MERGE_IN_OUTPUT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_GROUP_COMPARATOR_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_IFILE_BUFFER_SIZE_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_IFILE_READAHEAD - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Configuration key to enable/disable IFile readahead.
- TEZ_RUNTIME_IFILE_READAHEAD_BYTES - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Configuration key to set the IFile readahead length in bytes.
- TEZ_RUNTIME_IFILE_READAHEAD_BYTES_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_IFILE_READAHEAD_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_INDEX_CACHE_MEMORY_LIMIT_BYTES - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_INDEX_CACHE_MEMORY_LIMIT_BYTES_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_INPUT_BUFFER_PERCENT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_INPUT_POST_MERGE_BUFFER_PERCENT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_INTERNAL_SORTER_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_IO_FILE_BUFFER_SIZE - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
This is copy of io.file.buffer.size from Hadoop, which is used in several places such
as compression codecs, buffer sizes in IFile, while fetching etc.
- TEZ_RUNTIME_IO_SORT_FACTOR - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_IO_SORT_FACTOR_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_IO_SORT_MB - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_IO_SORT_MB_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_KEY_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_KEY_COMPARATOR_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_KEY_SECONDARY_COMPARATOR_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_OPTIMIZE_LOCAL_FETCH - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
If the shuffle input is on the local host bypass the http fetch and access the files directly
- TEZ_RUNTIME_OPTIMIZE_LOCAL_FETCH_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_OPTIMIZE_SHARED_FETCH - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Share data fetched between tasks running on the same host if applicable.
- TEZ_RUNTIME_OPTIMIZE_SHARED_FETCH_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
shared mode bypassing the http fetch is not enabled by default till we have unit tests in.
- TEZ_RUNTIME_PARTITIONER_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Specifies a partitioner class, which is used in Tez Runtime components
like OnFileSortedOutput
- TEZ_RUNTIME_PIPELINED_SHUFFLE_ENABLED - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Expert level setting.
- TEZ_RUNTIME_PIPELINED_SHUFFLE_ENABLED_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_PIPELINED_SORTER_LAZY_ALLOCATE_MEMORY - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Setting this to true would enable sorter
to auto-allocate memory on need basis in progressive fashion.
- TEZ_RUNTIME_PIPELINED_SORTER_LAZY_ALLOCATE_MEMORY_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_PIPELINED_SORTER_MIN_BLOCK_SIZE_IN_MB - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Tries to allocate @link{#TEZ_RUNTIME_IO_SORT_MB} in chunks specified in
this parameter.
- TEZ_RUNTIME_PIPELINED_SORTER_MIN_BLOCK_SIZE_IN_MB_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_PIPELINED_SORTER_SORT_THREADS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_PIPELINED_SORTER_SORT_THREADS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_RECORDS_BEFORE_PROGRESS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_RECORDS_BEFORE_PROGRESS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_REPORT_PARTITION_STATS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Report partition statistics (e.g better scheduling in ShuffleVertexManager).
- TEZ_RUNTIME_REPORT_PARTITION_STATS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_ACCEPTABLE_HOST_FETCH_FAILURE_FRACTION - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_ACCEPTABLE_HOST_FETCH_FAILURE_FRACTION_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_BATCH_WAIT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Expert level setting.
- TEZ_RUNTIME_SHUFFLE_BATCH_WAIT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_BUFFER_SIZE - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_BUFFER_SIZE_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_CONNECT_TIMEOUT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_ENABLE_MEMTOMEM - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_ENABLE_MEMTOMEM_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_ENABLE_SSL - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_ENABLE_SSL_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FAILED_CHECK_SINCE_LAST_COMPLETION - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FAILED_CHECK_SINCE_LAST_COMPLETION_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_BUFFER_PERCENT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_BUFFER_PERCENT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_ENABLE_TESTING_ERRORS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Enables fetch failures by a configuration.
- TEZ_RUNTIME_SHUFFLE_FETCH_ENABLE_TESTING_ERRORS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_FAILURES_LIMIT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_FAILURES_LIMIT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_MAX_TASK_OUTPUT_AT_ONCE - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_MAX_TASK_OUTPUT_AT_ONCE_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_TESTING_ERRORS_CONFIG - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Configures the injectable fetch failures, in a form of:
maphost#mapvertex#probability#comma,separated,features
Possible values are (fetch fails...):
"*#*#50": from all map hosts with 50% likelihood
"_first_#*#80": for the first ever seen map host with 80% likelihood (user doesn't want to use hostnames)
"host1#*#100": from host1 with 100% likelihood (simulates single node failure)
"host1#Map_1#100": from host1 for Map 1 source tasks with 100% likelihood
"host1#Map_1#100#fail_only_first": as above but only for input attempts with index 0
- TEZ_RUNTIME_SHUFFLE_FETCH_TESTING_ERRORS_CONFIG_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCH_VERIFY_DISK_CHECKSUM - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Controls verification of data checksums when fetching data directly to
disk.
- TEZ_RUNTIME_SHUFFLE_FETCH_VERIFY_DISK_CHECKSUM_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCHER_USE_SHARED_POOL - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_FETCHER_USE_SHARED_POOL_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_HOST_PENALTY_TIME_LIMIT_MS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Specifies in milliseconds the maximum delay a penalized host can have before being retried,
defaults to 10 minutes.
- TEZ_RUNTIME_SHUFFLE_HOST_PENALTY_TIME_LIMIT_MS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_KEEP_ALIVE_ENABLED - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_KEEP_ALIVE_ENABLED_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_KEEP_ALIVE_MAX_CONNECTIONS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_KEEP_ALIVE_MAX_CONNECTIONS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MAX_ALLOWED_FAILED_FETCH_ATTEMPT_FRACTION - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MAX_ALLOWED_FAILED_FETCH_ATTEMPT_FRACTION_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MAX_STALL_TIME_FRACTION - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MAX_STALL_TIME_FRACTION_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MEMORY_LIMIT_PERCENT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MEMORY_LIMIT_PERCENT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MEMTOMEM_SEGMENTS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MERGE_PERCENT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MERGE_PERCENT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MIN_FAILURES_PER_HOST - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MIN_FAILURES_PER_HOST_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MIN_REQUIRED_PROGRESS_FRACTION - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_MIN_REQUIRED_PROGRESS_FRACTION_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_NOTIFY_READERROR - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_NOTIFY_READERROR_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_PARALLEL_COPIES - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_PARALLEL_COPIES_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_READ_TIMEOUT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_READ_TIMEOUT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_SOURCE_ATTEMPT_ABORT_LIMIT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_SOURCE_ATTEMPT_ABORT_LIMIT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_STALLED_COPY_TIMEOUT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_USE_ASYNC_HTTP - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SHUFFLE_USE_ASYNC_HTTP_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SORT_SPILL_PERCENT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SORT_SPILL_PERCENT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_SORTER_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
String value.
- TEZ_RUNTIME_SORTER_CLASS_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_TRANSFER_DATA_VIA_EVENTS_ENABLED - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_TRANSFER_DATA_VIA_EVENTS_ENABLED_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_TRANSFER_DATA_VIA_EVENTS_MAX_SIZE - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_TRANSFER_DATA_VIA_EVENTS_MAX_SIZE_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_TRANSFER_DATA_VIA_EVENTS_SUPPORT_IN_MEM_FILE - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_TRANSFER_DATA_VIA_EVENTS_SUPPORT_IN_MEM_FILE_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_UNORDERED_OUTPUT_BUFFER_SIZE_MB - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Size of the buffer to use if not writing directly to disk.
- TEZ_RUNTIME_UNORDERED_OUTPUT_BUFFER_SIZE_MB_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_UNORDERED_OUTPUT_MAX_PER_BUFFER_SIZE_BYTES - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Maximum size for individual buffers used in the UnsortedPartitionedOutput.
- TEZ_RUNTIME_UNORDERED_PARTITIONED_KVWRITER_BUFFER_MERGE_PERCENT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
Integer value.
- TEZ_RUNTIME_UNORDERED_PARTITIONED_KVWRITER_BUFFER_MERGE_PERCENT_DEFAULT - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_RUNTIME_VALUE_CLASS - Static variable in class org.apache.tez.runtime.library.api.TezRuntimeConfiguration
-
- TEZ_SHUFFLE_VERTEX_MANAGER_DESIRED_TASK_INPUT_SIZE - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
The desired size of input per task.
- TEZ_SHUFFLE_VERTEX_MANAGER_DESIRED_TASK_INPUT_SIZE_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
- TEZ_SHUFFLE_VERTEX_MANAGER_ENABLE_AUTO_PARALLEL - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
Enables automatic parallelism determination for the vertex.
- TEZ_SHUFFLE_VERTEX_MANAGER_ENABLE_AUTO_PARALLEL_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
- TEZ_SHUFFLE_VERTEX_MANAGER_MAX_SRC_FRACTION - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
In case of a ScatterGather connection, once this fraction of source tasks
have completed, all tasks on the current vertex can be scheduled.
- TEZ_SHUFFLE_VERTEX_MANAGER_MAX_SRC_FRACTION_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
- TEZ_SHUFFLE_VERTEX_MANAGER_MIN_SRC_FRACTION - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
In case of a ScatterGather connection, the fraction of source tasks which
should complete before tasks for the current vertex are scheduled
- TEZ_SHUFFLE_VERTEX_MANAGER_MIN_SRC_FRACTION_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
- TEZ_SHUFFLE_VERTEX_MANAGER_MIN_TASK_PARALLELISM - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
Automatic parallelism determination will not decrease parallelism below this value
- TEZ_SHUFFLE_VERTEX_MANAGER_MIN_TASK_PARALLELISM_DEFAULT - Static variable in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager
-
- TezBytesComparator - Class in org.apache.tez.runtime.library.common.comparator
-
- TezBytesComparator() - Constructor for class org.apache.tez.runtime.library.common.comparator.TezBytesComparator
-
- TezBytesWritableSerialization - Class in org.apache.tez.runtime.library.common.serializer
-
When using BytesWritable, data is serialized in memory (4 bytes per key and 4 bytes per value)
and written to IFile where it gets serialized again (4 bytes per key and 4 bytes per value).
- TezBytesWritableSerialization() - Constructor for class org.apache.tez.runtime.library.common.serializer.TezBytesWritableSerialization
-
- TezRuntimeConfiguration - Class in org.apache.tez.runtime.library.api
-
Meant for user configurable job properties.
- toUserPayload() - Method in class org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig
-
Get a UserPayload representation of the Configuration
- toUserPayload() - Method in class org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig
-
Get a UserPayload representation of the Configuration
- toUserPayload() - Method in class org.apache.tez.runtime.library.conf.UnorderedKVInputConfig
-
Get a UserPayload representation of the Configuration
- toUserPayload() - Method in class org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig
-
Get a UserPayload representation of the Configuration
- toUserPayload() - Method in class org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig
-
Get a UserPayload representation of the Configuration