Package org.apache.flink.connector.base.sink
-
Class Summary Class Description AsyncSinkBase<InputT,RequestEntryT extends Serializable> A generic sink for destinations that provide an async client to persist data.AsyncSinkBaseBuilder<InputT,RequestEntryT extends Serializable,ConcreteBuilderT extends AsyncSinkBaseBuilder<?,?,?>> Abstract builder for constructing a concrete implementation ofAsyncSinkBase.