This commit is contained in:
sabeegrewal 2017-09-29 15:16:14 -07:00
Родитель afb2fad2fb
Коммит 784465dc5e
2 изменённых файлов: 1 добавлений и 2 удалений

Просмотреть файл

@ -21,7 +21,6 @@ import java.time.Instant
import scala.collection.JavaConverters._
import EventHubsOffsetTypes.EventHubsOffsetType
import com.microsoft.azure.eventhubs.{EventHubClient => AzureEventHubClient, _}
import com.microsoft.azure.servicebus._

Просмотреть файл

@ -18,8 +18,8 @@
package com.microsoft.spark.sql.examples
import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.streaming.ProcessingTime
import org.apache.spark.sql.functions._
import org.apache.spark.sql.streaming.ProcessingTime
object EventHubsStructuredStreamingExample {