[
https://issues.apache.org/jira/browse/FLINK-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14213913#comment-14213913
]
ASF GitHub Bot commented on FLINK-1173:
---------------------------------------
GitHub user chiwanpark opened a pull request:
https://github.com/apache/incubator-flink/pull/204
[FLINK-1173] Add socket text stream as a data source for the streaming API
Check more detail information in
[JIRA](https://issues.apache.org/jira/browse/FLINK-1173).
1. Add SocketTextStreamFunction class for a new stream source
2. Add socketTextStream method into StreamExecutionEnvironment
3. Add unit test for SocketTextStreamFunction class
Tested with `mvn verify` command.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chiwanpark/incubator-flink FLINK-1173
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-flink/pull/204.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 #204
----
commit 287d90b459fb975b757794b477f46062668aa63c
Author: Chiwan Park <[email protected]>
Date: 2014-11-16T10:33:02Z
[FLINK-1173] Add SocketTextStreamFunction
commit 754b4956f2d744493b534f5466a6f82e51fa6b5a
Author: Chiwan Park <[email protected]>
Date: 2014-11-16T11:28:47Z
[FLINK-1173] Add socketTextStream method
commit 162e564e813f75652bb6478ccd5aa953266b1750
Author: Chiwan Park <[email protected]>
Date: 2014-11-16T11:51:57Z
[FLINK-1173] Fix source codes to follow coding guidelines
commit 4f7d569c744e0469996152fd4c693ba8e1d50eed
Author: Chiwan Park <[email protected]>
Date: 2014-11-16T11:52:52Z
[FLINK-1173] Check clientSocket is already closed before close clientSocket
commit 8dacb8ddc3bb159b4b8eaf8f41a67e3a8b26af14
Author: Chiwan Park <[email protected]>
Date: 2014-11-16T12:09:50Z
[FLINK-1173] Add unit test for SocketTextStreamFunction
----
> Add socket text stream as a data source for the streaming API
> -------------------------------------------------------------
>
> Key: FLINK-1173
> URL: https://issues.apache.org/jira/browse/FLINK-1173
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Reporter: Gyula Fora
> Assignee: Chiwan Park
> Priority: Minor
> Labels: starter
>
> Add a socketTextStream(hostname,port) method to StreamExecutionEnvironment
> which would add a DataStreamSource that listens and streams the text input
> received through the selected port into the streaming program.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
