[ https://issues.apache.org/jira/browse/BEAM-988 ]
Danny McCormick deleted comment on BEAM-988:
--------------------------------------
was (Author: JIRAUSER282469):
This issue has been migrated to https://github.com/apache/beam/issues/17934
> 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: P3
>
> 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.20.7#820007)
