Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Won't Fix
-
0.10.0, 0.10.1, 1.0.0
-
None
Description
The DataSet API's methods collect(), count(), and print() should be mirrored to the DataStream API.
The semantics of the calls are different. We need to be able to sample parts of a stream, e.g. by supplying a time period in the arguments to the methods. Users should use the JobClient to retrieve the results.
StreamExecutionEnvironment env = StramEnvironment.getStreamExecutionEnvironment(); DataStream<DataType> streamData = env.addSource(..).map(..); JobClient jobClient = env.executeWithControl(); Iterable<DataType> sampled = jobClient.sampleStream(streamData, Time.seconds(5));
Attachments
Issue Links
- is related to
-
FLINK-4272 Create a JobClient for job control and monitoring
- Closed
-
FLINK-2313 Change Streaming Driver Execution Model
- Open