Interface | Description |
---|---|
AmPluginNode | |
AvailableSlotsCalculator |
Interface for fetching available slots during split calculation
|
DagCredentialSupplier |
A supplier of credentials for Tez dags.
|
HashableInputSplit |
An InputSplit type that has a custom/specific way of producing its serialized content, to be later used as input
of a hash function.
|
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 | 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.
|
NullMROutput | |
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.
|
TezAvailableSlotsCalculator |
Default implementation of AvailableSlotsCalculator which relies on available capacity of the cluster
|
TezConfigurationFactory | |
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.
|
TezTotalOrderPartitioner | |
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 | Description |
---|---|
CompileTimeCounters | |
HiveInputCounters |
Exception | Description |
---|---|
WorkloadManager.NoPoolMappingException |
Copyright © 2023 The Apache Software Foundation. All rights reserved.