[ https://issues.apache.org/jira/browse/BEAM-607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708357#comment-15708357 ]
ASF GitHub Bot commented on BEAM-607: ------------------------------------- GitHub user khurrumnasimm opened a pull request: https://github.com/apache/incubator-beam/pull/1464 BEAM-607: Add a bounded source for Apache DistributedLog (incubating) Apache DistributedLog (incubating) is a replicated log stream store. This pull request is the first part of BEAM-607 - ADD a bounded source for Apache DistributedLog streams. The bounded source is similar as HDFS bounded source. You can merge this pull request into a Git repository by running: $ git pull https://github.com/khurrumnasimm/incubator-beam kn/distributedlog_io Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-beam/pull/1464.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 #1464 ---- commit f0db56a7eb3ac840873cc9e3acf7a997d383f583 Author: Khurrum Nasim <khurrumnas...@gmail.com> Date: 2016-11-30T11:41:42Z Add a bounded source for Apache DistributedLog (incubating) ---- > 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)