Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73103038
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403502#comment-15403502
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73104101
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403513#comment-15403513
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73112564
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403597#comment-15403597
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73114470
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperTimeBasedPOJOImpl.java
---
@@ -0,0 +1,209 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403615#comment-15403615
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73115138
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apa
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73115095
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperTimeBasedPOJOImpl.java
---
@@ -0,0 +1,209 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403622#comment-15403622
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403623#comment-15403623
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73115146
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperTimeBasedPOJOImpl.java
---
@@ -0,0 +1,209 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403624#comment-15403624
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73132123
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,463 @@
+/**
+ * Licensed to the Apache
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73132107
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403746#comment-15403746
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403745#comment-15403745
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403750#comment-15403750
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73132603
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403751#comment-15403751
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73132546
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apache
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73134200
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403766#comment-15403766
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73134312
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperStreamCodec.java
---
@@ -0,0 +1,45 @@
+/**
+ * Licensed to the
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403767#comment-15403767
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73134653
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperStreamCodec.java
---
@@ -0,0 +1,45 @@
+/**
+ * Licensed to the
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403768#comment-15403768
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73139012
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apache
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73138996
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperStreamCodec.java
---
@@ -0,0 +1,45 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403802#comment-15403802
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73139110
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,462 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403801#comment-15403801
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403808#comment-15403808
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403809#comment-15403809
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73139258
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apa
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73141100
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java
---
@@ -0,0 +1,171 @@
+/**
+ * Licensed t
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73141070
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperIdempotencyTest.java
---
@@ -0,0 +1,132 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403837#comment-15403837
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403836#comment-15403836
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73141245
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperIdempotencyTest.java
---
@@ -0,0 +1,132 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403840#comment-15403840
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141485
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141506
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141502
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141529
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403849#comment-15403849
]
ASF GitHub Bot commented on APEXMALHAR-2100:
Github user chaithu14 commen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403848#comment-15403848
]
ASF GitHub Bot commented on APEXMALHAR-2100:
Github user chaithu14 commen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403845#comment-15403845
]
ASF GitHub Bot commented on APEXMALHAR-2100:
Github user chaithu14 commen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403847#comment-15403847
]
ASF GitHub Bot commented on APEXMALHAR-2100:
Github user chaithu14 commen
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73141988
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperStreamCodec.java
---
@@ -0,0 +1,45 @@
+/**
+ * Licensed to the Apa
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73142080
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403857#comment-15403857
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403858#comment-15403858
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73142228
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403862#comment-15403862
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73142273
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apa
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73142337
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403864#comment-15403864
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403863#comment-15403863
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73142554
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403869#comment-15403869
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73142614
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403871#comment-15403871
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73142681
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403872#comment-15403872
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user chinmaykolhatkar
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73145124
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403891#comment-15403891
]
ASF GitHub Bot commented on APEXMALHAR-2100:
Github user chaithu14 commen
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73155029
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperIdempotencyTest.java
---
@@ -0,0 +1,132 @@
+/**
+ * Licensed to th
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403963#comment-15403963
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73156746
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java
---
@@ -0,0 +1,171 @@
+/**
+ * Licensed to t
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73156767
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperIdempotencyTest.java
---
@@ -0,0 +1,132 @@
+/**
+ * Licensed to th
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403977#comment-15403977
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403976#comment-15403976
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73160437
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apache
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73160450
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404025#comment-15404025
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404024#comment-15404024
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73160639
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apache
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73160600
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404029#comment-15404029
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73160693
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404030#comment-15404030
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404032#comment-15404032
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/335#discussion_r73161100
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java ---
@@ -0,0 +1,459 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404037#comment-15404037
]
ASF GitHub Bot commented on APEXMALHAR-1701:
Github user bhupeshchawda co
Should Apex add JAVA_HOME to DAGContext and allow application to specify
which JDK to use if there are multiple JDK installations on Hadoop
cluster? Yarn already supports custom JAVA_HOME (please see
https://issues.apache.org/jira/browse/YARN-2481).
Vlad
Github user sandeshh commented on the issue:
https://github.com/apache/apex-core/pull/360
@davidyan74 Please review.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and w
[
https://issues.apache.org/jira/browse/APEXCORE-495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404942#comment-15404942
]
ASF GitHub Bot commented on APEXCORE-495:
-
Github user sandeshh commented on the
How about allowing specification of all environment variables supported by
YARN that are non-final described below
http://atetric.com/atetric/javadoc/org.apache.hadoop/hadoop-yarn-api/0.23.3/org/apache/hadoop/yarn/api/ApplicationConstants.Environment.html
Thanks
On Tue, Aug 2, 2016 at 3:43 PM, V
Sanjay M Pujare created APEXMALHAR-2173:
---
Summary: add a constraint validation for subject in JMSBase
Key: APEXMALHAR-2173
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2173
Project: Apac
Pramod Immaneni created APEXCORE-500:
Summary: Allow specification of non-heap memory size
Key: APEXCORE-500
URL: https://issues.apache.org/jira/browse/APEXCORE-500
Project: Apache Apex Core
[
https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15405327#comment-15405327
]
ASF GitHub Bot commented on APEXCORE-448:
-
Github user chandnisingh commented on
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73281443
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout)
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73281761
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,247 @@
+/**
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15405330#comment-15405330
]
ASF GitHub Bot commented on APEXMALHAR-2100:
Github user chaithu14 commen
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73281797
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractManagedStateInnerJoinOperator.java
---
@@ -0,0 +1,265 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15405331#comment-15405331
]
ASF GitHub Bot commented on APEXMALHAR-2100:
Github user chaithu14 commen
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73281978
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout)
[
https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15405334#comment-15405334
]
ASF GitHub Bot commented on APEXCORE-448:
-
Github user chandnisingh commented on
1 - 100 of 106 matches
Mail list logo