[
https://issues.apache.org/jira/browse/APEXMALHAR-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323645#comment-15323645
]
ASF GitHub Bot commented on APEXMALHAR-2106:
Github user ilganeli comment
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/309#discussion_r66544129
--- Diff:
library/src/test/java/com/datatorrent/lib/stream/MultipleStreamMergerTest.java
---
@@ -0,0 +1,145 @@
+/**
+ * Licensed to the Apache
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/295#discussion_r66537334
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
---
@@ -50,17 +48,21 @@
* @since 2.1.0
[
https://issues.apache.org/jira/browse/APEXMALHAR-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323565#comment-15323565
]
ASF GitHub Bot commented on APEXMALHAR-1966:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323550#comment-15323550
]
ASF GitHub Bot commented on APEXMALHAR-1966:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/295#discussion_r66536310
--- Diff:
library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java
---
@@ -67,6 +69,9 @@ public void process(T
[
https://issues.apache.org/jira/browse/APEXMALHAR-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323536#comment-15323536
]
ASF GitHub Bot commented on APEXMALHAR-1966:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/295#discussion_r66535086
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
---
@@ -162,35 +160,75 @@ public void activate(
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r6655
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
[
https://issues.apache.org/jira/browse/APEXMALHAR-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323504#comment-15323504
]
ASF GitHub Bot commented on APEXMALHAR-1966:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/295#discussion_r66533084
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
---
@@ -162,35 +160,75 @@ public void activate(
[
https://issues.apache.org/jira/browse/APEXMALHAR-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323501#comment-15323501
]
ASF GitHub Bot commented on APEXMALHAR-1966:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/295#discussion_r66532961
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
---
@@ -162,35 +160,75 @@ public void activate(
[
https://issues.apache.org/jira/browse/APEXMALHAR-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323482#comment-15323482
]
ASF GitHub Bot commented on APEXMALHAR-2066:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/282#discussion_r66531882
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java
---
@@ -0,0 +1,652 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323455#comment-15323455
]
Chandni Singh commented on APEXMALHAR-2063:
---
[~sandesh]
You plan to keep da
[
https://issues.apache.org/jira/browse/APEXMALHAR-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323444#comment-15323444
]
ASF GitHub Bot commented on APEXMALHAR-2066:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323448#comment-15323448
]
ASF GitHub Bot commented on APEXMALHAR-2066:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323445#comment-15323445
]
ASF GitHub Bot commented on APEXMALHAR-2066:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/282#discussion_r66529201
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcMetaDataUtility.java ---
@@ -0,0 +1,344 @@
+/**
+ * Licensed to the Apache
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/282#discussion_r66529132
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcMetaDataUtility.java ---
@@ -0,0 +1,344 @@
+/**
+ * Licensed to the Apache
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/282#discussion_r66529118
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcMetaDataUtility.java ---
@@ -0,0 +1,344 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323435#comment-15323435
]
ASF GitHub Bot commented on APEXMALHAR-2066:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/282#discussion_r66527998
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java
---
@@ -0,0 +1,652 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323417#comment-15323417
]
Sandesh commented on APEXMALHAR-2063:
-
[~csingh]
If this API exists, I want to u
[
https://issues.apache.org/jira/browse/APEXMALHAR-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323414#comment-15323414
]
ASF GitHub Bot commented on APEXMALHAR-2066:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/282#discussion_r66526171
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java
---
@@ -0,0 +1,652 @@
+/**
+ * Licensed to
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/282#discussion_r66526249
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java
---
@@ -0,0 +1,652 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323411#comment-15323411
]
ASF GitHub Bot commented on APEXMALHAR-2066:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323383#comment-15323383
]
Chandni Singh commented on APEXMALHAR-2063:
---
[~sandesh]
Window Data Manager
Github user brennonyork commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66521818
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66521781
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66520504
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66520156
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66519944
--- Diff:
library/src/main/java/com/datatorrent/lib/window/TriggerOption.java ---
@@ -0,0 +1,55 @@
+package com.datatorrent.lib.window;
+
Github user brennonyork commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66519279
--- Diff:
library/src/main/java/com/datatorrent/lib/window/TriggerOption.java ---
@@ -0,0 +1,55 @@
+package com.datatorrent.lib.window;
+
Github user brennonyork commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66516800
--- Diff:
library/src/main/java/com/datatorrent/lib/window/Quantification.java ---
@@ -0,0 +1,31 @@
+package com.datatorrent.lib.window;
+
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66510097
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509870
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509670
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509566
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509455
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509417
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/CompositeStreamTransform.java
---
@@ -0,0 +1,29 @@
+/**
+ * Licensed to t
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509223
--- Diff:
stream/src/test/java/org/apache/apex/malhar/stream/sample/ApplicationWithWindowedStreamAPI.java
---
@@ -0,0 +1,41 @@
+package org.apache.
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509288
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66509305
--- Diff:
library/src/main/java/com/datatorrent/lib/window/WindowOption.java ---
@@ -0,0 +1,143 @@
+package com.datatorrent.lib.window;
+
+i
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66508572
--- Diff:
library/src/main/java/com/datatorrent/lib/window/TriggerOption.java ---
@@ -0,0 +1,55 @@
+package com.datatorrent.lib.window;
+
+i
Github user ilganeli commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66508497
--- Diff:
library/src/main/java/com/datatorrent/lib/window/Quantification.java ---
@@ -0,0 +1,31 @@
+package com.datatorrent.lib.window;
+
+
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/316#discussion_r66507851
--- Diff: stream/pom.xml ---
@@ -94,6 +94,18 @@
cglib
3.2.1
+
+
+ org.twitter4j
+
[
https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323105#comment-15323105
]
Sandesh commented on APEXMALHAR-2063:
-
[~csingh] Please let me know your take on
[
https://issues.apache.org/jira/browse/APEXMALHAR-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323080#comment-15323080
]
ASF GitHub Bot commented on APEXMALHAR-2094:
Github user sandeep-n commen
Github user sandeep-n commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/301#discussion_r66498758
--- Diff:
sketches/src/main/java/org/apache/apex/malhar/sketches/QuantilesEstimator.java
---
@@ -0,0 +1,188 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323050#comment-15323050
]
ASF GitHub Bot commented on APEXMALHAR-2094:
Github user sandeep-n commen
Github user sandeep-n commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/301#discussion_r66496208
--- Diff:
sketches/src/main/java/org/apache/apex/malhar/sketches/QuantilesEstimator.java
---
@@ -0,0 +1,188 @@
+/**
+ * Licensed to the Apache
Seems like a good idea.
Make sure that, with the new way, we can still set properties of Unifiers
too -- I saw some
special case code for that, don't recall details.
Ram
On Thu, Jun 9, 2016 at 9:04 AM, Sandesh Hegde
wrote:
> There is a parallel between StreamCodec and Unifier. As StreamCodec c
There is a parallel between StreamCodec and Unifier. As StreamCodec can be
applied on the input ports as an Attribute, having Unifier as an attribute
for the output ports completes the similarity, making it easy for app
developers.
Another reason for making it an Attribute : Unifier can be applied
56 matches
Mail list logo
