[jira] [Commented] (BEAM-607) Add DistributedLog IO
[ https://issues.apache.org/jira/browse/BEAM-607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708365#comment-15708365 ] Khurrum Nasim commented on BEAM-607: [~jbonofre] I just sent out the first pull request for adding a bounded source for DistributedLog streams. It is in https://github.com/apache/incubator-beam/pull/1464 Let me know if you have any questions. I will send out an unbounded source and sink soon. > Add DistributedLog IO > - > > Key: BEAM-607 > URL: https://issues.apache.org/jira/browse/BEAM-607 > Project: Beam > Issue Type: New Feature > Components: sdk-java-extensions >Reporter: Khurrum Nasim > > I'd like to add an IO for the new DistributedLog streams - > http://distributedlog.io > - bounded source and sink (sealed streams) > - unbounded source and sink (unsealed streams) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (BEAM-607) Add DistributedLog IO
[ https://issues.apache.org/jira/browse/BEAM-607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15451628#comment-15451628 ] Khurrum Nasim commented on BEAM-607: I'd like to contribute. Can you assign this to me? > Add DistributedLog IO > - > > Key: BEAM-607 > URL: https://issues.apache.org/jira/browse/BEAM-607 > Project: Beam > Issue Type: New Feature > Components: sdk-java-extensions >Reporter: Khurrum Nasim >Assignee: James Malone > Fix For: 0.3.0-incubating > > > I'd like to add an IO for the new DistributedLog streams - > http://distributedlog.io > - bounded source and sink (sealed streams) > - unbounded source and sink (unsealed streams) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (BEAM-607) Add DistributedLog IO
Khurrum Nasim created BEAM-607: -- Summary: Add DistributedLog IO Key: BEAM-607 URL: https://issues.apache.org/jira/browse/BEAM-607 Project: Beam Issue Type: New Feature Components: sdk-java-extensions Reporter: Khurrum Nasim Assignee: James Malone Fix For: 0.3.0-incubating I'd like to add an IO for the new DistributedLog streams - http://distributedlog.io - bounded source and sink (sealed streams) - unbounded source and sink (unsealed streams) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
