stream.scotty.demo.flink.windowFunctions

Class MaxWindowFunction

java.lang.Object

windowFunctions.flink.demo.stream.scotty.MaxWindowFunction

All Implemented Interfaces:

AggregateFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>, ReduceAggregateFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>, java.io.Serializable

public class MaxWindowFunction
extends java.lang.Object
implements ReduceAggregateFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MaxWindowFunction()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>	combine(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> partialAggregate1, org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> partialAggregate2) Computes the combined aggregate from partial aggregates.

Methods inherited from class java.lang.Object

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

Methods inherited from interface stream.scotty.core.windowFunction.ReduceAggregateFunction

lift, lower

Constructor Detail

MaxWindowFunction

public MaxWindowFunction()

Method Detail

combine

public org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> combine(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> partialAggregate1,
                                                                                           org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> partialAggregate2)

Description copied from interface: AggregateFunction

Computes the combined aggregate from partial aggregates. Each incremental aggregation step results in one call of the combine function.

Specified by:

combine in interface AggregateFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>

Returns:

combined PartialAggregate