[
https://issues.apache.org/jira/browse/APEXMALHAR-2126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15356525#comment-15356525
]
Vlad Rozov commented on APEXMALHAR-2126:
Why is it necessary to have Slice he
[
https://issues.apache.org/jira/browse/APEXMALHAR-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15356375#comment-15356375
]
ASF GitHub Bot commented on APEXMALHAR-2069:
Github user vrozov commented
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/329#discussion_r69063970
--- Diff:
library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java ---
@@ -318,6 +317,9 @@ public TimeBasedDirectoryScanner()
@Over
[
https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15356342#comment-15356342
]
Thomas Weise commented on APEXMALHAR-2130:
--
What's the use case? I think thi
[
https://issues.apache.org/jira/browse/APEXMALHAR-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15356287#comment-15356287
]
ASF GitHub Bot commented on APEXMALHAR-2069:
GitHub user sanjaypujare ope
GitHub user sanjaypujare opened a pull request:
https://github.com/apache/apex-malhar/pull/329
Fix for APEXMALHAR-2069: moved creation of scanService to setup, @vroâ¦
@vrozov pls review.
You can merge this pull request into a Git repository by running:
$ git pull https://gith
Is there a way to get results for number of downloads by version of Apache
Apex from apex.apache.org?
Doesn't matter if it's done via Google Analytics, or by looking at web
server logs. Just wanted to know if this is possible, how to get
access/display this data on the site, and how other Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15356232#comment-15356232
]
bright chen commented on APEXMALHAR-2130:
-
Here are some of thoughts:
There a
bright chen created APEXMALHAR-2130:
---
Summary: implement scalable windowed storage
Key: APEXMALHAR-2130
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2130
Project: Apache Apex Malhar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355935#comment-15355935
]
ASF GitHub Bot commented on APEXMALHAR-2116:
Github user amberarrow comme
Github user amberarrow commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/326#discussion_r69042882
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java
---
@@ -0,0 +1,332 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355930#comment-15355930
]
ASF GitHub Bot commented on APEXMALHAR-2116:
Github user amberarrow comme
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355929#comment-15355929
]
ASF GitHub Bot commented on APEXMALHAR-2116:
Github user amberarrow comme
Github user amberarrow commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/326#discussion_r69042391
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java
---
@@ -0,0 +1,332 @@
+/**
+ * Licensed to the Apache
Github user amberarrow commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/326#discussion_r69042316
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java
---
@@ -0,0 +1,332 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355924#comment-15355924
]
ASF GitHub Bot commented on APEXMALHAR-2116:
Github user amberarrow comme
Github user amberarrow commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/326#discussion_r69041055
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java
---
@@ -0,0 +1,332 @@
+/**
+ * Licensed to the Apache
I believe it's because different types of sinks can get plugged in
depending on how the operators are deployed. If the operator and its
downstream operator are in same container it is a queue otherwise it
is a publisher to buffer server that is serializing the data
generically independent of the da
Siyuan,
I am not able to remember right now. Chetan or Thomas may remember. Even
casting a tuple from upstream port or to downstream port it should work if
both the above apis are . As of today, I cannot see a reason why we did
this.
Thks
Amol
On Wed, Jun 29, 2016 at 1:41 PM, Siyuan Hua wrote:
The setSink method on OutputPort takes Sink
But the getSink method on InputPort returns a Sink
Is there a reason for this asymmetric API ?
Regards,
Siyuan
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355507#comment-15355507
]
Chandni Singh commented on APEXMALHAR-2129:
---
[~bhupesh] I re-opened the tic
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chandni Singh updated APEXMALHAR-2129:
--
Description: Have an option that can disable purging of data. (was:
TimeBucketAssi
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chandni Singh updated APEXMALHAR-2129:
--
Priority: Major (was: Minor)
> ManagedState: Add a disable purging option
> --
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chandni Singh updated APEXMALHAR-2129:
--
Summary: ManagedState: Add a disable purging option (was: Introduce option
to adva
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chandni Singh reopened APEXMALHAR-2129:
---
Assignee: Chandni Singh (was: Bhupesh Chawda)
> ManagedState: Add a disable pu
Hi Thomas,
I agree that the case of processing bounded data is a special case of
unbounded data.
Th difference I was pointing out was in terms of expiry. This is not
applicable in case of bounded data sets, while unbounded data sets will
inherently use expiry for limiting the amount of data to be
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/294#discussion_r68977507
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractTupleUniqueExactlyOnceKafkaOutputOperator.java
---
@@ -0,0 +1,610 @@
+/**
Bhupesh,
Why is there a distinction between bounded and unbounded data? I see the
former as a special case of the latter?
When rewinding the stream or reprocessing the stream in another run the
operator should produce the same result.
This operator should be idempotent also. That implies that co
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355324#comment-15355324
]
Chandni Singh commented on APEXMALHAR-2129:
---
I am not disagreeing with your
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355202#comment-15355202
]
ASF GitHub Bot commented on APEXMALHAR-2116:
GitHub user yogidevendra reo
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355201#comment-15355201
]
ASF GitHub Bot commented on APEXMALHAR-2116:
Github user yogidevendra clo
GitHub user yogidevendra reopened a pull request:
https://github.com/apache/apex-malhar/pull/326
APEXMALHAR-2116 Added FS record reader operator, module, test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yogidevendra/apex-malh
Github user yogidevendra closed the pull request at:
https://github.com/apache/apex-malhar/pull/326
---
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 feat
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355113#comment-15355113
]
ASF GitHub Bot commented on APEXMALHAR-2116:
Github user yogidevendra clo
[
https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355114#comment-15355114
]
ASF GitHub Bot commented on APEXMALHAR-2116:
GitHub user yogidevendra reo
GitHub user yogidevendra reopened a pull request:
https://github.com/apache/apex-malhar/pull/326
APEXMALHAR-2116 Added FS record reader operator, module, test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yogidevendra/apex-malh
Github user yogidevendra closed the pull request at:
https://github.com/apache/apex-malhar/pull/326
---
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 feat
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhupesh Chawda closed APEXMALHAR-2129.
--
Resolution: Invalid
> Introduce option to advance time through Expiry task in TimeB
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355051#comment-15355051
]
Bhupesh Chawda commented on APEXMALHAR-2129:
Okay. I agree about the boun
Hi All,
I want to validate the use cases for de-duplication that will be going as
part of this implementation.
- *Bounded data set*
- This is de-duplication for bounded data. For example, data sets
which are old or fixed or which may not have a time field at
all. Example:
Las
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68926798
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,241 @@
+package
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68926769
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,241 @@
+package
[
https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15354726#comment-15354726
]
Chandni Singh commented on APEXMALHAR-2129:
---
[~bhupesh] Purging is tied at
43 matches
Mail list logo
