Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.scala |
Modifier and Type | Method and Description |
---|---|
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment)
Returns a
ScalaBatchTableEnv for a Scala ScalaBatchExecEnv . |
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment)
Returns a
ScalaBatchTableEnv for a Scala ScalaBatchExecEnv . |
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
Modifier and Type | Method and Description |
---|---|
Table |
DataSetConversions.toTable(BatchTableEnvironment tableEnv,
scala.collection.Seq<Expression> fields)
Converts the
DataSet into a Table . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.