Modifier and Type | Method and Description |
---|---|
TableConfig |
TableEnvironment.config() |
static TableConfig |
TableConfig.DEFAULT() |
TableConfig |
TableConfig$.DEFAULT() |
TableConfig |
TableEnvironment.getConfig()
Returns the table config to define the runtime behavior of the Table API.
|
Modifier and Type | Method and Description |
---|---|
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static StreamTableEnvironment |
TableEnvironment.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static StreamTableEnvironment |
TableEnvironment.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
Constructor and Description |
---|
BatchTableEnvironment(ExecutionEnvironment execEnv,
TableConfig config) |
StreamTableEnvironment(StreamExecutionEnvironment execEnv,
TableConfig config) |
TableEnvironment(TableConfig config) |
Constructor and Description |
---|
BatchTableEnvironment(ExecutionEnvironment execEnv,
TableConfig config) |
StreamTableEnvironment(StreamExecutionEnvironment execEnv,
TableConfig config) |
Constructor and Description |
---|
BatchTableEnvironment(ExecutionEnvironment execEnv,
TableConfig config) |
StreamTableEnvironment(StreamExecutionEnvironment execEnv,
TableConfig config) |
Constructor and Description |
---|
CodeGenerator(TableConfig config)
A code generator for generating Flink input formats.
|
CodeGenerator(TableConfig config,
boolean nullableInput,
TypeInformation<Object> input,
int[] inputPojoFieldMapping)
A code generator for generating unary Flink
Function s with one input. |
CodeGenerator(TableConfig config,
boolean nullableInput,
TypeInformation<Object> input1,
scala.Option<TypeInformation<Object>> input2,
scala.Option<int[]> input1PojoFieldMapping,
scala.Option<int[]> input2PojoFieldMapping) |
ExpressionReducer(TableConfig config) |
Modifier and Type | Method and Description |
---|---|
CorrelateFlatMapRunner<Object,Object> |
FlinkCorrelate.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 |
FlinkCalc.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) |
GeneratedCollector |
FlinkCorrelate.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>> |
FlinkCorrelate.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.
|
MapFunction<Object,Object> |
FlinkRel.getConversionMapper(TableConfig config,
boolean nullableInput,
TypeInformation<Object> inputType,
TypeInformation<Object> expectedType,
String conversionOperatorName,
scala.collection.Seq<String> fieldNames,
scala.Option<int[]> inputPojoFieldMapping) |
Modifier and Type | Method and Description |
---|---|
protected DataSet<Object> |
BatchScan.convertToExpectedType(DataSet<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
Modifier and Type | Method and Description |
---|---|
protected DataStream<Object> |
StreamScan.convertToExpectedType(DataStream<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.