org.apache.flink.api.connector.sink2

Interfaces

• Committer
• Committer.CommitRequest
• Sink
• Sink.InitContext
• SinkWriter
• SinkWriter.Context
• StatefulSink
• StatefulSink.StatefulSinkWriter
• StatefulSink.WithCompatibleState
• TwoPhaseCommittingSink
• TwoPhaseCommittingSink.PrecommittingSinkWriter