DataStreamV2SourceUtils (Flink : Core 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.api.connector.dsv2.DataStreamV2SourceUtils

@Experimental
public final class DataStreamV2SourceUtils
extends Object

Utils to create the DataStream V2 supported Source.

Constructor Summary

Constructors
Constructor Description

DataStreamV2SourceUtils()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static <T> org.apache.flink.api.connector.dsv2.Source<T>`	`fromData(Collection<T> data)`	Creates a source that contains the given elements.The type of the data stream is that of the elements in the collection.
`static <T> org.apache.flink.api.connector.dsv2.Source<T>`	`wrapSource(Source<T,?,?> source)`	Wrap a FLIP-27 based source to a DataStream V2 supported source.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DataStreamV2SourceUtils
```
public DataStreamV2SourceUtils()
```
- Method Detail
  - wrapSource
```
public static <T> org.apache.flink.api.connector.dsv2.Source<T> wrapSource(Source<T,?,?> source)
```
    Wrap a FLIP-27 based source to a DataStream V2 supported source.
    
    Parameters:
    
    source - The FLIP-27 based source to wrap.
    
    Returns:
    
    The DataStream V2 supported source.
  - fromData
```
public static <T> org.apache.flink.api.connector.dsv2.Source<T> fromData(Collection<T> data)
```
    Creates a source that contains the given elements.The type of the data stream is that of the elements in the collection.
    
    Type Parameters:
    
    T - The generic type of the returned data stream.
    
    Parameters:
    
    data - The collection of elements to create the source from.
    
    Returns:
    
    The source representing the given collection