Классика баз данных - статьи
Для этой цели служит конструкция
Для этой цели служит конструкция окна, определяющая "область видимости" операции над несколькими сообщениями, такой как агрегация или соединение. Должна иметься возможность определения окон на основе времени (вероятно, наиболее часто используемый случай), числа сообщений или точек прерывания в других атрибутах сообщения. У таких окон должна иметься возможность перемещения переменной величины из текущего окна (например, окно может быть шириной в пять сообщений, и другое окно может перемещать из текущего окна данные по одному сообщению). В результате, в зависимости от размеров окна и порции перемещения, окна можно сделать разъединенными или перекрывающимися. Пример перемещаемого окна показан на рис. 2.
Кроме того, требуются новые, ориентированные на потоки операции, не представленные в стандартном SQL. Примером может служить операция "Merge", которая мультиплексирует сообщения из нескольких потоков в манере, чувствительной ко времени поступления и порядку сообщений.
Наконец, набор операций должен быть расширяемым, чтобы разработчики могли легко получить от системы новые функции (например, реализовать собственный алгоритм анализа на потоковых данных).
Второе требование состоит в поддержке высокоуровневого языка "StreamSQL" со встроенными ориентированными на потоки примитивами и операциями.
