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 > > > > > > > > > >
