Я использую Spark Structured Streaming, которая считывает данные из Kafka, используя Java API.
Однако для конкретного условия необходимо прочитать данные из MySQL.
Как это можно реализовать с помощью структурированной потоковой передачи?
Я использую Spark Structured Streaming, которая считывает данные из Kafka, используя Java API. Однако для конкретного условия необходимо прочитать данные из MySQL. Как это можно реализовать с помощью структурированной потоковой передачи?
Я использую Spark Structured Streaming, которая считывает данные из Kafka, используя Java API.
Однако для конкретного условия необходимо прочитать данные из MySQL.
Как это можно реализовать с помощью структурированной потоковой передачи?
Я использую потоковую потоковую передачу Apache Spark для обработки входящих данных о событиях Debezium в партиях каждые 1 час (время расписания). Текущая реализация работает, но она кажется медленной и не удобной для производительности.
def...
Я пытаюсь использовать Openai -структурированные выходы со схемой JSON, например:
• Если часть 1 - «да», то часть2 должна присутствовать (требуется).
• Если часть 1 - Нет », тогда часть2 не должна быть вообще включена. Тем не менее, OpenAI не примет...
Мобильная версия