Package org.apache.hadoop.hive.ql.exec.tez

Interface Summary

Interface	Description
AmPluginNode
KeyValuesAdapter	Key-values interface for the Reader used by ReduceRecordSource
LlapPluginEndpointClient
LlapPluginEndpointClient.UpdateRequestContext
RecordSource
TezProcessor.Hook	This provides the ability to pass things into TezProcessor, which is normally impossible because of how Tez APIs are structured.
WorkloadManagerMxBean	MXbean to expose cache allocator related information through JMX.

Class Summary

Class	Description
AmPluginNode.AmPluginInfo
ColumnarSplitSizeEstimator	Split size estimator for columnar file formats.
CustomPartitionEdge
CustomPartitionVertex
CustomVertexConfiguration
DagUtils	DagUtils.
DagUtils.ValueHashPartitioner
DataInputByteBuffer
DynamicPartitionPruner	DynamicPartitionPruner takes a list of assigned partitions at runtime (split generation) and prunes them using events generated during execution of the dag.
DynamicValueRegistryTez
DynamicValueRegistryTez.RegistryConfTez
GuaranteedTasksAllocator	Implements query resource allocation using guaranteed tasks.
HashTableLoader	HashTableLoader for Tez constructs the hashtable from records read from a broadcast edge.
HivePreWarmProcessor	A simple sleep processor implementation that sleeps for the configured time in milliseconds.
HiveSplitGenerator	This class is used to generate splits inside the AM on the cluster.
HostAffinitySplitLocationProvider	This maps a split (path + offset) to an index based on the number of locations provided.
InterruptibleProcessing
KeyValuesFromKeyValue	Provides a key/values (note the plural values) interface out of a KeyValueReader, needed by ReduceRecordSource when reading input from a key/value source.
KeyValuesFromKeyValues	Provides a key/values interface out of a KeyValuesReader for use by ReduceRecordSource.
KillMoveTriggerActionHandler
KillTriggerActionHandler	Handles only Kill Action.
LlapObjectCache	LlapObjectCache.
LlapObjectSubCache<T>	LlapObjectSubCache.
LlapPluginEndpointClientImpl
MapRecordProcessor	Process input from tez LogicalInput and write output - for a map plan Just pump the records through the query plan.
MapRecordSource	Process input from tez LogicalInput and write output - for a map plan Just pump the records through the query plan.
MapTezProcessor	Subclass that is used to indicate if this is a map or reduce process
MergeFileRecordProcessor	Record processor for fast merging of files.
MergeFileTezProcessor	Tez processor for fast file merging.
ObjectCache	ObjectCache.
PerPoolTriggerValidatorRunnable
RecordProcessor	Process input from tez LogicalInput and write output It has different subclasses for map and reduce processing
ReduceRecordProcessor	Process input from tez LogicalInput and write output - for a map plan Just pump the records through the query plan.
ReduceRecordSource	Process input from tez LogicalInput and write output - for a map plan Just pump the records through the query plan.
ReduceTezProcessor	Subclass that is used to indicate if this is a map or reduce process
SplitGrouper	SplitGrouper is used to combine splits based on head room and locality.
TezContext	TezContext contains additional context only available with Tez
TezJobExecHelper	TezJobExecHelper is a utility to safely call Tez functionality from common code paths.
TezProcessor	Hive processor for Tez that forms the vertices in Tez and processes the data.
TezSessionPoolManager	This class is for managing multiple tez sessions particularly when HiveServer2 is being used to submit queries.
TezSessionState	Holds session state related to Tez
TezSessionState.HiveResources
TezTask	TezTask handles the execution of TezWork.
TriggerValidatorRunnable
Utils
WmEvent	Workload Manager events at query level.
WmEvent.WmTezSessionInfo
WmPoolMetrics	A wrapper for metrics for single WM pool.
WmTezSession
WorkloadManager	Workload management entry point for HS2.
WorkloadManagerFederation
YarnQueueHelper

Enum Summary

Enum	Description
HiveInputCounters

Exception Summary

Exception	Description
WorkloadManager.NoPoolMappingException