Modifier and Type | Method and Description |
---|---|
M |
Estimator.fit(TableEnvironment tEnv,
Table input)
|
Pipeline |
Pipeline.fit(TableEnvironment tEnv,
Table input)
Train the pipeline to fit on the records in the given
Table . |
Table |
Pipeline.transform(TableEnvironment tEnv,
Table input)
Generate a result table by applying all the stages in this pipeline to the input table in
order.
|
Table |
Transformer.transform(TableEnvironment tEnv,
Table input)
Applies the transformer on the input table, and returns the result table.
|
Modifier and Type | Method and Description |
---|---|
protected static TableEnvironment |
PipelineStageBase.tableEnvOf(Table table) |
Modifier and Type | Method and Description |
---|---|
M |
EstimatorBase.fit(TableEnvironment tEnv,
Table input) |
Table |
TransformerBase.transform(TableEnvironment tEnv,
Table input) |
Modifier and Type | Method and Description |
---|---|
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
|
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 |
---|---|
void |
CatalogTableStats.register2Catalog(TableEnvironment tEnv,
String table) |
static void |
TpcdsStatsProvider.registerTpcdsStats(TableEnvironment tEnv) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.