[
https://issues.apache.org/jira/browse/BEAM-1126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1126:
----------------------------
Description:
Today {{UnboundedSource}} exposes split backlog in bytes via
{{getSplitBacklogBytes()}}
There is value in exposing backlog in number of events as well, since this
number can be more human comprehensible than bytes. something like
{{getSplitBacklogEvents()}} or {{getSplitBacklogCount()}}.
was:
Today +UnboundedSource+ exposes split backlog in bytes via
getSplitBacklogBytes()
There is value in exposing backlog in number of events as well, since this
number can be more human comprehensible than bytes. something like
getSplitBacklogEvents() or getSplitBacklogCount().
> Expose UnboundedSource split backlog in number of events
> --------------------------------------------------------
>
> Key: BEAM-1126
> URL: https://issues.apache.org/jira/browse/BEAM-1126
> Project: Beam
> Issue Type: Improvement
> Components: sdk-java-core
> Reporter: Aviem Zur
> Assignee: Daniel Halperin
> Priority: Minor
>
> Today {{UnboundedSource}} exposes split backlog in bytes via
> {{getSplitBacklogBytes()}}
> There is value in exposing backlog in number of events as well, since this
> number can be more human comprehensible than bytes. something like
> {{getSplitBacklogEvents()}} or {{getSplitBacklogCount()}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
