Package | Description |
---|---|
org.apache.flink.streaming.api.datastream |
Modifier and Type | Method and Description |
---|---|
static <OUT> DataStreamUtils.ClientAndIterator<OUT> |
DataStreamUtils.collectWithClient(DataStream<OUT> stream,
String jobExecutionName)
Starts the execution of the program and returns an iterator to read the result of the given
data stream, plus a
JobClient to interact with the application execution. |
Modifier and Type | Method and Description |
---|---|
static <E> List<E> |
DataStreamUtils.collectRecordsFromUnboundedStream(DataStreamUtils.ClientAndIterator<E> client,
int numElements) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.