[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16130020#comment-16130020
]
Evgeny Kincharov commented on FLINK-3133:
-----------------------------------------
[~gaborhermann], [~aljoscha] thanks for Interest this.
This issue is blocked by FLINK-2313 and FLINK-4272.
The main idea is this issue is useless without a possibility of a nonblocking
execution.
I have implemented a scetch of a nonblocking execution (just for testing this
issue) [here|https://github.com/kenmy/flink/tree/FLINK-3133_temp].
But it is not within a scope of this issue.
As far as I remember "print" method was worked in my test cases.
It's about what was done. As for what should be done I agree with [~aljoscha]
the nonblocking execution may made the streaming API too complex.
>From this point of view the approach with "Future" is a lot more useful here.
[~gaborhermann] if you want you may assign this issue to you and continue work
on it. I don't mind. I can rebase my changes to current master if you want to
use they.
> Introduce collect()/count()/print() methods in DataStream API
> -------------------------------------------------------------
>
> Key: FLINK-3133
> URL: https://issues.apache.org/jira/browse/FLINK-3133
> Project: Flink
> Issue Type: Improvement
> Components: DataStream API
> Affects Versions: 0.10.0, 1.0.0, 0.10.1
> Reporter: Maximilian Michels
> Assignee: Evgeny Kincharov
> Fix For: 1.0.0
>
>
> 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.
> {code:java}
> StreamExecutionEnvironment env =
> StramEnvironment.getStreamExecutionEnvironment();
> DataStream<DataType> streamData = env.addSource(..).map(..);
> JobClient jobClient = env.executeWithControl();
> Iterable<DataType> sampled = jobClient.sampleStream(streamData,
> Time.seconds(5));
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
