Я хочу отправлять сообщения из приложения Twitter в центр событий Azure. Тем не менее я получаю сообщение об ошибке:
notebook:20: error: type mismatch;
found : java.util.concurrent.ExecutorService
required: java.util.concurrent.ScheduledExecutorService
val eventHubClient = EventHubClient.create(connStr.toString(), pool)
Я не знаю, как создать EventHubClient.create сейчас. Пожалуйста, помогите.
Я имею в виду код по ссылке
https://docs.microsoft.com/en-us/azure/azure-databricks/databricks-stream-from-eventhubs.
Также я попробовал решение по ссылке:
Потоковая передача данных в блоки данных Azure с помощью концентраторов событий , и у меня это не работает.
Версия кластера 5.2 (включает Apache Spark 2.4.0, Scala 2.11), которая должна включать библиотеки Java SE 8 с новым членом ScheduledExecutorService. Кроме того, прилагаются следующие библиотеки: com.microsoft.azure:azure-eventhubs-spark_2.11:2.3.9 и org.twitter4j: twitter4j-core: 4.0.7, поэтому снова выполняются все предварительные условия.
Код:
import java._
import java.util._
import scala.collection.JavaConverters._
import com.microsoft.azure.eventhubs._
import java.util.concurrent._
import java.util.concurrent.ExecutorService
import java.util.concurrent.ScheduledExecutorService
val pool = Executors.newFixedThreadPool(1)
val eventHubClient = EventHubClient.create(connStr.toString(), pool)