public interface FlinkCalc
Modifier and Type | Method and Description |
---|---|
RichFlatMapFunction<Object,Object> |
calcMapFunction(GeneratedFunction<FlatMapFunction<Object,Object>> genFunction) |
String |
calcOpName(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
String |
calcToString(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
String |
conditionToString(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
String |
functionBody(CodeGenerator generator,
TypeInformation<Object> inputType,
org.apache.calcite.rel.type.RelDataType rowType,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
scala.Option<TypeInformation<Object>> expectedType) |
String |
selectionToString(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
String functionBody(CodeGenerator generator, TypeInformation<Object> inputType, org.apache.calcite.rel.type.RelDataType rowType, org.apache.calcite.rex.RexProgram calcProgram, TableConfig config, scala.Option<TypeInformation<Object>> expectedType)
RichFlatMapFunction<Object,Object> calcMapFunction(GeneratedFunction<FlatMapFunction<Object,Object>> genFunction)
String conditionToString(org.apache.calcite.rex.RexProgram calcProgram, scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression)
String selectionToString(org.apache.calcite.rex.RexProgram calcProgram, scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression)
String calcOpName(org.apache.calcite.rex.RexProgram calcProgram, scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.