[
https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205022#comment-15205022
]
Daniel Halperin commented on BEAM-131:
--------------------------------------
+1.
Re your #2: I hope not. Specifically, I am optimistic that the runners need
only implement the primitives (BoundedSource, Sink, ParDo, UnboundedSource) and
then no runner-specific implementation should be needed for new connectors that
build on these.
That is, I hope that the JDBC connector would be built entirely on
BoundedSource/Sink (for batch) and ParDo (for streaming sink).
> Write to jdbc/database
> -----------------------
>
> Key: BEAM-131
> URL: https://issues.apache.org/jira/browse/BEAM-131
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: Kostas Kloudas
> Assignee: Kostas Kloudas
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)