org.apache.flink.streaming.api.functions.windowing.delta

Interface DeltaFunction<DATA>

Type Parameters:

DATA - The type of input data which can be compared using this function.

All Superinterfaces:

Serializable

All Known Implementing Classes:

CosineDistance, EuclideanDistance, ExtractionAwareDeltaFunction

@PublicEvolving
public interface DeltaFunction<DATA>
extends Serializable

This interface allows the implementation of a function which calculates the delta between two data points. Delta functions might be used in delta policies and allow flexible adaptive windowing based on the arriving data points.

Method Summary

Modifier and Type	Method and Description
double	getDelta(DATA oldDataPoint, DATA newDataPoint) Calculates the delta between two given data points.

Method Detail

getDelta

double getDelta(DATA oldDataPoint,
                DATA newDataPoint)

Calculates the delta between two given data points.

Parameters:

oldDataPoint - the old data point.

newDataPoint - the new data point.

Returns:

the delta between the two given points.