public interface CommonCorrelate
Modifier and Type | Method and Description |
---|---|
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,
RowSchema inputSchema,
TypeInformation<Object> udtfTypeInfo,
RowSchema returnSchema,
scala.Option<org.apache.calcite.rex.RexNode> condition,
scala.Option<int[]> pojoFieldMapping)
Generates table function collector.
|
<T extends Function> |
generateFunction(TableConfig config,
RowSchema inputSchema,
TypeInformation<Object> udtfTypeInfo,
RowSchema returnSchema,
org.apache.calcite.sql.SemiJoinType joinType,
org.apache.calcite.rex.RexCall rexCall,
scala.Option<int[]> pojoFieldMapping,
String ruleDescription,
Class<T> functionClass)
Generates the flat map function to run the user-defined table function.
|
String |
selectToString(org.apache.calcite.rel.type.RelDataType rowType) |
<T extends Function> GeneratedFunction<T,Row> generateFunction(TableConfig config, RowSchema inputSchema, TypeInformation<Object> udtfTypeInfo, RowSchema returnSchema, org.apache.calcite.sql.SemiJoinType joinType, org.apache.calcite.rex.RexCall rexCall, scala.Option<int[]> pojoFieldMapping, String ruleDescription, Class<T> functionClass)
config
- (undocumented)inputSchema
- (undocumented)udtfTypeInfo
- (undocumented)returnSchema
- (undocumented)joinType
- (undocumented)rexCall
- (undocumented)pojoFieldMapping
- (undocumented)ruleDescription
- (undocumented)functionClass
- (undocumented)GeneratedCollector generateCollector(TableConfig config, RowSchema inputSchema, TypeInformation<Object> udtfTypeInfo, RowSchema returnSchema, scala.Option<org.apache.calcite.rex.RexNode> condition, scala.Option<int[]> pojoFieldMapping)
config
- (undocumented)inputSchema
- (undocumented)udtfTypeInfo
- (undocumented)returnSchema
- (undocumented)condition
- (undocumented)pojoFieldMapping
- (undocumented)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–2018 The Apache Software Foundation. All rights reserved.