code: public Long getMax() {
  		return processFunction(new AbstractSplitFunction<Long>(Long.MIN_VALUE) {
  			@Override
  			public void evaluate(long runningFor) {
  				if (runningFor > result) {
  					result = runningFor;
  				}
  			}
  		});
  	}
docs: Compute the longest duration of splits in the buffer
  
  @return Maximum