[
https://issues.apache.org/jira/browse/FLINK-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14222418#comment-14222418
]
ASF GitHub Bot commented on FLINK-1081:
---------------------------------------
GitHub user chiwanpark opened a pull request:
https://github.com/apache/incubator-flink/pull/226
[FLINK-1081] Add HDFS file-stream source for streaming
You can see more detailed information for this pull request in
[JIRA](https://issues.apache.org/jira/browse/FLINK-1081).
There are three big changes in this pull request.
1. Rename FileStreamFunction class to TextStreamFunction class
2. New FileStreamFunction class with feature watching given path
3. Add readFileStream method in StreamExecutionEnvironment class
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chiwanpark/incubator-flink FLINK-1081
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-flink/pull/226.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #226
----
commit 616c62781c6fd6662962ae2b57cbeb46052a1873
Author: Chiwan Park <[email protected]>
Date: 2014-11-20T05:03:14Z
[FLINK-1081] Add HDFS file-stream source for streaming
----
> Add HDFS file-stream source for streaming
> -----------------------------------------
>
> Key: FLINK-1081
> URL: https://issues.apache.org/jira/browse/FLINK-1081
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Affects Versions: 0.7.0-incubating
> Reporter: Gyula Fora
> Assignee: Chiwan Park
> Labels: starter
>
> Add data stream source that will monitor a slected directory on HDFS (or
> other filesystems as well) and will process all new files created.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
