[jira] [Commented] (APEXMALHAR-2172) Update JDBC poll input operator to fix issues

[ https://issues.apache.org/jira/browse/APEXMALHAR-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411406#comment-15411406 ] ASF GitHub Bot commented on APEXMALHAR-2172: Github user bhupeshchawda co

[GitHub] apex-malhar pull request #358: [review only]APEXMALHAR-2172: Updates to JDBC...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/358#discussion_r73828487 --- Diff: library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java --- @@ -80,201 +91,45 @@ * @tags database, sq

[GitHub] apex-malhar pull request #330: APEXMALHAR-2100 Implementation of Inner Join ...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/330#discussion_r73828318 --- Diff: library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java --- @@ -0,0 +1,248 @@ +/** + * Licensed to the Apach

[jira] [Commented] (APEXMALHAR-2100) Development of Inner Join Operator using Spillable Datastructures

[ https://issues.apache.org/jira/browse/APEXMALHAR-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411403#comment-15411403 ] ASF GitHub Bot commented on APEXMALHAR-2100: Github user chinmaykolhatkar

[jira] [Commented] (APEXMALHAR-2172) Update JDBC poll input operator to fix issues

[ https://issues.apache.org/jira/browse/APEXMALHAR-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411399#comment-15411399 ] ASF GitHub Bot commented on APEXMALHAR-2172: Github user bhupeshchawda co

[GitHub] apex-malhar pull request #358: [review only]APEXMALHAR-2172: Updates to JDBC...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/358#discussion_r73828043 --- Diff: library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java --- @@ -286,149 +141,117 @@ public AbstractJdbcPoll

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411388#comment-15411388 ] Siyuan Hua commented on APEXMALHAR-2169: [~chaithu] Then I think the proble

[jira] [Commented] (APEXMALHAR-2172) Update JDBC poll input operator to fix issues

[ https://issues.apache.org/jira/browse/APEXMALHAR-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411374#comment-15411374 ] ASF GitHub Bot commented on APEXMALHAR-2172: Github user bhupeshchawda co

[GitHub] apex-malhar pull request #358: [review only]APEXMALHAR-2172: Updates to JDBC...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/358#discussion_r73826686 --- Diff: library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java --- @@ -565,67 +379,110 @@ public void emitReplayed

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411341#comment-15411341 ] ASF GitHub Bot commented on APEXMALHAR-2169: Github user chaithu14 commen

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411342#comment-15411342 ] ASF GitHub Bot commented on APEXMALHAR-2169: Github user chaithu14 commen

[GitHub] apex-malhar pull request #351: APEXMALHAR-2169 Fixed the issue of dynamic pa...

Github user chaithu14 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/351#discussion_r73824988 --- Diff: contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java --- @@ -188,6 +188,8 @@ @Min(1) private in

[GitHub] apex-malhar pull request #351: APEXMALHAR-2169 Fixed the issue of dynamic pa...

Github user chaithu14 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/351#discussion_r73824992 --- Diff: contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java --- @@ -834,17 +840,16 @@ private boolean isPartitionReq

[jira] [Commented] (APEXMALHAR-2172) Update JDBC poll input operator to fix issues

[ https://issues.apache.org/jira/browse/APEXMALHAR-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411331#comment-15411331 ] ASF GitHub Bot commented on APEXMALHAR-2172: Github user bhupeshchawda co

[GitHub] apex-malhar pull request #358: [review only]APEXMALHAR-2172: Updates to JDBC...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/358#discussion_r73824180 --- Diff: library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java --- @@ -80,201 +91,45 @@ * @tags database, sq

[jira] [Commented] (APEXMALHAR-2172) Update JDBC poll input operator to fix issues

[ https://issues.apache.org/jira/browse/APEXMALHAR-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411322#comment-15411322 ] ASF GitHub Bot commented on APEXMALHAR-2172: Github user bhupeshchawda co

[GitHub] apex-malhar pull request #358: [review only]APEXMALHAR-2172: Updates to JDBC...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/358#discussion_r73823756 --- Diff: library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java --- @@ -80,201 +91,45 @@ * @tags database, sq

[jira] [Commented] (APEXMALHAR-1701) Deduper : create a deduper backed by Managed State

[ https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411302#comment-15411302 ] ASF GitHub Bot commented on APEXMALHAR-1701: Github user bhupeshchawda cl

[GitHub] apex-malhar pull request #343: [Review Only] APEXMALHAR-1701: Deduper using ...

Github user bhupeshchawda closed the pull request at: https://github.com/apache/apex-malhar/pull/343 --- 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 wishes so, or if the fea

[jira] [Created] (APEXMALHAR-2177) Deduper: Create a windowed dedup operator

Bhupesh Chawda created APEXMALHAR-2177: -- Summary: Deduper: Create a windowed dedup operator Key: APEXMALHAR-2177 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2177 Project: Apache Apex Mal

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1546#comment-1546 ] Siyuan Hua commented on APEXMALHAR-2169: [~chaithu] I'm still not convinced.

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1540#comment-1540 ] ASF GitHub Bot commented on APEXMALHAR-2169: Github user siyuanh commente

[GitHub] apex-malhar pull request #351: APEXMALHAR-2169 Fixed the issue of dynamic pa...

Github user siyuanh commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/351#discussion_r73811202 --- Diff: contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java --- @@ -834,17 +840,16 @@ private boolean isPartitionRequi

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411108#comment-15411108 ] ASF GitHub Bot commented on APEXMALHAR-2169: Github user siyuanh commente

[GitHub] apex-malhar pull request #351: APEXMALHAR-2169 Fixed the issue of dynamic pa...

Github user siyuanh commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/351#discussion_r73811155 --- Diff: contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java --- @@ -834,17 +840,16 @@ private boolean isPartitionRequi

[GitHub] apex-malhar pull request #324: Spillable Datastructures PR for review only

Github user ilooner commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73809225 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java --- @@ -0,0 +1,292 @@ +/** +