Package org.apache.storm.trident.operation.builtin

Class Max

java.lang.Object

org.apache.storm.trident.operation.BaseOperation

org.apache.storm.trident.operation.BaseAggregator<ComparisonAggregator.State>

org.apache.storm.trident.operation.builtin.ComparisonAggregator<Comparable<Object>>

org.apache.storm.trident.operation.builtin.Max

All Implemented Interfaces:

Serializable, Aggregator<ComparisonAggregator.State>, Operation

public class Max
extends ComparisonAggregator<Comparable<Object>>

This aggregator computes the maximum of aggregated tuples in a stream. It assumes that the tuple has one value and it is an instance of Comparable.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregator

ComparisonAggregator.State

Constructor Summary

Constructors

Constructor	Description
Max(String inputFieldName)

Method Summary

Modifier and Type	Method	Description
protected Comparable<Object>	compare(Comparable<Object> value1, Comparable<Object> value2)

Methods inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregator

aggregate, complete, init, valueFromTuple

Methods inherited from class org.apache.storm.trident.operation.BaseOperation

cleanup, prepare

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup, prepare

Constructor Details

Max

public Max(String inputFieldName)

Method Details

compare

protected Comparable<Object> compare(Comparable<Object> value1,
 Comparable<Object> value2)

Specified by:

compare in class ComparisonAggregator<Comparable<Object>>