stream.scotty.flinkBenchmark.aggregations

Class SumAggregation

java.lang.Object

aggregations.flinkBenchmark.stream.scotty.SumAggregation

All Implemented Interfaces:

AggregateFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>, InvertibleAggregateFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>, InvertibleReduceAggregateFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>, ReduceAggregateFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>, java.io.Serializable

public class SumAggregation
extends java.lang.Object
implements InvertibleReduceAggregateFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SumAggregation()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>	combine(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> partialAggregate1, org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> partialAggregate2) Computes the combined aggregate from partial aggregates.
org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>	invert(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> currentAggregate, org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> 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

SumAggregation

public SumAggregation()

Method Detail

invert

public org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> invert(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> currentAggregate,
                                                                                                                       org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> 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.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

Returns:

combine

public org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> combine(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> partialAggregate1,
                                                                                                                        org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> 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.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>,org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

Returns:

combined PartialAggregate