spark-streaming

1зной

1ответ

Apache Bahir, отправить материал ActorReceiver

Я пытаюсь настроить простой процесс с помощью Spark Streaming, используя Apache Bahir для подключения к Akka. Я попытался следовать their example вместе с этим older one. У меня есть простой форвардер

0зной

1ответ

Передача данных в реальном времени с использованием Apache Spark и kfaka

Я разрабатываю приложение для искрообразования с помощью Kafka. У меня есть несколько вопросов следующим образом: я потоковый данные из таблиц RDBMS в Кафка и используя искровую потребителя потреблять

0зной

1ответ

Невозможно получить любые сообщения в Kafka 0.10.0 with Spark stream 1.6.2

Недавно мы перешли на HDP 2.5 с Kafka 0.10.0 и Spark 1.6.2. Поэтому я изменил свой pom и некоторые из API для работы с новым Kafka. Я могу запустить код, но я не вижу сообщений. Я добавил фрагмент код

1зной

1ответ

Scala Spark Streaming Via Apache Toree

Я использую изображение полной док-станции для ноутбука на моем mac, чтобы использовать apache toree и scala (https://github.com/jupyter/docker-stacks/tree/master/all-spark-notebook). Я пытаюсь провер