beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mark Shields (JIRA)" <>
Subject [jira] [Commented] (BEAM-129) Support pubsub IO
Date Fri, 18 Mar 2016 17:29:33 GMT


Mark Shields commented on BEAM-129:

For the read side I think this boils down to
plus making sure the Flink runner is invoking UnboundedSource readers appropriately. I'm working
on BEAM-125 right now. (Turns out to be very easy to get working, but more challenging to
make fast.)

For the write side ideally we'll start with generic UnboundedSink, then implement pub/sub
writes on that, then the Flink runner would invoke that generically. A shorter-term solution
may be in order.

> Support pubsub IO
> -----------------
>                 Key: BEAM-129
>                 URL:
>             Project: Beam
>          Issue Type: New Feature
>          Components: runner-flink
>            Reporter: Kostas Kloudas
>            Assignee: Maximilian Michels
> Support pubsub IO

This message was sent by Atlassian JIRA

View raw message