Package co.decodable.sdk.pipeline

Interface DecodableStreamSink<T>

Type Parameters:
T - The data type of this stream
All Superinterfaces:
Serializable, org.apache.flink.api.connector.sink2.Sink<T>, org.apache.flink.api.connector.sink2.StatefulSink<T,Object>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<T,Object>
public interface DecodableStreamSink<T> extends org.apache.flink.api.connector.sink2.StatefulSink<T,Object>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<T,Object>
A StatefulSink which allows to write to a Decodable stream from within a Flink job. The stream must be referenced in SinkStreams to be accessible.

  • Nested Class Summary

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

    org.apache.flink.api.connector.sink2.Sink.InitContext

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

    org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter<InputT,WriterStateT>, org.apache.flink.api.connector.sink2.StatefulSink.WithCompatibleState

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

    org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T> DecodableStreamSinkBuilder<T>
    builder()
    Returns a builder for creating a new DecodableStreamSink.
    DecodableWriter<T>
    createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context)

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

    getWriterStateSerializer, restoreWriter

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

    createCommitter, getCommittableSerializer

  • Method Details

    • builder

      static <T> DecodableStreamSinkBuilder<T> builder()
      Returns a builder for creating a new DecodableStreamSink.

    • createWriter

      DecodableWriter<T> createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context) throws IOException
      Specified by:
      createWriter in interface org.apache.flink.api.connector.sink2.Sink<T>
      Specified by:
      createWriter in interface org.apache.flink.api.connector.sink2.StatefulSink<T,Object>
      Specified by:
      createWriter in interface org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<T,Object>
      Throws:
      IOException