Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
Description
Description.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
UDFArgumentTypeException
exception class, thrown when udf arguments have wrong types.
|
Class and Description |
---|
Description
Description.
|
UDAF
Deprecated.
Either implement
GenericUDAFResolver2 or extend
AbstractGenericUDAFResolver instead. |
UDAFEvaluator
Interface that encapsulates the evaluation logic of a UDAF.
|
Class and Description |
---|
Description
Description.
|
UDF
Deprecated.
use
GenericUDF |
Class and Description |
---|
Description
Description.
|
UDF
Deprecated.
use
GenericUDF |
Class and Description |
---|
Description
Description.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
RecordReader
RecordReader.
|
RecordWriter
RecordWriter.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
FetchTask
FetchTask implementation.
|
HashTableLoader
HashTableLoader is an interface used by MapJoinOperator used to load the hashtables
needed to process the join.
|
Task
Task implementation.
|
Task.TaskState
Order of the States here is important as the ordinal values are used
determine the progression of taskState over its lifeCycle which is then
used to make some decisions in Driver.execute
|
TaskResult
TaskResult implementation.
|
TaskRunner
TaskRunner implementation.
|
Class and Description |
---|
AbstractFileMergeOperator
Fast file merge operator for ORC and RCfile.
|
AbstractMapJoinOperator |
AbstractMapOperator
Abstract Map operator.
|
AbstractMapOperator.Counter
Counter.
|
ArchiveUtils.PartSpecInfo
PartSpecInfo keeps fields and values extracted from partial partition info
which is prefix of the full info.
|
BucketMatcher |
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
CommonJoinOperator
Join operator implementation.
|
DefaultUDAFEvaluatorResolver
The default UDAF Method resolver.
|
DummyStoreOperator
For SortMerge joins, this is a dummy operator, which stores the row for the
small table before it reaches the sort merge join operator.
|
DynamicValueRegistry.RegistryConf |
ExprNodeEvaluator
ExprNodeEvaluator.
|
FetchOperator
FetchTask implementation.
|
FileSinkOperator.Counter
Counters.
|
FileSinkOperator.FSPaths |
FileSinkOperator.RecordWriter
RecordWriter.
|
FunctionInfo
FunctionInfo.
|
FunctionInfo.FunctionResource |
FunctionInfo.FunctionType |
FunctionUtils.FunctionType
Function type, for permanent functions.
|
FunctionUtils.UDFClassType
Enum type to describe what kind of UDF implementation class
|
HashTableLoader
HashTableLoader is an interface used by MapJoinOperator used to load the hashtables
needed to process the join.
|
HashTableSinkOperator |
IConfigureJobConf
Enables an operator to be able to make changes to the
JobConf . |
JoinOperator.SkewkeyTableCounter
SkewkeyTableCounter.
|
JoinUtil.JoinResult
Represents the join result between two tables
|
KeyWrapper |
MapJoinOperator
Map side Join operator implementation.
|
MapOperator.MapOpCtx |
MapredContext
Runtime context of MapredTask providing additional information to GenericUDF
|
MemoryMonitorInfo
Contains information required for memory usage monitoring.
|
NodeUtils.Function |
ObjectCache
ObjectCache.
|
Operator
Base operator implementation.
|
Operator.Counter
Counters.
|
Operator.OperatorFunc
OperatorFunc.
|
Operator.State
State.
|
PTFPartition |
PTFPartition.PTFPartitionIterator |
PTFRollingPartition |
RecordReader
RecordReader.
|
RecordWriter
RecordWriter.
|
RowSchema
RowSchema Implementation.
|
ScriptOperator.Counter
Counter.
|
SerializationUtilities.Hook |
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task
Task implementation.
|
Task.FeedType |
Task.TaskState
Order of the States here is important as the ordinal values are used
determine the progression of taskState over its lifeCycle which is then
used to make some decisions in Driver.execute
|
TaskFactory.TaskTuple
taskTuple.
|
TaskHandle
TaskHandle.
|
TaskResult
TaskResult implementation.
|
TerminalOperator
Terminal Operator Base Class.
|
TopNHash
Stores binary key/value in sorted manner to get top-n key/value
TODO: rename to TopNHeap?
|
TopNHash.BinaryCollector
For interaction between operator and top-n hash.
|
UDAF
Deprecated.
Either implement
GenericUDAFResolver2 or extend
AbstractGenericUDAFResolver instead. |
UDAFEvaluator
Interface that encapsulates the evaluation logic of a UDAF.
|
UDAFEvaluatorResolver
The UDF Method resolver interface.
|
UDF
Deprecated.
use
GenericUDF |
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
UDFMethodResolver
Deprecated.
|
Utilities.MissingBucketsContext |
Utilities.ReduceField
ReduceField:
KEY: record key
VALUE: record value
|
Utilities.SQLCommand |
Utilities.StreamStatus
StreamStatus.
|
WindowFunctionInfo |
Class and Description |
---|
FetchOperator
FetchTask implementation.
|
HashTableLoader
HashTableLoader is an interface used by MapJoinOperator used to load the hashtables
needed to process the join.
|
ObjectCache
ObjectCache.
|
Operator
Base operator implementation.
|
Operator.OperatorFunc
OperatorFunc.
|
Task
Task implementation.
|
Class and Description |
---|
ExprNodeEvaluator
ExprNodeEvaluator.
|
FileSinkOperator.RecordWriter
RecordWriter.
|
JoinUtil.JoinResult
Represents the join result between two tables
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
Operator
Base operator implementation.
|
Task
Task implementation.
|
Class and Description |
---|
DummyStoreOperator
For SortMerge joins, this is a dummy operator, which stores the row for the
small table before it reaches the sort merge join operator.
|
DynamicValueRegistry |
DynamicValueRegistry.RegistryConf |
MapredContext
Runtime context of MapredTask providing additional information to GenericUDF
|
ObjectCache
ObjectCache.
|
Operator
Base operator implementation.
|
Task
Task implementation.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
AbstractMapJoinOperator |
AbstractMapOperator
Abstract Map operator.
|
AppMasterEventOperator
AppMasterEventOperator sends any rows it receives to the Tez AM.
|
CommonJoinOperator
Join operator implementation.
|
FileSinkOperator
File Sink operator implementation.
|
FilterOperator
Filter operator implementation.
|
IConfigureJobConf
Enables an operator to be able to make changes to the
JobConf . |
JoinUtil.JoinResult
Represents the join result between two tables
|
KeyWrapper |
LimitOperator
Limit operator implementation Limits the number of rows to be passed on.
|
MapJoinOperator
Map side Join operator implementation.
|
Operator
Base operator implementation.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
SMBMapJoinOperator
Sorted Merge Map Join Operator.
|
SparkHashTableSinkOperator |
TerminalOperator
Terminal Operator Base Class.
|
TopNHash.BinaryCollector
For interaction between operator and top-n hash.
|
UDF
Deprecated.
use
GenericUDF |
Class and Description |
---|
Description
Description.
|
Class and Description |
---|
Description
Description.
|
Class and Description |
---|
AbstractMapJoinOperator |
CommonJoinOperator
Join operator implementation.
|
HashTableLoader
HashTableLoader is an interface used by MapJoinOperator used to load the hashtables
needed to process the join.
|
JoinUtil.JoinResult
Represents the join result between two tables
|
MapJoinOperator
Map side Join operator implementation.
|
Operator
Base operator implementation.
|
Class and Description |
---|
HashTableLoader
HashTableLoader is an interface used by MapJoinOperator used to load the hashtables
needed to process the join.
|
JoinUtil.JoinResult
Represents the join result between two tables
|
MapJoinOperator
Map side Join operator implementation.
|
MapredContext
Runtime context of MapredTask providing additional information to GenericUDF
|
Class and Description |
---|
JoinUtil.JoinResult
Represents the join result between two tables
|
Class and Description |
---|
JoinUtil.JoinResult
Represents the join result between two tables
|
Class and Description |
---|
Operator
Base operator implementation.
|
Class and Description |
---|
Operator
Base operator implementation.
|
TerminalOperator
Terminal Operator Base Class.
|
TopNHash
Stores binary key/value in sorted manner to get top-n key/value
TODO: rename to TopNHeap?
|
TopNHash.BinaryCollector
For interaction between operator and top-n hash.
|
Class and Description |
---|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
TaskRunner
TaskRunner implementation.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
FooterBuffer |
Operator
Base operator implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Class and Description |
---|
AbstractMapJoinOperator |
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
CommonJoinOperator
Join operator implementation.
|
DependencyCollectionTask
DependencyCollectionTask.
|
FileSinkOperator
File Sink operator implementation.
|
FilterOperator
Filter operator implementation.
|
GroupByOperator
GroupBy operator implementation.
|
JoinOperator
Join operator implementation.
|
ListSinkOperator
For fetch task with operator tree, row read from FetchOperator is processed via operator tree
and finally arrives to this operator.
|
MapJoinOperator
Map side Join operator implementation.
|
MemoryMonitorInfo
Contains information required for memory usage monitoring.
|
MoveTask
MoveTask implementation.
|
Operator
Base operator implementation.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
RowSchema
RowSchema Implementation.
|
SelectOperator
Select operator implementation.
|
SMBMapJoinOperator
Sorted Merge Map Join Operator.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task
Task implementation.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
UnionOperator
Union Operator Just forwards.
|
Class and Description |
---|
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
Class and Description |
---|
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
Operator
Base operator implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Class and Description |
---|
GroupByOperator
GroupBy operator implementation.
|
JoinOperator
Join operator implementation.
|
Operator
Base operator implementation.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
SelectOperator
Select operator implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Class and Description |
---|
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
Operator
Base operator implementation.
|
RowSchema
RowSchema Implementation.
|
SelectOperator
Select operator implementation.
|
Class and Description |
---|
FilterOperator
Filter operator implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
SelectOperator
Select operator implementation.
|
Class and Description |
---|
FilterOperator
Filter operator implementation.
|
Operator
Base operator implementation.
|
Class and Description |
---|
ConditionalTask
Conditional Task implementation.
|
GroupByOperator
GroupBy operator implementation.
|
JoinOperator
Join operator implementation.
|
MapJoinOperator
Map side Join operator implementation.
|
Operator
Base operator implementation.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
Task
Task implementation.
|
Class and Description |
---|
ExprNodeEvaluator
ExprNodeEvaluator.
|
FilterOperator
Filter operator implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
Operator
Base operator implementation.
|
Class and Description |
---|
JoinOperator
Join operator implementation.
|
MapJoinOperator
Map side Join operator implementation.
|
Operator
Base operator implementation.
|
SMBMapJoinOperator
Sorted Merge Map Join Operator.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task
Task implementation.
|
Class and Description |
---|
Operator
Base operator implementation.
|
Class and Description |
---|
UnionOperator
Union Operator Just forwards.
|
Class and Description |
---|
AbstractMapJoinOperator |
AppMasterEventOperator
AppMasterEventOperator sends any rows it receives to the Tez AM.
|
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
CommonMergeJoinOperator |
DependencyCollectionTask
DependencyCollectionTask.
|
ExprNodeEvaluator
ExprNodeEvaluator.
|
FetchTask
FetchTask implementation.
|
FileSinkOperator
File Sink operator implementation.
|
FunctionInfo
FunctionInfo.
|
GroupByOperator
GroupBy operator implementation.
|
JoinOperator
Join operator implementation.
|
ListSinkOperator
For fetch task with operator tree, row read from FetchOperator is processed via operator tree
and finally arrives to this operator.
|
MapJoinOperator
Map side Join operator implementation.
|
MaterializedViewDesc |
Operator
Base operator implementation.
|
PTFUtils.Predicate |
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
RowSchema
RowSchema Implementation.
|
SelectOperator
Select operator implementation.
|
SMBMapJoinOperator
Sorted Merge Map Join Operator.
|
StatsTask
StatsTask implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task
Task implementation.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
UnionOperator
Union Operator Just forwards.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
DependencyCollectionTask
DependencyCollectionTask.
|
FileSinkOperator
File Sink operator implementation.
|
MapJoinOperator
Map side Join operator implementation.
|
Operator
Base operator implementation.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
SMBMapJoinOperator
Sorted Merge Map Join Operator.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task
Task implementation.
|
UnionOperator
Union Operator Just forwards.
|
Class and Description |
---|
BucketMatcher |
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
CommonMergeJoinOperator |
DummyStoreOperator
For SortMerge joins, this is a dummy operator, which stores the row for the
small table before it reaches the sort merge join operator.
|
HashTableDummyOperator |
ListSinkOperator
For fetch task with operator tree, row read from FetchOperator is processed via operator tree
and finally arrives to this operator.
|
MapJoinOperator
Map side Join operator implementation.
|
MemoryMonitorInfo
Contains information required for memory usage monitoring.
|
Operator
Base operator implementation.
|
RecordReader
RecordReader.
|
RecordWriter
RecordWriter.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
RowSchema
RowSchema Implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task
Task implementation.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
UnionOperator
Union Operator Just forwards.
|
Class and Description |
---|
Operator
Base operator implementation.
|
Class and Description |
---|
ExprNodeEvaluator
ExprNodeEvaluator.
|
Class and Description |
---|
CommonJoinOperator
Join operator implementation.
|
FilterOperator
Filter operator implementation.
|
Operator
Base operator implementation.
|
Class and Description |
---|
FetchTask
FetchTask implementation.
|
Class and Description |
---|
FunctionInfo
FunctionInfo.
|
Operator
Base operator implementation.
|
Registry |
Class and Description |
---|
ColumnInfo
Implementation for ColumnInfo which contains the internal name for the column
(the one that is used by the operator to access the column) and the type
(identified by a java class).
|
RowSchema
RowSchema Implementation.
|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task
Task implementation.
|
Class and Description |
---|
Description
Description.
|
UDAF
Deprecated.
Either implement
GenericUDAFResolver2 or extend
AbstractGenericUDAFResolver instead. |
UDAFEvaluator
Interface that encapsulates the evaluation logic of a UDAF.
|
UDF
Deprecated.
use
GenericUDF |
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
Description
Description.
|
ExprNodeEvaluator
ExprNodeEvaluator.
|
MapredContext
Runtime context of MapredTask providing additional information to GenericUDF
|
Operator
Base operator implementation.
|
PTFPartition |
PTFPartition.PTFPartitionIterator |
SelectOperator
Select operator implementation.
|
UDAF
Deprecated.
Either implement
GenericUDAFResolver2 or extend
AbstractGenericUDAFResolver instead. |
UDAFEvaluator
Interface that encapsulates the evaluation logic of a UDAF.
|
UDF
Deprecated.
use
GenericUDF |
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
UDFArgumentLengthException
exception class, thrown when udf arguments have wrong length.
|
UDFArgumentTypeException
exception class, thrown when udf arguments have wrong types.
|
UDTFOperator
UDTFOperator.
|
WindowFunctionDescription |
Class and Description |
---|
ExprNodeEvaluator
ExprNodeEvaluator.
|
PTFPartition |
PTFPartition.PTFPartitionIterator |
Class and Description |
---|
Description
Description.
|
UDF
Deprecated.
use
GenericUDF |
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
Description
Description.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.