MapR [SPARK-879] Add changes to examples module to build for Spark-3.x (apache#817)

Author: ekrivokonmapr

examples/pom.xml

@@ -109,11 +109,11 @@
       <artifactId>scopt_${scala.binary.version}</artifactId>
       <version>3.7.1</version>
     </dependency>
-    <dependency>
-      <groupId>${hive.parquet.group}</groupId>
-      <artifactId>parquet-hadoop-bundle</artifactId>
-      <scope>provided</scope>
-    </dependency>
+<!--    <dependency>-->
+<!--      <groupId>com.twitter</groupId>-->
+<!--      <artifactId>parquet-hadoop-bundle</artifactId>-->
+<!--      <scope>provided</scope>-->
+<!--    </dependency>-->
 <!--    <dependency>-->
 <!--      <groupId>org.apache.spark</groupId>-->
 <!--      <artifactId>spark-streaming-kafka-producer_${scala.binary.version}</artifactId>-->

examples/src/main/scala/org/apache/spark/examples/sql/hive/SparkHiveExample.scala

@@ -30,7 +30,6 @@ object SparkHiveExample {
   case class Record(key: Int, value: String)
   // $example off:spark_hive$
 
-  def main(args: Array[String]): Unit = {
   val kv1Stream = SparkHiveExample.getClass.getResourceAsStream("/kv1.txt")
   val kv1File = File.createTempFile("kv1", "txt")
   kv1File.deleteOnExit()

examples/src/main/scala/org/apache/spark/examples/streaming/KafkaProducerExample.scala

@@ -22,7 +22,7 @@ import org.apache.kafka.clients.consumer.ConsumerConfig
 
 import org.apache.spark.SparkConf
 import org.apache.spark.streaming.{Seconds, StreamingContext}
-import org.apache.spark.streaming.kafka09.{
+import org.apache.spark.streaming.kafka010.{
   ConsumerStrategies,
   KafkaUtils,
   LocationStrategies
@@ -46,7 +46,7 @@ import org.apache.spark.streaming.kafka09.{
  *    topic1,topic2 my-consumer-group latest batch-interval pollTimeout
  */
 
-object V09DirectKafkaWordCount {
+object V010DirectKafkaWordCount {
   def main(args: Array[String]) {
     if (args.length < 4) {
       System.err.println(s"""