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 |
---|---|
TableDescriptor |
TableDescriptor.Builder.build()
Returns an immutable instance of
TableDescriptor . |
Modifier and Type | Method and Description |
---|---|
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 . |
void |
TableEnvironment.createTable(String path,
TableDescriptor descriptor)
Registers the given
TableDescriptor as a catalog table. |
void |
TableEnvironment.createTemporaryTable(String path,
TableDescriptor descriptor)
Registers the given
TableDescriptor as a temporary catalog table. |
TableResult |
Table.executeInsert(TableDescriptor descriptor)
Declares that the pipeline defined by the given
Table object should be written to a
table (backed by a DynamicTableSink ) expressed via the given TableDescriptor . |
TableResult |
Table.executeInsert(TableDescriptor descriptor,
boolean overwrite)
Declares that the pipeline defined by the given
Table object should be written to a
table (backed by a DynamicTableSink ) expressed via the given TableDescriptor . |
Table |
TableEnvironment.from(TableDescriptor descriptor)
Returns a
Table backed by the given descriptor . |
Modifier and Type | Method and Description |
---|---|
StreamStatementSet |
StreamStatementSet.addInsert(TableDescriptor targetDescriptor,
Table table) |
StreamStatementSet |
StreamStatementSet.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
Modifier and Type | Method and Description |
---|---|
StreamStatementSet |
StreamStatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
Modifier and Type | Method and Description |
---|---|
StatementSet |
StatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table) |
StatementSet |
StatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
void |
TableEnvironmentImpl.createTable(String path,
TableDescriptor descriptor) |
void |
TableEnvironmentImpl.createTemporaryTable(String path,
TableDescriptor descriptor) |
TableResult |
TableImpl.executeInsert(TableDescriptor descriptor) |
TableResult |
TableImpl.executeInsert(TableDescriptor descriptor,
boolean overwrite) |
Table |
TableEnvironmentImpl.from(TableDescriptor descriptor) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.