| 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 © 2019 The Apache Software Foundation. All Rights Reserved.