You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/05/09 17:57:17 UTC
flink git commit: [streaming] Made constructor of GroupedDataStream
public
Repository: flink
Updated Branches:
refs/heads/master bc8f1978c -> 170366c90
[streaming] Made constructor of GroupedDataStream public
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/170366c9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/170366c9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/170366c9
Branch: refs/heads/master
Commit: 170366c9003424f3847d2658df6f29d2f63c3e2c
Parents: bc8f197
Author: mbalassi <mb...@apache.org>
Authored: Fri May 8 12:15:12 2015 +0200
Committer: mbalassi <mb...@apache.org>
Committed: Sat May 9 17:53:53 2015 +0200
----------------------------------------------------------------------
.../flink/streaming/api/datastream/GroupedDataStream.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/170366c9/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
index 64d546a..91b22a2 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
@@ -42,7 +42,14 @@ public class GroupedDataStream<OUT> extends DataStream<OUT> {
KeySelector<OUT, ?> keySelector;
- protected GroupedDataStream(DataStream<OUT> dataStream, KeySelector<OUT, ?> keySelector) {
+ /**
+ * Creates a new {@link GroupedDataStream}, group inclusion is determined using
+ * a {@link KeySelector} on the elements of the {@link DataStream}.
+ *
+ * @param dataStream Base stream of data
+ * @param keySelector Function for determining group inclusion
+ */
+ public GroupedDataStream(DataStream<OUT> dataStream, KeySelector<OUT, ?> keySelector) {
super(dataStream.partitionBy(keySelector));
this.keySelector = keySelector;
}