Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.plan.nodes | |
org.apache.flink.table.plan.nodes.datastream | |
org.apache.flink.table.plan.nodes.logical |
Modifier and Type | Method and Description |
---|---|
protected <OUT> GeneratedFunction<MapFunction<Row,OUT>,OUT> |
TableEnvironment.generateRowConverterFunction(TypeInformation<Row> inputTypeInfo,
RowSchema schema,
TypeInformation<OUT> requestedTypeInfo,
String functionName) |
protected <IN,OUT> scala.Option<MapFunction<IN,OUT>> |
BatchTableEnvironment.getConversionMapper(TypeInformation<IN> physicalTypeInfo,
RowSchema schema,
TypeInformation<OUT> requestedTypeInfo,
String functionName)
Creates a final converter that maps the internal row type to external type.
|
protected <IN,OUT> MapFunction<IN,OUT> |
StreamTableEnvironment.getConversionMapper(TypeInformation<IN> physicalTypeInfo,
RowSchema schema,
TypeInformation<OUT> requestedTypeInfo,
String functionName)
Creates a final converter that maps the internal row type to external type.
|
Modifier and Type | Method and Description |
---|---|
GeneratedCollector |
CommonCorrelate.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> |
CommonCalc.generateFunction(CodeGenerator generator,
String ruleDescription,
RowSchema inputSchema,
RowSchema returnSchema,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
Class<T> functionClass) |
<T extends Function> |
CommonCorrelate.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.
|
Modifier and Type | Method and Description |
---|---|
DataStream<CRow> |
StreamScan.convertToInternalRow(RowSchema schema,
DataStream<Object> input,
FlinkTable<?> flinkTable,
TableConfig config) |
Constructor and Description |
---|
DataStreamCalc(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode input,
RowSchema inputSchema,
RowSchema schema,
org.apache.calcite.rex.RexProgram calcProgram,
String ruleDescription) |
DataStreamCorrelate(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
RowSchema inputSchema,
org.apache.calcite.rel.RelNode input,
FlinkLogicalTableFunctionScan scan,
scala.Option<org.apache.calcite.rex.RexNode> condition,
RowSchema schema,
RowSchema joinSchema,
org.apache.calcite.sql.SemiJoinType joinType,
String ruleDescription) |
DataStreamGroupAggregate(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode inputNode,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
RowSchema schema,
RowSchema inputSchema,
int[] groupings) |
DataStreamGroupWindowAggregate(LogicalWindow window,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties,
org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode inputNode,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
RowSchema schema,
RowSchema inputSchema,
int[] grouping) |
DataStreamOverAggregate(org.apache.calcite.rel.core.Window logicWindow,
org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode inputNode,
RowSchema schema,
RowSchema inputSchema) |
DataStreamScan(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.plan.RelOptTable table,
RowSchema schema) |
DataStreamUnion(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode leftNode,
org.apache.calcite.rel.RelNode rightNode,
RowSchema schema) |
DataStreamValues(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
RowSchema schema,
com.google.common.collect.ImmutableList<com.google.common.collect.ImmutableList<org.apache.calcite.rex.RexLiteral>> tuples,
String ruleDescription) |
Modifier and Type | Method and Description |
---|---|
static <T extends Function> |
FlinkLogicalCalc.generateFunction(CodeGenerator generator,
String ruleDescription,
RowSchema inputSchema,
RowSchema returnSchema,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
Class<T> functionClass) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.