Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
Class and Description |
---|
Description
Description.
|
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
A User-defined function (UDF) for use with Hive.
|
Class and Description |
---|
Description
Description.
|
UDF
A User-defined function (UDF) for use with Hive.
|
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.
|
Task
Task implementation.
|
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.
|
TaskRunner
TaskRunner implementation.
|
Class and Description |
---|
AbstractFileMergeOperator
Fast file merge operator for ORC and RCfile.
|
AbstractMapJoinOperator |
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.
|
ExprNodeEvaluator
ExprNodeEvaluator.
|
FetchFormatter
internal-use only
Used in ListSinkOperator for formatting final output
|
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 |
JoinOperator.SkewkeyTableCounter
SkewkeyTableCounter.
|
JoinUtil.JoinResult
Represents the join result between two tables
|
KeyWrapper |
MapJoinOperator
Map side Join operator implementation.
|
MapOperator.Counter
Counter.
|
MapOperator.MapOpCtx |
MapredContext
Runtime context of MapredTask providing additional information to GenericUDF
|
NodeUtils.Function |
ObjectCache
ObjectCache.
|
Operator
Base operator implementation.
|
Operator.OperatorFunc
OperatorFunc.
|
Operator.State
State.
|
PTFPartition |
PTFPartition.PTFPartitionIterator |
PTFRollingPartition |
RecordReader
RecordReader.
|
RecordWriter
RecordWriter.
|
ReduceSinkOperator.Counter
Counters.
|
RowSchema
RowSchema Implementation.
|
ScriptOperator.Counter
Counter.
|
Stat |
Task
Task implementation.
|
Task.FeedType |
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
A User-defined function (UDF) for use with Hive.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
UDFMethodResolver
The UDF Method resolver interface.
|
Utilities.DatePersistenceDelegate
DatePersistenceDelegate.
|
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 |
---|
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.
|
MapredContext
Runtime context of MapredTask providing additional information to GenericUDF
|
ObjectCache
ObjectCache.
|
Operator
Base operator implementation.
|
Task
Task implementation.
|
Class and Description |
---|
AbstractMapJoinOperator |
AppMasterEventOperator
AppMasterEventOperator sends any rows it receives to the Tez AM.
|
CommonJoinOperator
Join operator implementation.
|
FileSinkOperator
File Sink operator implementation.
|
FilterOperator
Filter operator implementation.
|
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.
|
MapOperator
Map operator.
|
Operator
Base operator implementation.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
SMBMapJoinOperator
Sorted Merge Map Join Operator.
|
TerminalOperator
Terminal Operator Base Class.
|
TopNHash.BinaryCollector
For interaction between operator and top-n hash.
|
UDF
A User-defined function (UDF) for use with Hive.
|
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.
|
MapredContext
Runtime context of MapredTask providing additional information to GenericUDF
|
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 |
---|
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 |
---|
Task
Task implementation.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
Task
Task implementation.
|
Class and Description |
---|
FileSinkOperator.RecordWriter
RecordWriter.
|
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 |
---|
Task
Task implementation.
|
Class and Description |
---|
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.
|
ConditionalTask
Conditional Task 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.
|
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).
|
FunctionInfo
FunctionInfo.
|
Operator
Base operator implementation.
|
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 |
---|
GroupByOperator
GroupBy operator implementation.
|
Operator
Base operator implementation.
|
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.
|
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 |
---|
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
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 |
---|
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 |
---|
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.
|
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.
|
Operator
Base operator implementation.
|
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
RowSchema
RowSchema 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 |
---|
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.
|
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.
|
Operator
Base operator implementation.
|
RecordReader
RecordReader.
|
RecordWriter
RecordWriter.
|
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 |
---|
ExprNodeEvaluator
ExprNodeEvaluator.
|
Class and Description |
---|
CommonJoinOperator
Join operator implementation.
|
FilterOperator
Filter operator implementation.
|
Operator
Base operator implementation.
|
Class and Description |
---|
FileSinkOperator
File Sink 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 |
---|
Task
Task implementation.
|
Class and Description |
---|
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
A User-defined function (UDF) for use with Hive.
|
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
|
PTFPartition.PTFPartitionIterator |
UDAF
Deprecated.
Either implement
GenericUDAFResolver2 or extend
AbstractGenericUDAFResolver instead. |
UDAFEvaluator
Interface that encapsulates the evaluation logic of a UDAF.
|
UDF
A User-defined function (UDF) for use with Hive.
|
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
A User-defined function (UDF) for use with Hive.
|
UDFArgumentException
exception class, thrown when udf argument have something wrong.
|
Class and Description |
---|
Task
Task implementation.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.