You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Munagala V. Ramanath (JIRA)" <ji...@apache.org> on 2016/02/15 02:26:18 UTC

[jira] [Created] (APEXCORE-343) Add property to AbstractFileInputOperator to trim processedFiles and ignoredFiles

Munagala V. Ramanath created APEXCORE-343:
---------------------------------------------

             Summary: Add property to AbstractFileInputOperator to trim processedFiles and ignoredFiles
                 Key: APEXCORE-343
                 URL: https://issues.apache.org/jira/browse/APEXCORE-343
             Project: Apache Apex Core
          Issue Type: Improvement
    Affects Versions: 3.3.0
            Reporter: Munagala V. Ramanath
            Assignee: Munagala V. Ramanath


In AbstractFileInputOperator, the processedFiles and DirectoryScanner.ignoredFiles sets can continue to grow without bound as new files are added to the monitored directory. There are scenarios where an input file is deleted by the application once it is processed; here, it is useful to provide a property that, if true, will cause the scanner to remove deleted files from these sets to prevent unbounded growth.

The only way to do this currently is to extend DirectoryScanner and provide implementations of the scan() and createPartition() methods which forces the operator writer to unnecessarily grapple with the internals of the base class.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)