Функции временных окон
Функции временных окон возвращают нижнюю границу соответствующего окна (включительно) и верхнюю границу (исключительно). Ниже перечислены функции для работы с WindowView:
hop
Введена в: v21.12
Скользящее временное окно имеет фиксированную длительность (window_interval) и сдвигается на заданный интервал (hop_interval). Если hop_interval меньше window_interval, скользящие окна перекрываются. Таким образом, записи могут попадать в несколько окон.
Поскольку одна запись может попадать в несколько скользящих окон, функция возвращает только границу первого окна при использовании функции hop без WINDOW VIEW.
Синтаксис
Аргументы
time_attr— дата и время.DateTimehop_interval— положительный интервал шага окна.Intervalwindow_interval— положительный интервал окна.Intervaltimezone— необязательный параметр. Название часового пояса.String
Возвращаемое значение
Возвращает нижнюю границу (включительно) и верхнюю границу (не включая) соответствующего скользящего (hopping) окна. Tuple(DateTime, DateTime)
Примеры
Скользящее (hopping) окно
hopEnd
Добавлена в версии: v22.1
Возвращает верхнюю исключающую границу соответствующего скользящего окна.
Поскольку одна запись может быть назначена нескольким hop-окнам, функция возвращает границу только первого окна, если функция hop используется без WINDOW VIEW.
Синтаксис
Аргументы
time_attr— Дата и время.DateTimehop_interval— Положительный интервал шага (hop).Intervalwindow_interval— Положительный интервал окна (window).Intervaltimezone— Необязательный параметр. Название часового пояса.String
Возвращаемое значение
Возвращает верхнюю границу (исключая её) соответствующего hopping-окна. DateTime
Примеры
Конец hopping-окна
hopStart
Впервые появилась в: v22.1
Возвращает включающую нижнюю границу соответствующего скользящего окна.
Поскольку одна запись может относиться к нескольким скользящим окнам, при использовании функции hop без WINDOW VIEW возвращается граница только первого окна.
Синтаксис
Аргументы
time_attr— Дата и время.DateTimehop_interval— Положительный интервал сдвига окна.Intervalwindow_interval— Положительный интервал окна.Intervaltimezone— Необязательный параметр. Название часового пояса.String
Возвращаемое значение
Возвращает включительную нижнюю границу соответствующего окна сдвига (hopping-окна). DateTime
Примеры
Начало окна сдвига (hopping-окна)
tumble
Добавлено в: v21.12
Функция tumble разбивает записи на неперекрывающиеся, последовательные временные окна фиксированной продолжительности (interval).
Синтаксис
Аргументы
time_attr— Дата и время.DateTimeinterval— Интервал окна, тип Interval.Intervaltimezone— Необязательный параметр. Название часового пояса.String
Возвращаемое значение
Возвращает нижнюю границу (включительно) и верхнюю границу (не включительно) соответствующего tumbling-окна. Tuple(DateTime, DateTime)
Примеры
Tumbling-окно
tumbleEnd
Добавлена в версии: v22.1
Возвращает невключительную верхнюю границу соответствующего tumbling-окна.
Синтаксис
Аргументы
time_attr— Дата и время.DateTimeinterval— Интервал окна с типомInterval.Intervaltimezone— Необязательный параметр. Название часового пояса.String
Возвращаемое значение
Возвращает верхнюю границу (не включительно) соответствующего окна типа tumbling. DateTime
Примеры
Конец окна типа tumbling
tumbleStart
Появилась в версии v22.1
Возвращает включающую нижнюю границу соответствующего фиксированного окна.
Синтаксис
Аргументы
time_attr— Дата и время.DateTimeinterval— Интервал временного окна в типеInterval.Intervaltimezone— Необязательный параметр. Имя часового пояса.String
Возвращаемое значение
Возвращает включающую нижнюю границу соответствующего фиксированного окна. DateTime
Примеры
Начало фиксированного окна