Class FromDataSource<T>

  • All Implemented Interfaces:
    org.apache.flink.api.connector.dsv2.Source<T>

    @Internal
    public class FromDataSource<T>
    extends Object
    implements org.apache.flink.api.connector.dsv2.Source<T>
    DataStream v2 source that emit data from pre-provided data.
    • Constructor Detail

      • FromDataSource

        public FromDataSource​(Collection<T> data)