THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public class Joined { /** * Set the grace period on the stream side of the join. Records will enter a buffer before being processed. Late records in the grace period will be processed in timestamp order, records out of the grace period will be dropped. * * @param gracePeriod the duration of the grace period. If zero, no buffer will be used. * @return new {@code Joined} instance configured with the gracePeriod */ public Joined withGracePeriod(Duration gracePeriod); } |
...