Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r63074921
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java
---
@@ -0,0 +1,457 @@
+/**
+ * Licens
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r63074486
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/AggregationStream.java
---
@@ -0,0 +1,35 @@
+/**
+ * Licensed
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r63073665
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java
---
@@ -0,0 +1,457 @@
+/**
+ * Licensed to
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r63073461
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/AggregationStream.java
---
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62950721
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java
---
@@ -0,0 +1,457 @@
+/**
+ * Licens
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62949738
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/AggregationStream.java
---
@@ -0,0 +1,35 @@
+/**
+ * Licensed
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62949394
--- Diff:
demos/wordcount/src/test/java/com/datatorrent/demos/wordcount/LocalTestWithoutStreamApplication.java
---
@@ -0,0 +1,48 @@
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62949339
--- Diff:
demos/wordcount/src/test/java/com/datatorrent/demos/wordcount/ApplicationWithStreamAPITest.java
---
@@ -0,0 +1,49 @@
+/**
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62396322
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/function/Function.java
---
@@ -0,0 +1,76 @@
+/**
+ * Licensed to the
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62396160
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/TupleUtil.java ---
@@ -0,0 +1,31 @@
+/**
+ * Licensed to the Apache So
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62396098
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java ---
@@ -0,0 +1,246 @@
+/**
+ * Licensed to the Apache
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62395945
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java ---
@@ -0,0 +1,246 @@
+/**
+ * Licensed to the Apache
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62394942
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/AggregationStream.java
---
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62394813
--- Diff: stream/pom.xml ---
@@ -0,0 +1,249 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-insta
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62390825
--- Diff:
demos/wordcount/src/main/java/com/datatorrent/demos/wordcount/ApplicationWithStreamAPI.java
---
@@ -0,0 +1,58 @@
+/**
+ * Li
GitHub user siyuanh opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/261
Stream API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/siyuanh/incubator-apex-malhar stream
Alternatively you can review an
16 matches
Mail list logo
