Been trying to deal with this problem for sooooo long! I may be approaching
this the incorrect way but can't really imagine another way.
.triggering(
AfterFirst.of(
AfterPane.elementCountAtLeast(options.getCountAtLeastValue().get()),
AfterProcessingTime.pastFirstElementInPane().plusDelayOf(Duration.standardSeconds(1))
)
)
Having the previous trigger, I would like to make the
AfterPane.elementCountAtLeast value configurable at runtime, but haven't found
a proper way to do so.
Is there any usual way in Beam to make trigger values configurable or should I
make my own? I've ValueProvider options within a custom pipeline stage by
including them in the constructor, but don't really know if there's an easier
way to do so.
