[
https://issues.apache.org/jira/browse/BEAM-70?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15167458#comment-15167458
]
Daniel Halperin commented on BEAM-70:
-------------------------------------
see also BEAM-71
> More expressive UnboundedSource hierarchy and utilities
> -------------------------------------------------------
>
> Key: BEAM-70
> URL: https://issues.apache.org/jira/browse/BEAM-70
> Project: Beam
> Issue Type: New Feature
> Components: sdk-java-core
> Reporter: Daniel Halperin
>
> Right now, the UnboundedSource type hierarchy is 1 deep -- UnboundedSource
> and then things like CountingSource or KafkaSource directly on top.
> To ease implementors, we should have more abstract classes in the "common
> source types". Some examples may be:
> - KeyRangeUnboundedSource -- for things like PubSub, Bigtable, Kafka, Kinesis
> - StreamSource -- for reading from a socket or other stream.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
