Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
titleJoined.java
linenumberstrue
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);
}

...