org.apache.flink.streaming.api.connector.sink2

接口

• CommittableMessage
• SupportsPostCommitTopology
• SupportsPreCommitTopology
• SupportsPreWriteTopology
• WithPostCommitTopology
• WithPreCommitTopology
• WithPreWriteTopology

类

• CommittableMessageSerializer
• CommittableMessageTypeInfo
• CommittableSummary
• CommittableWithLineage
• StandardSinkTopologies