You should really take a look at TestStream and have runners integrate with it instead.
There are already several tests which validate TestStream compatible runners to make sure their trigger evaluations are correct. On Wed, Jun 7, 2017 at 10:10 AM, Shen Li <cs.she...@gmail.com> wrote: > Hi Lukasz, > > Thanks for the suggestion. I am trying to test how the runner generates > watermarks. So I would like to have the trigger to fire on every watermark > advancing event. > > Shen > > On Wed, Jun 7, 2017 at 10:49 AM, Lukasz Cwik <lc...@google.com.invalid> > wrote: > > > Look into the AfterPane#elementCountAtLeast trigger as it seems to be the > > closest to your description. It fires as soon as any data is available. > > > > Are you sure you don't want some kind of watermark based trigger with > just > > with a small interval size? > > > > > > > > > > On Wed, Jun 7, 2017 at 8:22 AM, Shen Li <cs.she...@gmail.com> wrote: > > > > > Hi Lukasz, > > > > > > Thanks for your response. Is it possible to implement the following > logic > > > using existing triggers: always fire the trigger on a GlobalWindow > > whenever > > > watermark advances? > > > > > > Shen > > > > > > On Wed, Jun 7, 2017 at 10:05 AM, Lukasz Cwik <lc...@google.com.invalid > > > > > wrote: > > > > > > > Users are unable to create custom trigger implementations. If you > tell > > us > > > > what you want your trigger to do, we may be able to suggest an > > > alternative. > > > > > > > > On Wed, Jun 7, 2017 at 7:41 AM, Shen Li <cs.she...@gmail.com> wrote: > > > > > > > > > Hi, > > > > > > > > > > I created a custom trigger class (XYZ) by extending the > OnceTrigger. > > > > During > > > > > execution, I got this error "Cannot translate trigger class XYZ to > a > > > > > runner-API proto." It seems that the Triggers.ProtoConverter class > > > needs > > > > to > > > > > declare a convertSpecific method for my trigger XYZ. How can I use > my > > > > > custom trigger without modifying Beam's Triggers class? > > > > > > > > > > Thanks, > > > > > > > > > > Shen > > > > > > > > > > > > > > >
