Package org.apache.flink.streaming.api.windowing.assigners

Interface SessionWindowTimeGapExtractor<T>

  • Type Parameters:
    T - The type of elements that this SessionWindowTimeGapExtractor can extract session time gaps from.
    All Superinterfaces:
    Serializable
    @PublicEvolving
public interface SessionWindowTimeGapExtractor<T>
extends Serializable
    A SessionWindowTimeGapExtractor extracts session time gaps for Dynamic Session Window Assigners.

    • Method Detail

      • extract

        long extract​(T element)
        Extracts the session time gap.
        Parameters:
        element - The input element.
        Returns:
        The session time gap in milliseconds.