Package co.decodable.sdk.pipeline

Interface DecodableWriter<T>

Type Parameters:
T - Data type of the writer
All Superinterfaces:
AutoCloseable, org.apache.flink.api.connector.sink2.SinkWriter<T>, org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter<T,Object>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter<T,Object>
public interface DecodableWriter<T> extends org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter<T,Object>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter<T,Object>
Sink writer used by DecodableStreamSink.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

    org.apache.flink.api.connector.sink2.SinkWriter.Context

  • Method Summary

    Methods inherited from interface java.lang.AutoCloseable

    close

    Methods inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

    flush, write, writeWatermark

    Methods inherited from interface org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter

    snapshotState

    Methods inherited from interface org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter

    prepareCommit