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.SupportsCommitter<Object>, org.apache.flink.api.connector.sink2.SupportsWriterState<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, org.apache.flink.api.connector.sink2.Sink.InitContextWrapper

    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.Sink

    createWriter

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

    restoreWriter, restoreWriter

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

    getCommittableSerializer

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

    getWriterStateSerializer

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

    createCommitter, createCommitter