Uses of Package
org.apache.flink.connector.base.sink.writer
-
Packages that use org.apache.flink.connector.base.sink.writer Package Description org.apache.flink.connector.base.sink org.apache.flink.connector.base.sink.writer -
Classes in org.apache.flink.connector.base.sink.writer used by org.apache.flink.connector.base.sink Class Description ElementConverter This interface specifies the mapping between elements of a stream to request entries that can be sent to the destination. -
Classes in org.apache.flink.connector.base.sink.writer used by org.apache.flink.connector.base.sink.writer Class Description BufferedRequestState Class holding state ofAsyncSinkWriterneeded at taking a snapshot.ElementConverter This interface specifies the mapping between elements of a stream to request entries that can be sent to the destination.RequestEntryWrapper A wrapper that contains aRequestEntryTready to be written by the Sink Writer class, along with the size of that entry as defined by the methodgetSizeInBytes(RequestEntryT)of theAsyncSinkWriter.ResultHandler Interface to handle the result of aAsyncSinkWriterrequest.