public final class OpProcFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
OpProcFactory.DefaultPPD
Default processor which just merges its children.
|
static class |
OpProcFactory.FilterPPD
Determines the push down predicates in its where expression and then
combines it with the push down predicates that are passed from its children.
|
static class |
OpProcFactory.JoinerPPD
Determines predicates for which alias can be pushed to it's parents.
|
static class |
OpProcFactory.JoinPPD |
static class |
OpProcFactory.LateralViewForwardPPD |
static class |
OpProcFactory.PTFPPD |
static class |
OpProcFactory.ReduceSinkPPD |
static class |
OpProcFactory.ScriptPPD
Processor for Script Operator Prevents any predicates being pushed.
|
static class |
OpProcFactory.TableScanPPD
Combines predicates of its child into a single expression and adds a filter
op as new child.
|
static class |
OpProcFactory.UDTFPPD |
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
LOG |
Modifier and Type | Method and Description |
---|---|
protected static Object |
createFilter(Operator op,
ExprWalkerInfo pushDownPreds,
OpWalkerInfo owi) |
protected static Object |
createFilter(Operator op,
Map<String,List<ExprNodeDesc>> predicates,
OpWalkerInfo owi) |
static NodeProcessor |
getDefaultProc() |
static NodeProcessor |
getFilterProc() |
static NodeProcessor |
getJoinProc() |
static NodeProcessor |
getLIMProc() |
static NodeProcessor |
getLVFProc() |
static NodeProcessor |
getLVJProc() |
static NodeProcessor |
getPTFProc() |
static NodeProcessor |
getRSProc() |
static NodeProcessor |
getSCRProc() |
static NodeProcessor |
getTSProc() |
static NodeProcessor |
getUDTFProc() |
protected static Object createFilter(Operator op, ExprWalkerInfo pushDownPreds, OpWalkerInfo owi)
protected static Object createFilter(Operator op, Map<String,List<ExprNodeDesc>> predicates, OpWalkerInfo owi)
public static NodeProcessor getFilterProc()
public static NodeProcessor getJoinProc()
public static NodeProcessor getTSProc()
public static NodeProcessor getDefaultProc()
public static NodeProcessor getPTFProc()
public static NodeProcessor getSCRProc()
public static NodeProcessor getLIMProc()
public static NodeProcessor getLVFProc()
public static NodeProcessor getUDTFProc()
public static NodeProcessor getLVJProc()
public static NodeProcessor getRSProc()
Copyright © 2017 The Apache Software Foundation. All rights reserved.