Я должен обработать некоторые файлы, которые приходят ко мне ежедневно.Информация имеет первичный...
В моем сценарии у меня есть 2 задания структурированной потоковой передачи: одна запись в таблицу...
1) У меня 32 раздела в EventHUB. 2) я хочу начать чтение с определенного seqNO для всех этих 32...
В настоящее время я использую два пользовательских ридера, использующих API V2 для работы с...
Я не могу создать толстый флягу для моего конвейера Kafka-SparkStructuredStreaming-MongoDB. Я...
Продолжение до этого вопроса У меня есть потоковые данные JSON в формате, аналогичном приведенному...