Uses of Class
org.apache.flink.table.api.InsertConflictStrategy

Packages that use InsertConflictStrategy

Package	Description
org.apache.flink.table.api

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

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

Modifier and Type	Method	Description
InsertConflictStrategy	InsertConflictStrategy.Builder.build()	Builds the InsertConflictStrategy.
static InsertConflictStrategy	InsertConflictStrategy.deduplicate()	Creates a strategy that maintains the full history of changes for each primary key to support rollback on retraction.
static InsertConflictStrategy	InsertConflictStrategy.error()	Creates a strategy that throws an exception when multiple distinct records arrive for the same primary key after watermark compaction.
static InsertConflictStrategy	InsertConflictStrategy.nothing()	Creates a strategy that keeps the first record that arrives for a given primary key and discards subsequent conflicts.

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

Modifier and Type	Method	Description
default TableResult	Table.executeInsert(String tablePath, InsertConflictStrategy conflictStrategy)	Shorthand for tableEnv.insertInto(tablePath, conflictStrategy).execute().
default TableResult	Table.executeInsert(String tablePath, InsertConflictStrategy conflictStrategy, boolean overwrite)	Shorthand for tableEnv.insertInto(tablePath, conflictStrategy, overwrite).execute().
default TableResult	Table.executeInsert(TableDescriptor descriptor, InsertConflictStrategy conflictStrategy)	Shorthand for tableEnv.insertInto(descriptor, conflictStrategy).execute().
default TableResult	Table.executeInsert(TableDescriptor descriptor, InsertConflictStrategy conflictStrategy, boolean overwrite)	Shorthand for tableEnv.insertInto(descriptor, conflictStrategy, overwrite).execute().
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, 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.