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 |
Transformer.transform(TableEnvironment tEnv,
Table input)
Applies the transformer on the input table, and returns the result 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.
|
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 & SQL
API programs.
|
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 |
---|---|
static TableImpl |
TableImpl.createTable(TableEnvironment tableEnvironment,
QueryOperation operationTree,
OperationTreeBuilder operationTreeBuilder,
FunctionLookup functionLookup) |
Modifier and Type | Interface and Description |
---|---|
interface |
BatchTableEnvironment
|
interface |
StreamTableEnvironment
This table environment is the entry point and central context for creating Table & 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 | Method and Description |
---|---|
TableEnvironment |
ExecutionContext.EnvironmentInstance.getTableEnvironment() |
Constructor and Description |
---|
BatchTableDescriptor(TableEnvironment tableEnv,
ConnectorDescriptor connectorDescriptor) |
ConnectTableDescriptor(TableEnvironment tableEnv,
ConnectorDescriptor connectorDescriptor) |
StreamTableDescriptor(TableEnvironment tableEnv,
ConnectorDescriptor connectorDescriptor) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.