Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.bridge.java | |
org.apache.flink.table.api.bridge.java.internal | |
org.apache.flink.table.api.internal |
Modifier and Type | Method and Description |
---|---|
StatementSet |
StatementSet.addInsert(String targetPath,
Table table)
Adds a statement that the pipeline defined by the given
Table object should be
written to a table (backed by a DynamicTableSink ) that was registered under the
specified path. |
StatementSet |
StatementSet.addInsert(String targetPath,
Table table,
boolean overwrite)
Adds a statement that the pipeline defined by the given
Table object should be
written to a table (backed by a DynamicTableSink ) that was registered under the
specified path. |
StatementSet |
StatementSet.addInsert(TableDescriptor targetDescriptor,
Table table)
Adds a statement that the pipeline defined by the given
Table object should be
written to a table (backed by a DynamicTableSink ) expressed via the given TableDescriptor . |
StatementSet |
StatementSet.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite)
Adds a statement that the pipeline defined by the given
Table object should be
written to a table (backed by a DynamicTableSink ) expressed via the given TableDescriptor . |
StatementSet |
StatementSet.addInsertSql(String statement)
Adds an
INSERT INTO SQL statement. |
StatementSet |
TableEnvironment.createStatementSet()
Returns a
StatementSet that accepts pipelines defined by DML statements or Table objects. |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamStatementSet
A
StatementSet that integrates with the Java-specific DataStream API. |
Modifier and Type | Class and Description |
---|---|
class |
StreamStatementSetImpl
Implementation for
StreamStatementSet . |
Modifier and Type | Class and Description |
---|---|
class |
StatementSetImpl<E extends TableEnvironmentInternal>
Implementation for
StatementSet . |
Modifier and Type | Method and Description |
---|---|
StatementSet |
StatementSetImpl.addInsert(String targetPath,
Table table) |
StatementSet |
StatementSetImpl.addInsert(String targetPath,
Table table,
boolean overwrite) |
StatementSet |
StatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table) |
StatementSet |
StatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
StatementSet |
StatementSetImpl.addInsertSql(String statement) |
StatementSet |
TableEnvironmentImpl.createStatementSet() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.