public class TableEnvironment$ extends Object
TableEnvironment
depending on the batch or stream execution
environment.Modifier and Type | Field and Description |
---|---|
static TableEnvironment$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
TableEnvironment$() |
Modifier and Type | Method and Description |
---|---|
BatchTableEnvironment |
getTableEnvironment(ExecutionEnvironment executionEnvironment)
Returns a
JavaBatchTableEnv for a Java JavaBatchExecEnv . |
BatchTableEnvironment |
getTableEnvironment(ExecutionEnvironment executionEnvironment)
Returns a
ScalaBatchTableEnv for a Scala ScalaBatchExecEnv . |
BatchTableEnvironment |
getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
BatchTableEnvironment |
getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
StreamTableEnvironment |
getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
Returns a
JavaStreamTableEnv for a Java JavaStreamExecEnv . |
StreamTableEnvironment |
getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
StreamTableEnvironment |
getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
StreamTableEnvironment |
getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
public static final TableEnvironment$ MODULE$
public BatchTableEnvironment getTableEnvironment(ExecutionEnvironment executionEnvironment)
JavaBatchTableEnv
for a Java JavaBatchExecEnv
.
executionEnvironment
- The Java batch ExecutionEnvironment.public BatchTableEnvironment getTableEnvironment(ExecutionEnvironment executionEnvironment, TableConfig tableConfig)
executionEnvironment
- The Java batch ExecutionEnvironment.tableConfig
- The TableConfig for the new TableEnvironment.public BatchTableEnvironment getTableEnvironment(ExecutionEnvironment executionEnvironment)
ScalaBatchTableEnv
for a Scala ScalaBatchExecEnv
.
executionEnvironment
- The Scala batch ExecutionEnvironment.public BatchTableEnvironment getTableEnvironment(ExecutionEnvironment executionEnvironment, TableConfig tableConfig)
executionEnvironment
- The Scala batch ExecutionEnvironment.tableConfig
- The TableConfig for the new TableEnvironment.public StreamTableEnvironment getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
JavaStreamTableEnv
for a Java JavaStreamExecEnv
.
executionEnvironment
- The Java StreamExecutionEnvironment.public StreamTableEnvironment getTableEnvironment(StreamExecutionEnvironment executionEnvironment, TableConfig tableConfig)
executionEnvironment
- The Java StreamExecutionEnvironment.tableConfig
- The TableConfig for the new TableEnvironment.public StreamTableEnvironment getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
ScalaStreamTableEnv
for a Scala stream ScalaStreamExecEnv
.
executionEnvironment
- The Scala StreamExecutionEnvironment.public StreamTableEnvironment getTableEnvironment(StreamExecutionEnvironment executionEnvironment, TableConfig tableConfig)
ScalaStreamTableEnv
for a Scala stream ScalaStreamExecEnv
.
executionEnvironment
- The Scala StreamExecutionEnvironment.tableConfig
- The TableConfig for the new TableEnvironment.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.