|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||
| Interface Summary | |
|---|---|
| FileSinkOperator.RecordWriter | |
| Operator.OperatorFunc | |
| RecordReader | |
| UDAFEvaluator | Interface that encapsulates the evaluation logic of a UDAF. |
| UDAFEvaluatorResolver | The UDF Method resolver interface. |
| UDFMethodResolver | The UDF Method resolver interface. |
| Class Summary | |
|---|---|
| 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). |
| CommonJoinOperator<T extends joinDesc> | Join operator implementation. |
| CommonJoinOperator.IntermediateObject | |
| ComparisonOpMethodResolver | The class implements the method resolution for overloaded comparison operators. |
| ConditionalTask | Conditional Task implementation |
| CopyTask | CopyTask implementation |
| DDLTask | DDLTask implementation |
| DefaultUDAFEvaluatorResolver | The default UDAF Method resolver. |
| DefaultUDFMethodResolver | The default UDF Method resolver. |
| ExecDriver | |
| ExecMapper | |
| ExecMapper.reportStats | |
| ExecReducer | |
| ExplainTask | ExplainTask implementation |
| ExplainTask.MethodComparator | |
| ExprNodeColumnEvaluator | This evaluator gets the column from the row object. |
| ExprNodeConstantEvaluator | |
| ExprNodeEvaluator | |
| ExprNodeEvaluatorFactory | |
| ExprNodeFieldEvaluator | This Evaluator can evaluate s.f for s as both struct and list of struct. |
| ExprNodeFuncEvaluator | |
| ExprNodeGenericFuncEvaluator | |
| 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 | |
| FunctionRegistry | |
| FunctionTask | |
| GroupByOperator | GroupBy operator implementation. |
| JoinOperator | Join operator implementation. |
| LimitOperator | Limit operator implementation Limits the number of rows to be passed on. |
| MapJoinObjectKey | Map Join Object used for both key |
| MapJoinObjectValue | Map Join Object used for both key and value |
| MapJoinOperator | Map side Join operator implementation. |
| MapJoinOperator.MapJoinObjectCtx | |
| MapOperator | Map operator. |
| MapRedTask | Alternate implementation (to ExecDriver) of spawning a mapreduce task that runs it from a separate jvm. |
| 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 Serializable> | Base operator implementation |
| OperatorFactory | |
| OperatorFactory.opTuple<T extends Serializable> | |
| ReduceSinkOperator | Reduce Sink Operator sends output to the reduce stage |
| RowSchema | RowSchema Implementation |
| ScriptOperator | |
| SelectOperator | Select operator 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> | |
| TerminalOperator<T extends Serializable> | Terminal Operator Base Class |
| TextRecordReader | |
| Throttle | |
| UDAF | Base class for all User-defined Aggregation Function (UDAF) classes. |
| UDF | A User-defined function (UDF) for the use with Hive. |
| UnionOperator | Union Operator Just forwards. |
| Utilities | |
| Utilities.EnumDelegate | Java 1.5 workaround. |
| Utilities.StreamPrinter | |
| Utilities.Tuple<T,V> | |
| Enum Summary | |
|---|---|
| FileSinkOperator.TableIdEnum | |
| FilterOperator.Counter | |
| FunctionInfo.OperatorType | |
| MapOperator.Counter | |
| Operator.State | |
| ScriptOperator.Counter | |
| Utilities.ReduceField | The object in the reducer are composed of these top level fields |
| Utilities.streamStatus | |
| Exception Summary | |
|---|---|
| AmbiguousMethodException | Exception thrown by the UDF and UDAF method resolvers in case a unique method is not found. |
| 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 | |
|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||