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