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.slf4j.Logger |
LOG |
protected static Set<Class<?>> |
propagatableUdfs |
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 © 2021 The Apache Software Foundation. All rights reserved.