sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java
/**
   * Sets a time limit (in processing time) on how long an incomplete batch of elements is allowed
   * to be buffered. Once a batch is flushed to output, the timer is reset. The provided limit must
   * be a positive duration or zero; a zero buffering duration effectively means no limit.
   */
Sets a time limit (in processing time) on how long an incomplete batch of elements is allowed
to be buffered. Once a batch is flushed to output, the timer is reset. The provided limit must
be a positive duration or zero; a zero buffering duration effectively means no limit.
Sets a time limit ( in processing time ) on how long an incomplete batch of elements is allowed to be buffered . Once a batch is flushed to output the timer is reset . The provided limit must be a positive duration or zero ; a zero buffering duration effectively means no limit .
public GroupIntoBatches<K, InputT> withMaxBufferingDuration(Duration duration) {
    checkArgument(
        duration != null && !duration.isShorterThan(Duration.ZERO),
        "max buffering duration should be a non-negative value");
    return new GroupIntoBatches<>(BatchingParams.create(params.getBatchSize(), duration));
  }
public GroupIntoBatches < K , InputT > withMaxBufferingDuration ( Duration duration ) { checkArgument ( duration != null && ! duration . isShorterThan ( Duration . ZERO ) , "max buffering duration should be a non-negative value" ) ; return new GroupIntoBatches < > ( BatchingParams . create ( params . getBatchSize ( ) , duration ) ) ; }
Sets a time limit (in processing time) on how long an incomplete batch of elements is allowed
 to be buffered.
Sets a time limit ( in processing time ) on how long an incomplete batch of elements is allowed to be buffered .