beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Daniel Halperin (JIRA)" <>
Subject [jira] [Updated] (BEAM-988) Support for testing how soon output is emitted
Date Thu, 01 Dec 2016 21:49:58 GMT


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

> Support for testing how soon output is emitted
> ----------------------------------------------
>                 Key: BEAM-988
>                 URL:
>             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

View raw message