Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.spark | |
org.apache.hadoop.hive.ql.exec.vector | |
org.apache.hadoop.hive.ql.optimizer.spark | |
org.apache.hadoop.hive.ql.parse.spark |
Modifier and Type | Method and Description |
---|---|
static boolean |
OperatorUtils.isInBranch(SparkPartitionPruningSinkOperator op)
Return true if contain branch otherwise return false
|
static void |
OperatorUtils.removeBranch(SparkPartitionPruningSinkOperator op)
Remove the branch that contains the specified operator.
|
Modifier and Type | Method and Description |
---|---|
static SparkPartitionPruningSinkOperator |
SparkUtilities.findReusableDPPSink(Operator<? extends OperatorDesc> branchingOP,
List<Operator<? extends OperatorDesc>> list) |
Modifier and Type | Class and Description |
---|---|
class |
VectorSparkPartitionPruningSinkOperator
Vectorized version for SparkPartitionPruningSinkOperator.
|
Modifier and Type | Method and Description |
---|---|
static void |
CombineEquivalentWorkResolver.combineEquivalentDPPSinks(SparkPartitionPruningSinkOperator first,
SparkPartitionPruningSinkOperator second) |
Modifier and Type | Method and Description |
---|---|
void |
GenSparkUtils.processPartitionPruningSink(GenSparkProcContext context,
SparkPartitionPruningSinkOperator pruningSink)
Populate partition pruning information from the pruning sink operator to the
target MapWork (the MapWork for the big table side).
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.