[GitHub] apex-site pull request #46: update docs to add a blog link

GitHub user ashwinchandrap opened a pull request: https://github.com/apache/apex-site/pull/46 update docs to add a blog link You can merge this pull request into a Git repository by running: $ git pull https://github.com/ashwinchandrap/apex-site patch-3 Alternatively you can

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

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

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

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

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

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

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

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

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

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

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

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

[GitHub] apex-core pull request #364: APEXCORE-448 Made operator name available in op...

Github user vrozov commented on a diff in the pull request: https://github.com/apache/apex-core/pull/364#discussion_r73068052 --- Diff: engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java --- @@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout)

[jira] [Commented] (APEXCORE-448) Make operator name available in OperatorContext

[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402987#comment-15402987 ] ASF GitHub Bot commented on APEXCORE-448: - Github user sandeshh commented on a diff in the pull

[GitHub] apex-core pull request #364: APEXCORE-448 Made operator name available in op...

Github user sandeshh commented on a diff in the pull request: https://github.com/apache/apex-core/pull/364#discussion_r73067721 --- Diff: api/src/main/java/com/datatorrent/api/Context.java --- @@ -328,6 +328,8 @@ */ int getWindowsFromCheckpoint(); +

[jira] [Commented] (APEXCORE-448) Make operator name available in OperatorContext

[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402975#comment-15402975 ] ASF GitHub Bot commented on APEXCORE-448: - Github user vrozov commented on a diff in the pull

[GitHub] apex-core pull request #364: APEXCORE-448 Made operator name available in op...

Github user vrozov commented on a diff in the pull request: https://github.com/apache/apex-core/pull/364#discussion_r73066955 --- Diff: engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java --- @@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout)

[jira] [Commented] (APEXCORE-448) Make operator name available in OperatorContext

[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402971#comment-15402971 ] ASF GitHub Bot commented on APEXCORE-448: - Github user chandnisingh commented on a diff in the

[jira] [Commented] (APEXCORE-448) Make operator name available in OperatorContext

[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402972#comment-15402972 ] ASF GitHub Bot commented on APEXCORE-448: - Github user vrozov commented on a diff in the pull

[GitHub] apex-core pull request #364: APEXCORE-448 Made operator name available in op...

Github user vrozov commented on a diff in the pull request: https://github.com/apache/apex-core/pull/364#discussion_r73066772 --- Diff: api/src/main/java/com/datatorrent/api/Context.java --- @@ -328,6 +328,8 @@ */ int getWindowsFromCheckpoint(); +

[GitHub] apex-core pull request #364: APEXCORE-448 Made operator name available in op...

Github user vrozov commented on a diff in the pull request: https://github.com/apache/apex-core/pull/364#discussion_r73065873 --- Diff: api/src/main/java/com/datatorrent/api/Context.java --- @@ -328,6 +328,8 @@ */ int getWindowsFromCheckpoint(); +

[jira] [Commented] (APEXCORE-448) Make operator name available in OperatorContext

[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402956#comment-15402956 ] ASF GitHub Bot commented on APEXCORE-448: - Github user vrozov commented on a diff in the pull

[jira] [Assigned] (APEXMALHAR-2044) Exception in AbstractFileOutputOperator during write.

[ https://issues.apache.org/jira/browse/APEXMALHAR-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Velineni Lakshmi Prasanna reassigned APEXMALHAR-2044: - Assignee: Velineni Lakshmi Prasanna > Exception in

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

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

[jira] [Updated] (APEXMALHAR-2044) Exception in AbstractFileOutputOperator during write.

[ https://issues.apache.org/jira/browse/APEXMALHAR-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2044: -- Assignee: (was: Chandni Singh) > Exception in AbstractFileOutputOperator

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032779 --- Diff: library/src/test/java/org/apache/apex/malhar/lib/state/spillable/inmem/InMemorySpillableStateStoreTest.java --- @@ -0,0 +1,63 @@ +/**

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032644 --- Diff: library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableComplexComponentImplTest.java --- @@ -0,0 +1,88 @@ +/**

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032590 --- Diff: library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteMapImplTest.java --- @@ -0,0 +1,487 @@ +/** + *

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032527 --- Diff: library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImplTest.java --- @@ -0,0 +1,344 @@

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032414 --- Diff: library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SequentialSpillableIdentifierGeneratorTest.java --- @@ -0,0 +1,128 @@

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032354 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SliceUtils.java --- @@ -0,0 +1,70 @@ +/** + * Licensed to the Apache

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032245 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerdeListSlice.java --- @@ -0,0 +1,103 @@ +/** + * Licensed to the

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

Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/324#discussion_r73032134 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruByteArraySliceSerde.java --- @@ -0,0 +1,55 @@ +/** + *

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

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

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

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

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

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

[GitHub] apex-malhar pull request #345: APEXMALHAR-2130 REVIEW ONLY (WindowedOperator...

Github user davidyan74 closed the pull request at: https://github.com/apache/apex-malhar/pull/345 --- 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

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402480#comment-15402480 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user sanjaypujare commented on a diff

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402476#comment-15402476 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user sanjaypujare commented on a diff

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402475#comment-15402475 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user sanjaypujare commented on a diff

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user sanjaypujare commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r73019499 --- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java --- @@ -143,7 +172,7 @@ public void

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user sanjaypujare commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r73017855 --- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java --- @@ -76,18 +76,52 @@ private transient Session session;

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402456#comment-15402456 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user sanjaypujare commented on a diff

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user sanjaypujare commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r73017194 --- Diff: contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java --- @@ -250,12 +250,7 @@ public void

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user sanjaypujare commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r73017452 --- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java --- @@ -76,18 +76,52 @@ private transient Session session;

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402274#comment-15402274 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user PramodSSImmaneni commented on a

[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=15402256#comment-15402256 ] ASF GitHub Bot commented on APEXMALHAR-1701: Github user chinmaykolhatkar commented on a

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72998669 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperTimeBasedPOJOImpl.java --- @@ -0,0 +1,209 @@ +/** + * Licensed

[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=15402252#comment-15402252 ] ASF GitHub Bot commented on APEXMALHAR-1701: Github user chinmaykolhatkar commented on a

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72998388 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperTimeBasedPOJOImpl.java --- @@ -0,0 +1,209 @@ +/** + * Licensed

[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=15402241#comment-15402241 ] ASF GitHub Bot commented on APEXMALHAR-1701: Github user chinmaykolhatkar commented on a

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72997448 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java --- @@ -0,0 +1,462 @@ +/** + * Licensed to the

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72997177 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java --- @@ -0,0 +1,462 @@ +/** + * Licensed to the

[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=15402236#comment-15402236 ] ASF GitHub Bot commented on APEXMALHAR-1701: Github user chinmaykolhatkar commented on a

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402219#comment-15402219 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user PramodSSImmaneni commented on a

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user PramodSSImmaneni commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r72995064 --- Diff: stream/src/test/java/org/apache/apex/malhar/stream/FunctionOperator/FunctionOperatorTest.java --- @@ -1,332 +0,0 @@ -/** ---

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402217#comment-15402217 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user PramodSSImmaneni commented on a

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user PramodSSImmaneni commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r72994883 --- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java --- @@ -76,18 +76,52 @@ private transient Session session;

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402211#comment-15402211 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user PramodSSImmaneni commented on a

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user PramodSSImmaneni commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r72994523 --- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java --- @@ -143,7 +172,7 @@ public void

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72994134 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java --- @@ -0,0 +1,462 @@ +/** + * Licensed to the

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user PramodSSImmaneni commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r72993901 --- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java --- @@ -76,18 +76,52 @@ private transient Session session;

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402206#comment-15402206 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user PramodSSImmaneni commented on a

[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=15402197#comment-15402197 ] ASF GitHub Bot commented on APEXMALHAR-1701: Github user chinmaykolhatkar commented on a

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72993201 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java --- @@ -0,0 +1,462 @@ +/** + * Licensed to the

[jira] [Commented] (APEXMALHAR-2156) JMS Input operator enhancements

[ https://issues.apache.org/jira/browse/APEXMALHAR-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402171#comment-15402171 ] ASF GitHub Bot commented on APEXMALHAR-2156: Github user PramodSSImmaneni commented on a

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user PramodSSImmaneni commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r72991746 --- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java --- @@ -76,18 +76,52 @@ private transient Session session;

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72991555 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/AbstractDeduper.java --- @@ -0,0 +1,462 @@ +/** + * Licensed to the

[GitHub] apex-malhar pull request #347: APEXMALHAR-2156 changes

Github user PramodSSImmaneni commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/347#discussion_r72991276 --- Diff: contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java --- @@ -250,12 +250,7 @@ public void

[GitHub] apex-malhar pull request #335: [Review Only] APEXMALHAR-1701 Deduper with Ma...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/335#discussion_r72989366 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/dedup/DeduperTimeBasedPOJOImpl.java --- @@ -0,0 +1,209 @@ +/** + * Licensed

[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=15402141#comment-15402141 ] ASF GitHub Bot commented on APEXMALHAR-1701: Github user chinmaykolhatkar commented on a

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

[ https://issues.apache.org/jira/browse/APEXMALHAR-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401981#comment-15401981 ] ASF GitHub Bot commented on APEXMALHAR-2153: GitHub user chinmaykolhatkar reopened a pull

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

GitHub user chinmaykolhatkar reopened a pull request: https://github.com/apache/apex-malhar/pull/353 APEXMALHAR-2153 Adding user docs for POJOEnricher. @bhupeshchawda Please review and merge. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

[ https://issues.apache.org/jira/browse/APEXMALHAR-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401980#comment-15401980 ] ASF GitHub Bot commented on APEXMALHAR-2153: Github user chinmaykolhatkar closed the pull

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user chinmaykolhatkar closed the pull request at: https://github.com/apache/apex-malhar/pull/353 --- 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

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

[ https://issues.apache.org/jira/browse/APEXMALHAR-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401976#comment-15401976 ] ASF GitHub Bot commented on APEXMALHAR-2153: Github user chinmaykolhatkar closed the pull

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user chinmaykolhatkar closed the pull request at: https://github.com/apache/apex-malhar/pull/353 --- 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

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

[ https://issues.apache.org/jira/browse/APEXMALHAR-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401977#comment-15401977 ] ASF GitHub Bot commented on APEXMALHAR-2153: GitHub user chinmaykolhatkar reopened a pull

Re: APEXCORE-408 : Ability to schedule Sub-DAG from running application

Hi All, I was able to prototype an simple word count application, which will start with just a single file reader operator. File reader operator will emit pendingFiles as metric to StatsListener. The statslistener will change DAG once enough files are available. The listener will return plan

[jira] [Commented] (APEXMALHAR-2129) ManagedState: Add a disable purging option

[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401886#comment-15401886 ] Bhupesh Chawda commented on APEXMALHAR-2129: As discussed on dev@apex, we are proceeding

[jira] [Updated] (APEXCORE-408) Ability to schedule Sub-DAG from running application

[ https://issues.apache.org/jira/browse/APEXCORE-408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tushar Gosavi updated APEXCORE-408: --- Attachment: Dynamic DAG Changes.docx Adding document. > Ability to schedule Sub-DAG from

Re: Need suggestion on jooq ASL License

jooq library I am using is ASL licensed: https://mvnrepository.com/artifact/org.jooq/jooq/3.6.4 It does not add any extra dependency, output part of maven dependencies: [INFO] +- joda-time:joda-time:jar:2.9.1:compile [INFO] +- it.unimi.dsi:fastutil:jar:7.0.6:compile [INFO] +-

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

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

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

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

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/353#discussion_r72931886 --- Diff: docs/operators/enricher.md --- @@ -0,0 +1,169 @@ +POJO Enricher += + +## Operator Objective +This

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/353#discussion_r72931853 --- Diff: docs/operators/enricher.md --- @@ -0,0 +1,169 @@ +POJO Enricher += + +## Operator Objective +This

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user chinmaykolhatkar commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/353#discussion_r72931450 --- Diff: docs/operators/enricher.md --- @@ -0,0 +1,169 @@ +POJO Enricher += + +## Operator Objective +This

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

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

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/353#discussion_r72930798 --- Diff: docs/operators/enricher.md --- @@ -0,0 +1,169 @@ +POJO Enricher += + +## Operator Objective +This

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

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

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/353#discussion_r72930763 --- Diff: docs/operators/enricher.md --- @@ -0,0 +1,169 @@ +POJO Enricher += + +## Operator Objective +This

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

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

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/353#discussion_r72930659 --- Diff: docs/operators/enricher.md --- @@ -0,0 +1,169 @@ +POJO Enricher += + +## Operator Objective +This

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

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

[GitHub] apex-malhar pull request #353: APEXMALHAR-2153 Adding user docs for POJOEnri...

Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/353#discussion_r72930589 --- Diff: docs/operators/enricher.md --- @@ -0,0 +1,169 @@ +POJO Enricher += + +## Operator Objective +This

[jira] [Commented] (APEXMALHAR-2153) Add user documentation for Enricher on apex docs

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

Re: Malhar 3.5.0 release

APEXMALHAR-2128 is already done. Somehow the status did not go to resolved. Changed it now. On Fri, Jul 29, 2016 at 1:53 PM, Yogi Devendra wrote: > APEXMALHAR-2116 > https://github.com/apache/apex-malhar/pull/326 > > @Ram > Your review comments are incorporated.

[jira] [Commented] (APEXMALHAR-2161) Add tests for AbstractThroughputFileInputOperator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401585#comment-15401585 ] ASF GitHub Bot commented on APEXMALHAR-2161: GitHub user DT-Priyanka opened a pull

[GitHub] apex-malhar pull request #359: APEXMALHAR-2161: Add tests for AbstractThroug...

GitHub user DT-Priyanka opened a pull request: https://github.com/apache/apex-malhar/pull/359 APEXMALHAR-2161: Add tests for AbstractThroughputFileInputOperator Added unit tests for AbstractThroughputFileInputOperator class You can merge this pull request into a Git repository by

Need suggestion on jooq ASL License

Hi, I have used jooq library (ASL licensed) in new updates to JDBC input operator. Here is the licensing information of library: http://www.jooq .org/legal/licensing License says it *depends but doesn't bundle* those non ASL license dependencies. As per my understanding those will be included

Re: Using DSL api to construct sql queries

Hi, Does anyone has inputs on licensing part? I will start a new mail thread to discuss that issue separately. -Priyanka On Fri, Jul 22, 2016 at 11:58 PM, Pradeep A. Dalvi wrote: > +1 From what I read, this change is completely backword compatible. > > --prad > > On Thu, Jul

[jira] [Commented] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401564#comment-15401564 ] ASF GitHub Bot commented on APEXCORE-494: - Github user chaithu14 commented on the issue: