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

Hive QL execution tasks, operators, functions and other handlers.


Interface Summary
FileSinkOperator.RecordWriter RecordWriter.
Operator.OperatorFunc OperatorFunc.
RecordReader RecordReader.
RecordWriter RecordWriter.
UDAFEvaluator Interface that encapsulates the evaluation logic of a UDAF.
UDAFEvaluatorResolver The UDF Method resolver interface.
UDFMethodResolver The UDF Method resolver interface.

Class Summary
AbstractMapJoinOperator<T extends MapJoinDesc>  
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 ByteWritable.
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).
ColumnStatsTask ColumnStatsTask implementation.
CommonJoinOperator<T extends JoinDesc> Join operator implementation.
CommonJoinOperator.IntermediateObject IntermediateObject.
ComparisonOpMethodResolver The class implements the method resolution for operators like (> < <= >= = <>).
ConditionalTask Conditional Task implementation.
CopyTask CopyTask implementation.
DDLTask DDLTask implementation.
DefaultUDAFEvaluatorResolver The default UDAF Method resolver.
DefaultUDFMethodResolver The default UDF Method resolver.
DependencyCollectionTask DependencyCollectionTask.
ExecDriver ExecDriver.
ExecMapper ExecMapper.
ExecMapper.reportStats reportStats.
ExecReducer ExecReducer.
ExplainTask ExplainTask implementation.
ExplainTask.MethodComparator MethodComparator.
ExprNodeColumnEvaluator This evaluator gets the column from the row object.
ExprNodeConstantEvaluator ExprNodeConstantEvaluator.
ExprNodeEvaluator ExprNodeEvaluator.
ExprNodeEvaluatorFactory ExprNodeEvaluatorFactory.
ExprNodeFieldEvaluator This Evaluator can evaluate s.f for s as both struct and list of struct.
ExprNodeGenericFuncEvaluator ExprNodeGenericFuncEvaluator.
ExprNodeNullEvaluator ExprNodeNullEvaluator.
ExtractOperator Extract operator implementation Extracts a subobject and passes that on.
FetchOperator FetchTask implementation.
FetchTask FetchTask implementation.
FileSinkOperator File Sink operator implementation.
FilterOperator Filter operator implementation.
ForwardOperator Forward Operator Just forwards.
FunctionInfo FunctionInfo.
FunctionRegistry FunctionRegistry.
FunctionTask FunctionTask.
GroupByOperator GroupBy operator implementation.
JobCloseFeedBack After this job closed, some data (feedbacks) can be passed to descendant jobs.
JobDebugger JobDebugger takes a RunningJob that has failed and grabs the top 4 failing tasks and outputs this information to the Hive CLI.
JobTrackerURLResolver JobTrackerURLResolver.
JoinOperator Join operator implementation.
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.
MapRedTask Extension of ExecDriver: - can optionally spawn a map-reduce task from a separate jvm - will make last minute adjustments to map-reduce job parameters, viz: * estimating number of reducers * estimating whether job should run locally
MoveTask MoveTask implementation.
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.
Operator<T extends OperatorDesc> Base operator implementation.
OperatorFactory OperatorFactory.
OperatorFactory.OpTuple<T extends OperatorDesc> OpTuple.
ReduceSinkOperator Reduce Sink Operator sends output to the reduce stage.
RowSchema RowSchema Implementation.
ScriptOperator ScriptOperator.
SelectOperator Select operator implementation.
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.
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.
TerminalOperator<T extends OperatorDesc> Terminal Operator Base Class.
TestExecDriver Mimics the actual query compiler in generating end to end plans and testing them out.
TestExpressionEvaluator TestExpressionEvaluator.
TestHashMapWrapper TestHashMapWrapper.
TestOperators TestOperators.
TestPlan TestPlan.
TestStatsPublisherEnhanced TestPublisher jdbc.
TextRecordReader TextRecordReader.
TextRecordWriter TextRecordWriter.
Throttle Intelligence to make clients wait if the cluster is in a bad state.
UDAF Base class for all User-defined Aggregation Function (UDAF) classes.
UDF A User-defined function (UDF) for the use with Hive.
UDTFOperator UDTFOperator.
UnionOperator Union Operator Just forwards.
Utilities Utilities.
Utilities.EnumDelegate Java 1.5 workaround.
Utilities.StreamPrinter StreamPrinter.
Utilities.Tuple<T,V> Tuple.

Enum Summary
FileSinkOperator.TableIdEnum TableIdEnum.
FilterOperator.Counter Counter.
JoinOperator.SkewkeyTableCounter SkewkeyTableCounter.
MapOperator.Counter Counter.
Operator.ProgressCounter TODO This is a hack for hadoop 0.17 which only supports enum counters.
Operator.State State.
ScriptOperator.Counter Counter.
Utilities.ReduceField ReduceField.
Utilities.StreamStatus StreamStatus.

Exception Summary
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 Types Summary
Description Description.

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

Hive QL execution tasks, operators, functions and other handlers.

Copyright © 2013 The Apache Software Foundation