Uses of Package
org.apache.flink.streaming.api.connector.sink2
-
Classes in org.apache.flink.streaming.api.connector.sink2 used by org.apache.flink.streaming.api.connector.sink2 Class Description CommittableMessage The message send fromSinkWritertoCommitter.CommittableSummary This class tracks the information about committables belonging to one checkpoint coming from one subtask.CommittableWithLineage Provides metadata.SupportsPostCommitTopology Allows expert users to implement a custom topology afterCommitter.SupportsPreCommitTopology Allows expert users to implement a custom topology afterSinkWriterand beforeCommitter.SupportsPreWriteTopology Allows expert users to implement a custom topology beforeSinkWriter. -
Classes in org.apache.flink.streaming.api.connector.sink2 used by org.apache.flink.streaming.api.transformations Class Description CommittableMessage The message send fromSinkWritertoCommitter. -
Classes in org.apache.flink.streaming.api.connector.sink2 used by org.apache.flink.streaming.runtime.operators.sink Class Description CommittableMessage The message send fromSinkWritertoCommitter. -
Classes in org.apache.flink.streaming.api.connector.sink2 used by org.apache.flink.streaming.runtime.operators.sink.committables Class Description CommittableMessage The message send fromSinkWritertoCommitter.