twitter data analysis

package com.bigdata.spark.sparksql import org.apache.spark.sql.SparkSession import org.apache.spark.streaming._ object twitterdata { // //https://mvnrepository.com/artifact/org.apache.bahir/spark-streaming-twitter_2.11/2.3.0 //https://developer.twitter.com/en/apps //http://twitter4j.org/javadoc/twitter4j/Status.html // https://mvnrepository.com/artifact/org.twitter4j/twitter4j-stream/4.0.4 // https://mvnrepository.com/artifact/org.twitter4j/twitter4j-core/4.0.4 def main(args: Array[String]) { val spark = SparkSession.builder.master(“local[2]”).appName(“kafka_wordcount”).getOrCreate() import org.apache.spark.streaming.StreamingContext._ // not necessary since Spark 1.3 val ssc = new StreamingContext(spark.sparkContext, Seconds(10)) val