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
----
---
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 feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
