Как читать данные постов из sparkjobserver в моей работе Spark? - PullRequest
0 голосов
/ 08 апреля 2019

Как обрабатывать эти данные пост-запроса в моей искровой работе, исходящей с этого сервера искровой работы, я очень запутался.

Я пытаюсь запустить свою работу, используя configfactory, но это не помогает, мне нужно больше разъяснений по этому поводу.

val conf = new SparkConf().setMaster("local[4]").setAppName("JourneyAnalytics")
val sc = new SparkContext(conf)
//val json = fromURL("localhost:8090/jobs?appName=test&classPath=spark.jobserver.WordCountExample&context=test-context&sync=true").mkString
//val config = ConfigFactory.parseString("{\"noOfDays\":2,\"propertyPath\":cjanalytics.properties,\"startChannelName\":bmb,\"listofdates\":bmb}")
val config = ConfigFactory.parseString("")

//val config1= scala.io.Source.fromFile("B:/barclays/JourneyAnalytics/src/test/resources/config/sample/pathAnalysis.json").mkString
//val config = ConfigFactory.parseString(config1)
println(config)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...