See: Description
Interface | Description |
---|---|
BucketMatcher | |
DynamicValueRegistry | |
FileSinkOperator.RecordWriter |
RecordWriter.
|
HashTableLoader |
HashTableLoader is an interface used by MapJoinOperator used to load the hashtables
needed to process the join.
|
IConfigureJobConf |
Enables an operator to be able to make changes to the
JobConf . |
NodeUtils.Function<T> | |
ObjectCache |
ObjectCache.
|
Operator.OperatorFunc |
OperatorFunc.
|
PTFPartition.PTFPartitionIterator<T> | |
RecordReader |
RecordReader.
|
RecordWriter |
RecordWriter.
|
TopNHash.BinaryCollector |
For interaction between operator and top-n hash.
|
UDAFEvaluator |
Interface that encapsulates the evaluation logic of a UDAF.
|
UDAFEvaluatorResolver |
The UDF Method resolver interface.
|
UDFMethodResolver | Deprecated |
Class | Description |
---|---|
AbstractFileMergeOperator<T extends FileMergeDesc> |
Fast file merge operator for ORC and RCfile.
|
AbstractMapJoinOperator<T extends MapJoinDesc> | |
AbstractMapOperator |
Abstract Map operator.
|
AppMasterEventOperator |
AppMasterEventOperator sends any rows it receives to the Tez AM.
|
ArchiveUtils |
ArchiveUtils.
|
ArchiveUtils.HarPathHelper |
HarPathHelper helps to create har:/ URIs for locations inside of archive.
|
ArchiveUtils.PartSpecInfo |
PartSpecInfo keeps fields and values extracted from partial partition info
which is prefix of the full info.
|
AutoProgressor |
AutoProgressor periodically sends updates to the job tracker so that it
doesn't consider this task attempt dead if there is a long period of
inactivity.
|
BinaryRecordReader |
Read from a binary stream and treat each 1000 bytes (configurable via
hive.binary.record.max.length) as a record.
|
ByteWritable | Deprecated |
ByteWritable.Comparator |
A Comparator optimized for BytesWritable.
|
CollectOperator |
Buffers rows emitted by other operators.
|
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).
|
ColumnStatsUpdateTask |
ColumnStatsUpdateTask implementation.
|
CommonJoinOperator<T extends JoinDesc> |
Join operator implementation.
|
CommonMergeJoinOperator | |
ComparisonOpMethodResolver |
The class implements the method resolution for operators like (> < <= >= =
<>).
|
ConditionalTask |
Conditional Task implementation.
|
CopyTask |
CopyTask implementation.
|
DagUtils | |
DDLTask |
DDLTask implementation.
|
DefaultBucketMatcher | |
DefaultUDAFEvaluatorResolver |
The default UDAF Method resolver.
|
DefaultUDFMethodResolver |
The default UDF Method resolver.
|
DemuxOperator |
DemuxOperator is an operator used by MapReduce Jobs optimized by
CorrelationOptimizer.
|
DependencyCollectionTask |
DependencyCollectionTask.
|
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 | |
ExplainSQRewriteTask | |
ExplainTask |
ExplainTask implementation.
|
ExportTask | |
ExprNodeColumnEvaluator |
This evaluator gets the column from the row object.
|
ExprNodeConstantEvaluator |
ExprNodeConstantEvaluator.
|
ExprNodeDynamicValueEvaluator |
ExprNodeDynamicEvaluator.
|
ExprNodeEvaluator<T extends ExprNodeDesc> |
ExprNodeEvaluator.
|
ExprNodeEvaluatorFactory |
ExprNodeEvaluatorFactory.
|
ExprNodeEvaluatorHead |
Increases version number of each evaluations for correct caching
|
ExprNodeEvaluatorRef |
Returns evaluation result of other evaluator
|
ExprNodeFieldEvaluator |
This Evaluator can evaluate s.f for s as both struct and list of struct.
|
ExprNodeGenericFuncEvaluator |
ExprNodeGenericFuncEvaluator.
|
FetchOperator |
FetchTask implementation.
|
FetchTask |
FetchTask implementation.
|
FileSinkOperator |
File Sink operator implementation.
|
FilterOperator |
Filter operator implementation.
|
FooterBuffer | |
ForwardOperator |
Forward Operator Just forwards.
|
FunctionInfo |
FunctionInfo.
|
FunctionInfo.FunctionResource | |
FunctionRegistry |
FunctionRegistry.
|
FunctionTask |
FunctionTask.
|
FunctionUtils | |
GlobalWorkMapFactory | |
GroupByOperator |
GroupBy operator implementation.
|
HashTableDummyOperator | |
HashTableSinkOperator | |
HiveTotalOrderPartitioner | |
JoinOperator |
Join operator implementation.
|
JoinUtil | |
KeyWrapper | |
KeyWrapperFactory | |
LateralViewForwardOperator |
LateralViewForwardOperator.
|
LateralViewJoinOperator |
The lateral view join operator is used for FROM src LATERAL VIEW udtf()...
|
LimitOperator |
Limit operator implementation Limits the number of rows to be passed on.
|
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.
|
MapOperator |
Map operator.
|
MapOperator.MapOpCtx | |
MapredContext |
Runtime context of MapredTask providing additional information to GenericUDF
|
MaterializedViewDesc | |
MaterializedViewTask |
This task does some work related to materialized views.
|
MemoryMonitorInfo |
Contains information required for memory usage monitoring.
|
MoveTask |
MoveTask implementation.
|
MuxOperator |
MuxOperator is used in the Reduce side of MapReduce jobs optimized by Correlation Optimizer.
|
MuxOperator.Handler |
Handler is used to construct the key-value structure.
|
NodeUtils |
Simple node iterating utils
|
NumericOpMethodResolver |
The class implements the method resolution for operators like (+, -, *, %).
|
NumericUDAF |
Base class of numeric UDAFs like sum and avg which need a
NumericUDAFEvaluatorResolver.
|
NumericUDAFEvaluatorResolver |
Resolver for Numeric UDAFs like sum and avg.
|
ObjectCacheFactory |
ObjectCacheFactory returns the appropriate cache depending on settings in
the hive conf.
|
ObjectCacheWrapper | |
Operator<T extends OperatorDesc> |
Base operator implementation.
|
OperatorFactory |
OperatorFactory.
|
OperatorUtils | |
OrcFileMergeOperator |
Fast file merge operator for ORC files.
|
PartitionKeySampler | |
PTFOperator | |
PTFPartition | |
PTFRollingPartition | |
PTFTopNHash | |
PTFUtils | |
PTFUtils.Predicate<T> | |
PTFUtils.ReverseIterator<T> | |
RCFileMergeOperator |
Fast file merge operator for RC files.
|
ReduceSinkOperator |
Reduce Sink Operator sends output to the reduce stage.
|
Registry | |
ReplCopyTask | |
ReplTxnTask |
ReplTxnTask.
|
RowSchema |
RowSchema Implementation.
|
ScriptOperator |
ScriptOperator.
|
SecureCmdDoAs |
SecureCmdDoAs - Helper class for setting parameters and env necessary for
being able to run child jvm as intended user.
|
SelectOperator |
Select operator implementation.
|
SerializationUtilities |
Utilities related to serialization and deserialization.
|
SerializationUtilities.Hook | |
SkewJoinHandler |
At runtime in Join, we output big keys in one table into one corresponding
directories, and all same keys in other tables into different dirs(one for
each table).
|
SMBMapJoinOperator |
Sorted Merge Map Join Operator.
|
SparkHashTableSinkOperator | |
Stat | |
StatsTask |
StatsTask implementation.
|
TableScanOperator |
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
Task<T extends Serializable> |
Task implementation.
|
TaskFactory |
TaskFactory implementation.
|
TaskFactory.TaskTuple<T extends Serializable> |
taskTuple.
|
TaskHandle |
TaskHandle.
|
TaskResult |
TaskResult implementation.
|
TaskRunner |
TaskRunner implementation.
|
TemporaryHashSinkOperator | |
TerminalOperator<T extends OperatorDesc> |
Terminal Operator Base Class.
|
TextRecordReader |
TextRecordReader.
|
TextRecordWriter |
TextRecordWriter.
|
TezDummyStoreOperator |
A dummy store operator same as the dummy store operator but for tez.
|
TopNHash |
Stores binary key/value in sorted manner to get top-n key/value
TODO: rename to TopNHeap?
|
UDAF | Deprecated
Either implement
GenericUDAFResolver2 or extend
AbstractGenericUDAFResolver instead. |
UDF | Deprecated
use
GenericUDF |
UDFClassLoader |
UDFClassLoader is used to dynamically register
udf (and related) jars
This was introducted to fix HIVE-11878
Each session will have its own instance of UDFClassLoader
This is to support HiveServer2 where there can be multiple
active sessions. |
UDTFOperator |
UDTFOperator.
|
UnionOperator |
Union Operator Just forwards.
|
Utilities |
Utilities.
|
Utilities.CollectionPersistenceDelegate | |
Utilities.MissingBucketsContext | |
Utilities.SQLCommand<T> | |
WindowFunctionInfo |
Enum | Description |
---|---|
AbstractMapOperator.Counter |
Counter.
|
FileSinkOperator.Counter |
Counters.
|
FunctionInfo.FunctionType | |
FunctionUtils.FunctionType |
Function type, for permanent functions.
|
FunctionUtils.UDFClassType |
Enum type to describe what kind of UDF implementation class
|
JoinOperator.SkewkeyTableCounter |
SkewkeyTableCounter.
|
JoinUtil.JoinResult |
Represents the join result between two tables
|
Operator.Counter |
Counters.
|
Operator.State |
State.
|
ScriptOperator.Counter |
Counter.
|
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
|
Utilities.ReduceField |
ReduceField:
KEY: record key
VALUE: record value
|
Utilities.StreamStatus |
StreamStatus.
|
Exception | Description |
---|---|
AmbiguousMethodException |
Exception thrown by the UDF and UDAF method resolvers in case a unique method
is not found.
|
NoMatchingMethodException |
Exception thrown by the UDF and UDAF method resolvers in case no matching method
is found.
|
TaskExecutionException |
Exception thrown by any task processor to signal a problem with task
execution.
|
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.
|
Annotation Type | Description |
---|---|
Description |
Description.
|
PartitionTableFunctionDescription | |
WindowFunctionDescription |
Copyright © 2022 The Apache Software Foundation. All rights reserved.