Uses of Interface
org.apache.flink.table.api.TablePipeline

Packages that use TablePipeline

Package	Description
org.apache.flink.table.api

Uses of TablePipeline in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return TablePipeline

Modifier and Type	Method	Description
TablePipeline	Table.insertInto(String tablePath)	Declares 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.
TablePipeline	Table.insertInto(String tablePath, boolean overwrite)	Declares 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.
TablePipeline	Table.insertInto(String tablePath, InsertConflictStrategy conflictStrategy)	Declares 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.
TablePipeline	Table.insertInto(String tablePath, InsertConflictStrategy conflictStrategy, boolean overwrite)	Declares 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.
TablePipeline	Table.insertInto(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.
TablePipeline	Table.insertInto(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.
TablePipeline	Table.insertInto(TableDescriptor descriptor, InsertConflictStrategy conflictStrategy)	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.
TablePipeline	Table.insertInto(TableDescriptor descriptor, InsertConflictStrategy conflictStrategy, 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.

Methods in org.apache.flink.table.api with parameters of type TablePipeline

Modifier and Type	Method	Description
StatementSet	StatementSet.add(TablePipeline tablePipeline)	Adds a TablePipeline.