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 |
---|---|
<A> int[] |
getFieldIndices(TableSource<A> tableSource)
Returns field indices for a given
TableSource . |
int[] |
getFieldIndices(TypeInformation<?> inputType)
Returns field indexes for a given
TypeInformation . |
<A> String[] |
getFieldNames(TableSource<A> tableSource)
Returns field names for a given
TableSource . |
<A> String[] |
getFieldNames(TypeInformation<A> inputType)
Returns field names for a given
TypeInformation . |
TypeInformation<?>[] |
getFieldTypes(TypeInformation<?> inputType)
Returns field types for a given
TypeInformation . |
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 . |
void |
validateType(TypeInformation<?> typeInfo)
Validate if class represented by the typeInfo is static and globally accessible
|
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.public <A> String[] getFieldNames(TypeInformation<A> inputType)
TypeInformation
.
inputType
- The TypeInformation extract the field names.public void validateType(TypeInformation<?> typeInfo)
typeInfo
- type to checkTableException
- if type does not meet these criteriapublic int[] getFieldIndices(TypeInformation<?> inputType)
TypeInformation
.
inputType
- The TypeInformation extract the field positions from.public TypeInformation<?>[] getFieldTypes(TypeInformation<?> inputType)
TypeInformation
.
inputType
- The TypeInformation to extract field types from.public <A> String[] getFieldNames(TableSource<A> tableSource)
TableSource
.
tableSource
- The TableSource to extract field names from.public <A> int[] getFieldIndices(TableSource<A> tableSource)
TableSource
.
tableSource
- The TableSource to extract field indices from.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.