public final class ConstantPropagateProcFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ConstantPropagateProcFactory.ConstantPropagateDefaultProc
The Default Node Processor for Constant Propagation.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateFileSinkProc
The Node Processor for constant propagation for FileSink Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateFilterProc
Node Processor for Constant Propagation on Filter Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateGroupByProc
Node Processor for Constant Propagate for Group By Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateJoinProc
The Node Processor for Constant Propagation for Join Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateReduceSinkProc
The Node Processor for Constant Propagation for ReduceSink Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateSelectProc
The Node Processor for Constant Propagation for Select Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateStopProc
The Node Processor for Constant Propagation for Operators which is designed to stop propagate.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateTableScanProc
The Node Processor for Constant Propagation for Table Scan Operators.
|
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
LOG |
protected static Set<Class<?>> |
propagatableUdfs |
Modifier and Type | Method and Description |
---|---|
static ExprNodeDesc |
foldExpr(ExprNodeGenericFuncDesc funcDesc) |
static ConstantPropagateProcFactory.ConstantPropagateDefaultProc |
getDefaultProc()
Factory method to get the ConstantPropagateDefaultProc class.
|
static NodeProcessor |
getFileSinkProc() |
static ConstantPropagateProcFactory.ConstantPropagateFilterProc |
getFilterProc()
Factory method to get the ConstantPropagateFilterProc class.
|
static ConstantPropagateProcFactory.ConstantPropagateGroupByProc |
getGroupByProc()
Factory method to get the ConstantPropagateGroupByProc class.
|
static NodeProcessor |
getJoinProc() |
static NodeProcessor |
getReduceSinkProc() |
static ConstantPropagateProcFactory.ConstantPropagateSelectProc |
getSelectProc()
The Factory method to get the ConstantPropagateSelectProc class.
|
static NodeProcessor |
getStopProc() |
static NodeProcessor |
getTableScanProc() |
static ColumnInfo |
resolveColumn(RowSchema rs,
ExprNodeColumnDesc desc)
Get ColumnInfo from column expression.
|
public static ColumnInfo resolveColumn(RowSchema rs, ExprNodeColumnDesc desc)
rr
- desc
- public static ExprNodeDesc foldExpr(ExprNodeGenericFuncDesc funcDesc)
public static ConstantPropagateProcFactory.ConstantPropagateFilterProc getFilterProc()
public static ConstantPropagateProcFactory.ConstantPropagateGroupByProc getGroupByProc()
public static ConstantPropagateProcFactory.ConstantPropagateDefaultProc getDefaultProc()
public static ConstantPropagateProcFactory.ConstantPropagateSelectProc getSelectProc()
public static NodeProcessor getFileSinkProc()
public static NodeProcessor getStopProc()
public static NodeProcessor getReduceSinkProc()
public static NodeProcessor getJoinProc()
public static NodeProcessor getTableScanProc()
Copyright © 2017 The Apache Software Foundation. All rights reserved.