public interface FlinkCorrelate
Modifier and Type | Method and Description |
---|---|
CorrelateFlatMapRunner<Object,Object> |
correlateMapFunction(TableConfig config,
TypeInformation<Object> inputTypeInfo,
TypeInformation<Object> udtfTypeInfo,
org.apache.calcite.rel.type.RelDataType rowType,
org.apache.calcite.sql.SemiJoinType joinType,
org.apache.calcite.rex.RexCall rexCall,
scala.Option<org.apache.calcite.rex.RexNode> condition,
scala.Option<TypeInformation<Object>> expectedType,
scala.Option<int[]> pojoFieldMapping,
String ruleDescription)
Creates the
CorrelateFlatMapRunner to execute the join of input table
and user-defined table function. |
String |
correlateOpName(org.apache.calcite.rex.RexCall rexCall,
TableSqlFunction sqlFunction,
org.apache.calcite.rel.type.RelDataType rowType) |
String |
correlateToString(org.apache.calcite.rex.RexCall rexCall,
TableSqlFunction sqlFunction) |
GeneratedCollector |
generateCollector(TableConfig config,
TypeInformation<Object> inputTypeInfo,
TypeInformation<Object> udtfTypeInfo,
TypeInformation<Object> returnType,
org.apache.calcite.rel.type.RelDataType rowType,
scala.Option<org.apache.calcite.rex.RexNode> condition,
scala.Option<int[]> pojoFieldMapping)
Generates table function collector.
|
GeneratedFunction<FlatMapFunction<Object,Object>> |
generateFunction(TableConfig config,
TypeInformation<Object> inputTypeInfo,
TypeInformation<Object> udtfTypeInfo,
TypeInformation<Object> returnType,
org.apache.calcite.rel.type.RelDataType rowType,
org.apache.calcite.sql.SemiJoinType joinType,
org.apache.calcite.rex.RexCall rexCall,
scala.Option<int[]> pojoFieldMapping,
String ruleDescription)
Generates the flat map function to run the user-defined table function.
|
String |
selectToString(org.apache.calcite.rel.type.RelDataType rowType) |
CorrelateFlatMapRunner<Object,Object> correlateMapFunction(TableConfig config, TypeInformation<Object> inputTypeInfo, TypeInformation<Object> udtfTypeInfo, org.apache.calcite.rel.type.RelDataType rowType, org.apache.calcite.sql.SemiJoinType joinType, org.apache.calcite.rex.RexCall rexCall, scala.Option<org.apache.calcite.rex.RexNode> condition, scala.Option<TypeInformation<Object>> expectedType, scala.Option<int[]> pojoFieldMapping, String ruleDescription)
CorrelateFlatMapRunner
to execute the join of input table
and user-defined table function.GeneratedFunction<FlatMapFunction<Object,Object>> generateFunction(TableConfig config, TypeInformation<Object> inputTypeInfo, TypeInformation<Object> udtfTypeInfo, TypeInformation<Object> returnType, org.apache.calcite.rel.type.RelDataType rowType, org.apache.calcite.sql.SemiJoinType joinType, org.apache.calcite.rex.RexCall rexCall, scala.Option<int[]> pojoFieldMapping, String ruleDescription)
GeneratedCollector generateCollector(TableConfig config, TypeInformation<Object> inputTypeInfo, TypeInformation<Object> udtfTypeInfo, TypeInformation<Object> returnType, org.apache.calcite.rel.type.RelDataType rowType, scala.Option<org.apache.calcite.rex.RexNode> condition, scala.Option<int[]> pojoFieldMapping)
String selectToString(org.apache.calcite.rel.type.RelDataType rowType)
String correlateOpName(org.apache.calcite.rex.RexCall rexCall, TableSqlFunction sqlFunction, org.apache.calcite.rel.type.RelDataType rowType)
String correlateToString(org.apache.calcite.rex.RexCall rexCall, TableSqlFunction sqlFunction)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.