stream.scotty.demo.flink.windowFunctions

Class QuantileWindowFunction

java.lang.Object

windowFunctions.flink.demo.stream.scotty.QuantileWindowFunction

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,QuantileTreeMap>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>, java.io.Serializable

public class QuantileWindowFunction
extends java.lang.Object
implements AggregateFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private double	quantile

Constructor Summary

Constructors

Constructor and Description
QuantileWindowFunction(double quantile)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap>	combine(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap> partialAggregate1, org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap> partialAggregate2) Computes the combined aggregate from partial aggregates.
org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap>	lift(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> inputTuple) Transforms a tuple to a partial aggregate.
org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>	lower(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap> aggregate) Transforms a partial aggregate to a final aggregate.

Methods inherited from class java.lang.Object

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

Field Detail

quantile

private final double quantile

Constructor Detail

QuantileWindowFunction

public QuantileWindowFunction(double quantile)

Method Detail

lift

public org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap> lift(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> inputTuple)

Description copied from interface: AggregateFunction

Transforms a tuple to a partial aggregate. For example, consider an average computation. If a tuple ⟨p,v⟩ contains its position p and a value v, the lift function will transform it to ⟨sum←v, count←1⟩, which is the partial aggregate of that one tuple.

Specified by:

lift 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,QuantileTreeMap>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>

Parameters:

inputTuple - input Tuple

Returns:

PartialAggregate

lower

public org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer> lower(org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,QuantileTreeMap> aggregate)

Description copied from interface: AggregateFunction

Transforms a partial aggregate to a final aggregate. In our example, the lower function computes the average from sum and count: ⟨sum, count⟩ 7→ sum/count.

Specified by:

lower 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,QuantileTreeMap>,org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>

Returns:

final Aggregate

combine

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

Returns:

combined PartialAggregate