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.