This commit is contained in:
Arijit Tarafdar 2016-11-28 15:04:16 -08:00
Родитель 9d818b8f09
Коммит 67b7fcf142
1 изменённых файлов: 5 добавлений и 6 удалений

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

@ -28,13 +28,12 @@ import scala.collection.Map
object EventHubsUtils {
/**
* Return an initialized SparkConf that registered
* Azure Eventhubs client's internal classes with Kryo serializer
* @return SparkConf
*/
/**
* Return an initialized SparkConf that registered
* Azure Eventhubs client's internal classes with Kryo serializer
* @return SparkConf
*/
def initializeSparkStreamingConfigurations: SparkConf = {
new SparkConf().registerKryoClasses(Array(classOf[EventData]))
}