Оптимизация потокового SQL на примере TopN в Apache Flink