init main

aqib1 · aqib1 · commit 2946e188cf84 · 2019-10-25T13:15:07.000+05:00
diff --git a/Spark-Kafka/src/main/java/com/spark/kafka/task/SparkKafkaApplication.java b/Spark-Kafka/src/main/java/com/spark/kafka/task/SparkKafkaApplication.java
@@ -1,9 +1,11 @@
 package com.spark.kafka.task;
 
+import com.spark.kafka.task.client.SSClient;
+
 public class SparkKafkaApplication {
 
 	public static void main(String[] args) {
-		
+		SSClient.getInstance().initSpark().loadDataFromKafka().writeData();
 	}
 
 }

Original file line number	Diff line number	Diff line change
`@@ -1,9 +1,11 @@`
`1`	`1`	`package com.spark.kafka.task;`
`2`	`2`
	`3`	`+import com.spark.kafka.task.client.SSClient;`
	`4`	`+`
`3`	`5`	`public class SparkKafkaApplication {`
`4`	`6`
`5`	`7`	`public static void main(String[] args) {`
`6`		`-`
	`8`	`+ SSClient.getInstance().initSpark().loadDataFromKafka().writeData();`
`7`	`9`	`}`
`8`	`10`
`9`	`11`	`}`