Just saw that there is *HDFSFileSplitter* in the library as well.
This sets *ignoreFilePatternRegularExp *to ".*._COPYING_" and
*unsupportedChar* to ":",
IMO this class should be removed as well.
Chandni
On Fri, May 6, 2016 at 4:16 PM, Chandni Singh
wrote:
> Hi,
>
> Recently there was FSFileS
Hi,
Recently there was FSFileSplitter added to Malhar library.
I have created https://issues.apache.org/jira/browse/APEXMALHAR-2081 to
remove this operator and adds its functionality to the FileSplitterInput.
The reason to do so is because this extension just adds 3 trivial features
which makes i
[
https://issues.apache.org/jira/browse/APEXMALHAR-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chandni Singh reassigned APEXMALHAR-2081:
-
Assignee: Chandni Singh
> Remove FSFileSplitter
> -
>
>
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62396322
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/function/Function.java
---
@@ -0,0 +1,76 @@
+/**
+ * Licensed to the
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62396160
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/TupleUtil.java ---
@@ -0,0 +1,31 @@
+/**
+ * Licensed to the Apache So
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62396098
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java ---
@@ -0,0 +1,246 @@
+/**
+ * Licensed to the Apache
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62395945
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java ---
@@ -0,0 +1,246 @@
+/**
+ * Licensed to the Apache
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62394942
--- Diff:
stream/src/main/java/org/apache/apex/malhar/stream/api/AggregationStream.java
---
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62394813
--- Diff: stream/pom.xml ---
@@ -0,0 +1,249 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-insta
GitHub user vrozov opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/266
Fix for LF/CR
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/incubator-apex-malhar LFCR
Alternativel
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/261#discussion_r62390825
--- Diff:
demos/wordcount/src/main/java/com/datatorrent/demos/wordcount/ApplicationWithStreamAPI.java
---
@@ -0,0 +1,58 @@
+/**
+ * Li
[
https://issues.apache.org/jira/browse/APEXMALHAR-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXMALHAR-2079:
-
Summary: FileOutputOperator expireStreamAfterAccessMillis field typo (was:
expireStr
[
https://issues.apache.org/jira/browse/APEXMALHAR-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved APEXMALHAR-2080.
--
Resolution: Fixed
> File expiration time is set too low by default in AbstractFileO
[
https://issues.apache.org/jira/browse/APEXMALHAR-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved APEXMALHAR-2079.
--
Resolution: Fixed
> expireStreamAfterAccessMillis property not getting set
> --
[
https://issues.apache.org/jira/browse/APEXMALHAR-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274681#comment-15274681
]
ASF GitHub Bot commented on APEXMALHAR-2080:
Github user asfgit closed th
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/265
---
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
[
https://issues.apache.org/jira/browse/APEXMALHAR-1995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed APEXMALHAR-1995.
Resolution: Fixed
> Upgrade Apex Core dependency to 3.3.0
> ---
+1 (binding)
- build passes with rat check and unit tests
- launched pi demo both in local mode and in cluster mode
David
On Thu, May 5, 2016 at 10:21 PM, Thomas Weise
wrote:
> Dear Community,
>
> Please vote on the following Apache Apex Core 3.4.0 release candidate.
>
> This is the first rele
[
https://issues.apache.org/jira/browse/APEXCORE-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274433#comment-15274433
]
ASF GitHub Bot commented on APEXCORE-340:
-
Github user asfgit closed the pull re
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/327
---
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 fe
[
https://issues.apache.org/jira/browse/APEXCORE-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274291#comment-15274291
]
ASF GitHub Bot commented on APEXCORE-340:
-
GitHub user tweise opened a pull requ
GitHub user tweise opened a pull request:
https://github.com/apache/incubator-apex-core/pull/327
APEXCORE-340 Fix leftover script references.
@davidyan74 merge
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tweise/incubator-apex-
22 matches
Mail list logo