Добавление поддержки SQL подобного языка для потоковой обработки данных в Apache Flink

Задача
Реализовать кастомный Flink-оператор, который будет обрабатывать потоковые данные в соответствии с переданным ему запросом на языке SiddhiQL. Сделать операции Join и Group By распределенными. Оформить написанный код в виде Java-библиотеки.
Кураторы
Александр Трушев
Инженер,
Huawei Technologies Co., Ltd.

Сергей Трошков
Инженер,
Huawei Technologies Co., Ltd.
Требуемые навыки
Знание Java, git. Базовое знание SQL. Будет здорово, если вы знакомы с Maven, Scala и Apache Spark.
Дополнительные материалы
Вы можете более подробно ознакомиться с проектом в презентации по ссылке