Class FromDataSource<T>
- java.lang.Object
-
- org.apache.flink.api.connector.dsv2.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 Summary
Constructors Constructor Description FromDataSource(Collection<T> data)
-
-
-
Constructor Detail
-
FromDataSource
public FromDataSource(Collection<T> data)
-
-
Method Detail
-
getData
public Collection<T> getData()
-
-