Class Hierarchy
- java.lang.Object
- org.apache.flink.api.connector.sink2.Sink.InitContextWrapper (implements org.apache.flink.api.connector.sink2.Sink.InitContext)
Interface Hierarchy
- java.lang.AutoCloseable
- org.apache.flink.api.connector.sink2.Committer<CommT>
- org.apache.flink.api.connector.sink2.SinkWriter<InputT>
- org.apache.flink.api.connector.sink2.CommittingSinkWriter<InputT,CommittableT>
- org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>
- org.apache.flink.api.connector.sink2.StatefulSinkWriter<InputT,WriterStateT>
- org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter<InputT,WriterStateT>
- org.apache.flink.api.connector.sink2.CommittingSinkWriter<InputT,CommittableT>
- org.apache.flink.api.connector.sink2.Committer.CommitRequest<CommT>
- org.apache.flink.api.connector.sink2.InitContext
- org.apache.flink.api.connector.sink2.CommitterInitContext
- org.apache.flink.api.connector.sink2.Sink.InitContext
- org.apache.flink.api.connector.sink2.WriterInitContext
- java.io.Serializable
- org.apache.flink.api.connector.sink2.Sink<InputT>
- org.apache.flink.api.connector.sink2.StatefulSink<InputT,WriterStateT> (also extends org.apache.flink.api.connector.sink2.SupportsWriterState<InputT,WriterStateT>)
- org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,CommT> (also extends org.apache.flink.api.connector.sink2.SupportsCommitter<CommittableT>)
- org.apache.flink.api.connector.sink2.Sink<InputT>
- org.apache.flink.api.connector.sink2.SinkWriter.Context
- org.apache.flink.api.connector.sink2.SupportsCommitter<CommittableT>
- org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,CommT> (also extends org.apache.flink.api.connector.sink2.Sink<InputT>)
- org.apache.flink.api.connector.sink2.SupportsWriterState<InputT,WriterStateT>
- org.apache.flink.api.connector.sink2.StatefulSink<InputT,WriterStateT> (also extends org.apache.flink.api.connector.sink2.Sink<InputT>)
- org.apache.flink.api.connector.sink2.SupportsWriterState.WithCompatibleState
- org.apache.flink.api.connector.sink2.StatefulSink.WithCompatibleState