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 |
---|
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<?> input1,
scala.Option<TypeInformation<?>> input2,
scala.Option<int[]> input1FieldMapping,
scala.Option<int[]> input2FieldMapping) |
CodeGenerator(TableConfig config,
boolean nullableInput,
TypeInformation<Object> input,
int[] inputFieldMapping)
A code generator for generating unary Flink
Function s with one input. |
ExpressionReducer(TableConfig config) |
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.
|
<F extends Function> |
CommonScan.generatedConversionFunction(TableConfig config,
Class<F> functionClass,
TypeInformation<Object> inputType,
TypeInformation<Row> expectedType,
String conversionOperatorName,
scala.collection.Seq<String> fieldNames,
scala.Option<int[]> inputFieldMapping) |
<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 |
---|---|
DataSet<Row> |
BatchScan.convertToInternalRow(DataSet<Object> input,
FlinkTable<?> flinkTable,
TableConfig config) |
Modifier and Type | Method and Description |
---|---|
DataStream<CRow> |
StreamScan.convertToInternalRow(RowSchema schema,
DataStream<Object> input,
FlinkTable<?> flinkTable,
TableConfig config) |
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.