Method max

storm-client/src/jvm/org/apache/storm/trident/Stream.java:585–588

This aggregator operation computes the maximum of tuples in a stream by using the given comparator with TridentTuples. @param comparator comparator used in for finding maximum of two tuple values. @return the new stream with this operation.

(Comparator<TridentTuple> comparator)

     * @return the new stream with this operation.
     */
    public Stream max(Comparator<TridentTuple> comparator) {
        Aggregator<ComparisonAggregator.State> max = new MaxWithComparator<>(comparator);
        return comparableAggregateStream(null, max);
    }

    private <T> Stream comparableAggregateStream(String inputFieldName, Aggregator<T> aggregator) {
        if (inputFieldName != null) {