bakeypan created BEAM-21:
----------------------------
Summary: Add SocketStream IO
Key: BEAM-21
URL: https://issues.apache.org/jira/browse/BEAM-21
Project: Beam
Issue Type: New Feature
Components: runner-direct, sdk-java-extensions
Reporter: bakeypan
Assignee: Davor BonaciNow there is no unbounded io support in direct pipeline runner. We can add the SocketStream as Flink to read data from net -- This message was sent by Atlassian JIRA (v6.3.4#6332)
