Uses of Package
org.apache.flink.api.connector.sink2
-
Packages that use org.apache.flink.api.connector.sink2 Package Description org.apache.flink.api.common.functions.util org.apache.flink.api.connector.sink2 -
Classes in org.apache.flink.api.connector.sink2 used by org.apache.flink.api.common.functions.util Class Description SinkWriter TheSinkWriteris responsible for writing data.SinkWriter.Context Context thatSinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context)can use for getting additional data about an input record. -
Classes in org.apache.flink.api.connector.sink2 used by org.apache.flink.api.connector.sink2 Class Description Committer TheCommitteris responsible for committing the data staged by theTwoPhaseCommittingSink.PrecommittingSinkWriterin the second step of a two-phase commit protocol.Committer.CommitRequest A request to commit a specific committable.Sink Base interface for developing a sink.Sink.InitContext The interface exposes some runtime info for creating aSinkWriter.SinkWriter TheSinkWriteris responsible for writing data.SinkWriter.Context Context thatSinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context)can use for getting additional data about an input record.StatefulSink.StatefulSinkWriter ASinkWriterwhose state needs to be checkpointed.TwoPhaseCommittingSink.PrecommittingSinkWriter ASinkWriterthat performs the first part of a two-phase commit protocol.