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