[
https://issues.apache.org/jira/browse/APEXMALHAR-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188807#comment-15188807
]
ASF GitHub Bot commented on APEXMALHAR-2008:
--------------------------------------------
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/207#discussion_r55640357
--- Diff:
library/src/test/java/com/datatorrent/lib/io/fs/FileSplitterInputTest.java ---
@@ -110,8 +110,7 @@ protected void starting(org.junit.runner.Description
description)
fileSplitterInput.setIdempotentStorageManager(new
IdempotentStorageManager.NoopIdempotentStorageManager());
Attribute.AttributeMap.DefaultAttributeMap attributes = new
Attribute.AttributeMap.DefaultAttributeMap();
- attributes.put(Context.DAGContext.APPLICATION_PATH,
- "target/" + className + "/" + methodName + "/" +
Long.toHexString(System.currentTimeMillis()));
+ attributes.put(Context.DAGContext.APPLICATION_PATH, "target/" +
className + "/" + methodName + "/" +
Long.toHexString(System.currentTimeMillis()));
--- End diff --
Please revert all the changes in this file which are not related to this
PR. Only take care of Checkstyle violations which appears in new code.
> Create hdfs file input module
> ------------------------------
>
> Key: APEXMALHAR-2008
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2008
> Project: Apache Apex Malhar
> Issue Type: Task
> Reporter: Priyanka Gugale
> Assignee: Priyanka Gugale
> Priority: Minor
> Original Estimate: 72h
> Remaining Estimate: 72h
>
> To read HDFS files in parallel using Apex we normally use FileSplitter and
> FileReader module. It would be a good idea to combine those operators as a
> unit in module. Having a module will give us readily usable set of operators
> to read HDFS files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
