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.InitContext Common interface which exposes runtime info for creatingSinkWriterandCommitterobjects.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.StatefulSinkWriter ASinkWriterwhose state needs to be checkpointed.WriterInitContext The interface exposes some runtime info for creating aSinkWriter.