Package co.decodable.sdk.pipeline

Interface DecodableStreamSource<T>

Type Parameters:
T - The data type of this stream
All Superinterfaces:
org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, Serializable, org.apache.flink.api.connector.source.Source<T,DecodableSourceSplit,DecodableSourceEnumeratorState>
public interface DecodableStreamSource<T> extends org.apache.flink.api.connector.source.Source<T,DecodableSourceSplit,DecodableSourceEnumeratorState>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
A Source which allows to retrieve the contents of a Decodable stream from within a Flink job. The stream must be referenced in SourceStreams to be accessible.

  • Method Summary

    Static Methods
    Modifier and Type
    Method
    Description
    static <T> DecodableStreamSourceBuilder<T>
    builder()
    Returns a builder for creating a new DecodableStreamSource.

    Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

    getProducedType

    Methods inherited from interface org.apache.flink.api.connector.source.Source

    createEnumerator, createReader, getBoundedness, getEnumeratorCheckpointSerializer, getSplitSerializer, restoreEnumerator