Daniel Halperin updated BEAM-988:
    Component/s: testing

> Support for testing how soon output is emitted
> ----------------------------------------------
>                 Key: BEAM-988
>                 URL: https://issues.apache.org/jira/browse/BEAM-988
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-direct, testing
>            Reporter: Eugene Kirpichov
>            Assignee: Thomas Groh
> 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

Reply via email to