Потоковая передача данных в блоки данных Azure с помощью концентраторов событий

Question

Я хочу отправлять сообщения из приложения Twitter в центр событий Azure.Тем не менее, я получаю сообщение об ошибке, вместо java.util.concurrent.ExecutorService использовать java.util.concurrent.ScheduledExecutorService.

Я не знаю, как создать EventHubClient.create сейчас.Пожалуйста, помогите.

Я имею в виду код по ссылке

https://docs.microsoft.com/en-us/azure/azure-databricks/databricks-stream-from-eventhubs

Это ошибка, которую я получаю:

ноутбук:15: ошибка: несоответствие типов;найдено: java.util.concurrent.ExecutorService обязательно: java.util.concurrent.ScheduledExecutorService

val pool = `Executors.newFixedThreadPool(1)`

val eventHubClient = EventHubClient.create(connStr.toString(), pool)

Вот мой код,

import java.util._
import scala.collection.JavaConverters._
import com.microsoft.azure.eventhubs._
import java.util.concurrent.{Executors, ExecutorService}

val pool: ExecutorService = Executors.newFixedThreadPool(1)
val eventHubClient = EventHubClient.create(connStr.toString(), pool)

Answer 1

Создайте библиотеку в рабочей области Databricks, используя координаты Maven com.microsoft.azure:azure-eventhubs-spark_2.11:2.3.2 или более позднюю версию.Присоедините созданную библиотеку к вашему кластеру и снова подключите записную книжку к кластеру после нее.

import java.util._
import scala.collection.JavaConverters._
import com.microsoft.azure.eventhubs._
import java.util.concurrent._
//Set up Connection to Azure Event Hubs
val namespaceName = "namespaceName_of_event_hub"
val eventHubName = "Name_of_event_hub"
val sasKeyName = "your_Sas_key_name"
val sasKey = "xxxxxxxxxxxxxxxxxxxxxxx"
val connStr = new ConnectionStringBuilder()
            .setNamespaceName(namespaceName)
            .setEventHubName(eventHubName)
            .setSasKeyName(sasKeyName)
            .setSasKey(sasKey)
val pool = Executors.newFixedThreadPool(1)
val eventHubClient = EventHubClient.create(connStr.toString(), pool)