Исследовательская группа

Лаборатория машинного обучения и организации информации

FlameStream

Руководитель проекта: Игорь Куралёнок
Статус: Активный

FlameStream - модель распределенной потоковой обработки данных, которая обладает следующими свойствами:

  • Элементы обрабатываются последовательно и независимо
  • Результаты определяются только входными данными, и не меняются между запусками
  • Модель поддерживает "exactly-once" семантику

FlameStream реализован на языке Java с использованием Akka Actors.

Реализация основана на следующих идеях:

  • Детерминизм достигается с помощью строгого порядка
  • Идемпотентность - с помощью детерминизма
  • "Exactly-once" - с помощью идемпотентности

В отличие от существующих моделей, FlameStream поддерживает ограниченный набор операций, который, однако, достаточен для выражения любого преобразования с состоянием. Это свойство позволяет реализовать строгий порядок с помощью оптимистичного подхода.

Участники

Публикации

Дополнительно