@Experimental public class DataStreamList extends Object
DataStream
, which might have different types.Constructor and Description |
---|
DataStreamList(List<org.apache.flink.streaming.api.datastream.DataStream<?>> dataStreams) |
Modifier and Type | Method and Description |
---|---|
<T> org.apache.flink.streaming.api.datastream.DataStream<T> |
get(int index)
Returns the data stream at the given index in this list.
|
List<org.apache.flink.streaming.api.datastream.DataStream<?>> |
getDataStreams()
Returns all the data streams as a native list.
|
static DataStreamList |
of(org.apache.flink.streaming.api.datastream.DataStream<?>... streams) |
int |
size()
Returns the number of data streams in this list.
|
public DataStreamList(List<org.apache.flink.streaming.api.datastream.DataStream<?>> dataStreams)
public static DataStreamList of(org.apache.flink.streaming.api.datastream.DataStream<?>... streams)
public int size()
public <T> org.apache.flink.streaming.api.datastream.DataStream<T> get(int index)
public List<org.apache.flink.streaming.api.datastream.DataStream<?>> getDataStreams()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.