[
https://issues.apache.org/jira/browse/BEAM-988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Beam JIRA Bot updated BEAM-988:
-------------------------------
Labels: stale-P2 (was: )
> Support for testing how soon output is emitted
> ----------------------------------------------
>
> Key: BEAM-988
> URL: https://issues.apache.org/jira/browse/BEAM-988
> Project: Beam
> Issue Type: Improvement
> Components: runner-direct, testing
> Reporter: Eugene Kirpichov
> Priority: P2
> Labels: stale-P2
>
> I ran into this issue when testing Splittable DoFn. My intention is, it
> should behave exactly like a DoFn - i.e. emit output immediately when it
> receives input, regardless of the windowing/triggering strategy of the input
> (even though SDF has a GBK internally).
> However, currently the SDK doesn't have facilities for testing that.
> TestStream allows controlling the timing of the input, but there's nothing to
> capture timing of the output. Moreover, timing of the output is unspecified
> by the model because triggers technically only enable firing, but do not
> force it (i.e. they are a lower bound on when output will be emitted).
> I'm not sure what's the best way to address this. E.g., perhaps, PaneInfo
> could include a field "since when was this pane enabled to fire" (regardless
> of when it really fired)?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
