Modifier and Type | Method and Description |
---|---|
CompilationOpContext |
Context.getOpContext() |
Modifier and Type | Field and Description |
---|---|
protected CompilationOpContext |
Operator.cContext |
Modifier and Type | Method and Description |
---|---|
CompilationOpContext |
Operator.getCompilationOpContext() |
Modifier and Type | Method and Description |
---|---|
static <T extends OperatorDesc> |
OperatorFactory.get(CompilationOpContext cContext,
Class<T> descClass) |
static <T extends OperatorDesc> |
OperatorFactory.get(CompilationOpContext cContext,
T conf)
Returns an operator given the conf and a list of children operators.
|
static <T extends OperatorDesc> |
OperatorFactory.get(CompilationOpContext cContext,
T conf,
RowSchema rwsch)
Returns an operator given the conf and a list of children operators.
|
static <T extends OperatorDesc> |
OperatorFactory.getAndMakeChild(CompilationOpContext cContext,
T conf,
List<Operator<? extends OperatorDesc>> oplist)
Returns an operator given the conf and a list of parent operators.
|
static <T extends OperatorDesc> |
OperatorFactory.getAndMakeChild(CompilationOpContext cContext,
T conf,
RowSchema rwsch)
Returns an operator given the conf and a list of parent operators.
|
static <T extends OperatorDesc> |
OperatorFactory.getAndMakeChild(CompilationOpContext cContext,
T conf,
RowSchema rwsch,
List<Operator<? extends OperatorDesc>> oplist)
Returns an operator given the conf and a list of parent operators.
|
static <T extends OperatorDesc> |
OperatorFactory.getAndMakeChild(CompilationOpContext cContext,
T conf,
RowSchema rwsch,
Map<String,ExprNodeDesc> colExprMap,
List<Operator<? extends OperatorDesc>> oplist)
Returns an operator given the conf and a list of parent operators.
|
static <T extends OperatorDesc> |
OperatorFactory.getAndMakeChild(CompilationOpContext ctx,
T conf,
RowSchema rwsch,
Operator[] oplist)
Returns an operator given the conf and a list of parent operators.
|
static <T extends OperatorDesc> |
OperatorFactory.getVectorOperator(Class<? extends Operator<?>> opClass,
CompilationOpContext cContext,
T conf,
VectorizationContext vContext,
Operator<? extends OperatorDesc> originalOp) |
static <T extends OperatorDesc> |
OperatorFactory.getVectorOperator(CompilationOpContext cContext,
T conf,
VectorizationContext vContext,
Operator<? extends OperatorDesc> originalOp) |
void |
FetchTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
Task.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
void |
FunctionTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
ColumnStatsUpdateTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
ColumnStatsTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
StatsNoJobTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
void |
DDLTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext ctx,
CompilationOpContext opContext) |
void |
Operator.setCompilationOpContext(CompilationOpContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
MapredLocalTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
void |
ExecDriver.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext)
Initialization when invoked from QL.
|
Modifier and Type | Method and Description |
---|---|
void |
SparkTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
Modifier and Type | Method and Description |
---|---|
void |
MergeFileTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
Modifier and Type | Method and Description |
---|---|
void |
PartialScanTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnTruncateTask.initialize(QueryState queryState,
QueryPlan queryPlan,
DriverContext driverContext,
CompilationOpContext opContext) |
Modifier and Type | Method and Description |
---|---|
static MapWork |
GenMapRedUtils.createMergeTask(FileSinkDesc fsInputDesc,
org.apache.hadoop.fs.Path finalName,
boolean hasDynamicPartitions,
CompilationOpContext ctx)
Create a block level merge task for RCFiles or stripe level merge task for
ORCFiles
|
static TableScanOperator |
GenMapRedUtils.createTemporaryTableScanOperator(CompilationOpContext ctx,
RowSchema rowSchema) |
Modifier and Type | Field and Description |
---|---|
protected CompilationOpContext |
BaseSemanticAnalyzer.cContext |
Modifier and Type | Method and Description |
---|---|
CompilationOpContext |
SemanticAnalyzer.getOpContext() |
Constructor and Description |
---|
SparkPartitionPruningSinkOperator(CompilationOpContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
FetchWork.initializeForFetch(CompilationOpContext ctx) |
void |
ColumnStatsWork.initializeForFetch(CompilationOpContext ctx) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.