updating import statements to new eventhubs namespace
This commit is contained in:
Родитель
00fe018f0c
Коммит
ba45c101bb
|
@ -22,7 +22,7 @@ import scala.collection.JavaConverters._
|
|||
|
||||
import EventHubsOffsetTypes.EventHubsOffsetType
|
||||
import com.microsoft.azure.eventhubs.{EventHubClient => AzureEventHubClient, _}
|
||||
import com.microsoft.azure.servicebus._
|
||||
import com.microsoft.azure.eventhubs._
|
||||
|
||||
import org.apache.spark.{SparkEnv, TaskContext}
|
||||
import org.apache.spark.eventhubscommon.EventHubNameAndPartition
|
||||
|
|
|
@ -26,7 +26,7 @@ import scala.concurrent.duration._
|
|||
import scala.util.{Failure, Success}
|
||||
import scala.xml.XML
|
||||
|
||||
import com.microsoft.azure.servicebus.SharedAccessSignatureTokenProvider
|
||||
import com.microsoft.azure.eventhubs.SharedAccessSignatureTokenProvider
|
||||
import scalaj.http.{Http, HttpResponse}
|
||||
|
||||
import org.apache.spark.eventhubscommon.EventHubNameAndPartition
|
||||
|
|
Загрузка…
Ссылка в новой задаче