У меня проблема, когда пользователь очень быстро нажимает две кнопки, которые обновляют в базе данных firebase один и тот же объект и одно и то же свойство. проблема в том, что только один запрос сохраняет, а остальные переопределяют. это...

Пытаюсь сделать тюнер. К плате Arduino Uno подключены 3 светодиода, каждый из которых соответствует одной ситуации (слишком высокая, низкая или правильная высота). Python обрабатывает обнаружение заметки в соответствии с входом микрофона и...

Некоторое время я использовал apache flink для пакетной обработки, но теперь мы хотим преобразовать это пакетное задание в потоковое задание. Проблема, с которой я сталкиваюсь, заключается в том, как выполнять сквозные тесты. Как это работало при...

Я пытаюсь сопоставить CSV-файл, уже использованный Flink и созданный Kafka, в Tuple4. В моем CSV-файле 4 столбца, и я хочу сопоставить каждую строку с Tuple4. Проблема в том, что я не знаю, как реализовать функции map () и csv2Tuple. Вот где я...

У меня есть поток данных (из файла csv), который содержит строки и определенное значение (двойное значение) в каждой строке. Я использую keyBy () в Flink для группировки этих значений по определенному атрибуту (стране), поэтому у меня есть разные...

Я пытаюсь создать таблицу API таблицы flink, которая использует функцию источника Debezium, я нашел реализацию этих функций здесь https://github.com/ververica/flink-cdc-connectors и использовал их в моем коде следующим образом: val...