stream.scotty.demo.flink.windowFunctions

Class SumWindowFunction

java.lang.Object

windowFunctions.flink.demo.stream.scotty.SumWindowFunction

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>>, InvertibleAggregateFunction<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>>, InvertibleReduceAggregateFunction<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 SumWindowFunction
extends java.lang.Object
implements InvertibleReduceAggregateFunction<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
SumWindowFunction()

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.
org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>	invert(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> currentAggregate, org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> toRemove) Removes one partial aggregate from another with an incremental operation.

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

SumWindowFunction

public SumWindowFunction()

Method Detail

invert

public org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> invert(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> currentAggregate,
                                                                                          org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> toRemove)

Description copied from interface: InvertibleAggregateFunction

Removes one partial aggregate from another with an incremental operation.

Specified by:

invert in interface InvertibleAggregateFunction<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:

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