Package 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 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.