org.apache.flink.table.api

Class Session

java.lang.Object

org.apache.flink.table.api.Session

@PublicEvolving
public final class Session
extends Object

Helper class for creating a session window. The boundary of session windows are defined by intervals of inactivity, i.e., a session window is closes if no event appears for a defined gap period.

Java Example:

 Session.withGap("10.minutes").on("rowtime").as("w")
 

Scala Example:

 Session withGap 10.minutes on 'rowtime as 'w
 

Constructor Summary

Constructors

Constructor and Description
Session()

Method Summary

Modifier and Type	Method and Description
static SessionWithGap	withGap(Expression gap) Creates a session window.

Methods inherited from class java.lang.Object

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

Constructor Detail

Session

public Session()

Method Detail

withGap

public static SessionWithGap withGap(Expression gap)

Creates a session window. The boundary of session windows are defined by intervals of inactivity, i.e., a session window is closes if no event appears for a defined gap period.

Parameters:

gap - specifies how long (as interval of milliseconds) to wait for new data before closing the session window.

Returns:

a partially defined session window