[
https://issues.apache.org/jira/browse/BEAM-70?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Cwik resolved BEAM-70.
---------------------------
Resolution: Won't Do
Fix Version/s: Not applicable
UnboundedSource will be replaced with SplittableDoFn. The intent is that users
will use RestrictionTrackers that exist or create their own.
> 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
> Priority: Major
> Fix For: Not applicable
>
>
> 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
(v7.6.3#76005)
