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) |
Modifier and Type | Method and Description |
---|---|
TableConfig |
TableEnvironment.config() |
TableConfig |
TableConfig$.DEFAULT() |
static 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 |
---|---|
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
static StreamTableEnvironment |
TableEnvironment.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static 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 |
---|
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[]> inputPojoFieldMapping) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
protected DataSet<Object> |
BatchScan.convertToExpectedType(DataSet<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
MapFunction<Object,Object> |
DataSetRel.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 DataStream<Object> |
StreamScan.convertToExpectedType(DataStream<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple2<MapFunction<Object,Row>,GroupReduceFunction<Row,Row>> |
AggregateUtil.createOperatorFunctionsForAggregates(scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
TableConfig config)
Create Flink operator functions for aggregates.
|
scala.Tuple2<MapFunction<Object,Row>,GroupReduceFunction<Row,Row>> |
AggregateUtil$.createOperatorFunctionsForAggregates(scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
TableConfig config)
Create Flink operator functions for aggregates.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.