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.dsv2 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.dsv2 Class Description Sink Base interface for developing a sink. -
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 theCommittingSinkWriterin the second step of a two-phase commit protocol.Committer.CommitRequest A request to commit a specific committable.CommitterInitContext The interface exposes some runtime info for creating aCommitter.CommittingSinkWriter ASinkWriterthat performs the first part of a two-phase commit protocol.InitContext Common interface which exposes runtime info for creatingSinkWriterandCommitterobjects.Sink Base interface for developing a sink.Sink.InitContext Deprecated.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 Deprecated.ASinkWriterwhose state needs to be checkpointed.StatefulSinkWriter ASinkWriterwhose state needs to be checkpointed.SupportsCommitter A mixin interface for aSinkwhich supports exactly-once semantics using a two-phase commit protocol.SupportsWriterState A mixin interface for aSinkwhich supports a statefulStatefulSinkWriter.SupportsWriterState.WithCompatibleState A mix-in forSupportsWriterStatethat allows users to migrate from a sink with a compatible state to this sink.WriterInitContext The interface exposes some runtime info for creating aSinkWriter.