Modifier and Type | Method and Description |
---|---|
static TableEnvironment |
TableEnvironment.create(Configuration configuration)
Creates a table environment that is the entry point and central context for creating Table
and SQL API programs.
|
static TableEnvironment |
TableEnvironment.create(EnvironmentSettings settings)
Creates a table environment that is the entry point and central context for creating Table
and SQL API programs.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BatchTableEnvironment
Deprecated.
BatchTableEnvironment will be dropped in Flink 1.14 because it only supports
the old planner. Use the unified TableEnvironment instead, which supports both batch
and streaming. More advanced operations previously covered by the DataSet API can now use the
DataStream API in BATCH execution mode. |
interface |
StreamTableEnvironment
This table environment is the entry point and central context for creating Table and SQL API
programs that integrate with the Java-specific
DataStream API. |
Modifier and Type | Class and Description |
---|---|
class |
StreamTableEnvironmentImpl
The implementation for a Java
StreamTableEnvironment . |
Modifier and Type | Interface and Description |
---|---|
interface |
TableEnvironmentInternal
An internal interface of
TableEnvironment that defines extended methods used for TableImpl . |
Modifier and Type | Class and Description |
---|---|
class |
TableEnvironmentImpl
Implementation of
TableEnvironment that works exclusively with Table API interfaces. |
Modifier and Type | Method and Description |
---|---|
TableEnvironment |
TableImpl.getTableEnvironment() |
Modifier and Type | Method and Description |
---|---|
TableEnvironment |
ExecutionContext.getTableEnvironment() |
Modifier and Type | Method and Description |
---|---|
static void |
LegacyTableEnvironmentInitializer.initializeSessionState(TableEnvironment tableEnv,
Environment environment,
URLClassLoader classLoader)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
CatalogTableStats.register2Catalog(TableEnvironment tEnv,
String table) |
static void |
TpcdsStatsProvider.registerTpcdsStats(TableEnvironment tEnv) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.