Uses of Interface
org.apache.flink.connector.base.sink.writer.ElementConverter
-
Packages that use ElementConverter Package Description org.apache.flink.connector.base.sink org.apache.flink.connector.base.sink.writer -
-
Uses of ElementConverter in org.apache.flink.connector.base.sink
Methods in org.apache.flink.connector.base.sink that return ElementConverter Modifier and Type Method Description protected ElementConverter<InputT,RequestEntryT>AsyncSinkBase. getElementConverter()Constructors in org.apache.flink.connector.base.sink with parameters of type ElementConverter Constructor Description AsyncSinkBase(ElementConverter<InputT,RequestEntryT> elementConverter, int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes) -
Uses of ElementConverter in org.apache.flink.connector.base.sink.writer
Constructors in org.apache.flink.connector.base.sink.writer with parameters of type ElementConverter Constructor Description AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, org.apache.flink.api.connector.sink2.Sink.InitContext context, int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes)Deprecated.AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, org.apache.flink.api.connector.sink2.Sink.InitContext context, int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes, Collection<BufferedRequestState<RequestEntryT>> states)Deprecated.AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, org.apache.flink.api.connector.sink2.Sink.InitContext context, AsyncSinkWriterConfiguration configuration, Collection<BufferedRequestState<RequestEntryT>> states)Deprecated.AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, org.apache.flink.api.connector.sink2.WriterInitContext context, AsyncSinkWriterConfiguration configuration, Collection<BufferedRequestState<RequestEntryT>> states)
-