Package org.apache.flink.connector.base.sink.writer

Interface Summary

Interface	Description
ElementConverter<InputT,RequestEntryT>	This interface specifies the mapping between elements of a stream to request entries that can be sent to the destination.
ResultHandler<T>	Interface to handle the result of a AsyncSinkWriter request.

Class Summary

Class	Description
AsyncSinkFatalExceptionClassifiers	Common retry exception classifiers needed for common errors.
AsyncSinkWriter<InputT,RequestEntryT extends Serializable>	A generic sink writer that handles the general behaviour of a sink such as batching and flushing, and allows extenders to implement the logic for persisting individual request elements, with allowance for retries.
AsyncSinkWriterStateSerializer<RequestEntryT extends Serializable>	Serializer class for AsyncSinkWriter state.
BufferedRequestState<RequestEntryT extends Serializable>	Class holding state of AsyncSinkWriter needed at taking a snapshot.
RequestEntryWrapper<RequestEntryT>	A wrapper that contains a RequestEntryT ready to be written by the Sink Writer class, along with the size of that entry as defined by the method getSizeInBytes(RequestEntryT) of the AsyncSinkWriter.