Merge pull request #31 from data-integrations/feature/CDAP-16222-FixImports

CDAP-16222: Fix imports in dynamic spark plugin documentation/examples

Author: domnicjp

docs/ScalaSparkCompute-sparkcompute.md

@@ -47,9 +47,9 @@ and produces records of two fields, ``'word'`` and ``'count'``.
 
 The following imports are included automatically and are ready for the user code to use:
 
-      import co.cask.cdap.api.data.format._
-      import co.cask.cdap.api.data.schema._;
-      import co.cask.cdap.etl.api.batch._
+      import io.cdap.cdap.api.data.format._
+      import io.cdap.cdap.api.data.schema._;
+      import io.cdap.cdap.etl.api.batch._
       import org.apache.spark._
       import org.apache.spark.api.java._
       import org.apache.spark.rdd._

docs/ScalaSparkProgram-sparkprogram.md

@@ -13,14 +13,14 @@ Properties
 **mainClass** The fully qualified class name for the Spark application.
 It must either be an ``object`` that has a ``main`` method define inside, with the method signature as 
 ``def main(args: Array[String]): Unit``; or it is a class that extends from the CDAP 
-``co.cask.cdap.api.spark.SparkMain`` trait that implements the ``run`` method, with the method signature as
+``io.cdap.cdap.api.spark.SparkMain`` trait that implements the ``run`` method, with the method signature as
 ``def run(implicit sec: SparkExecutionContext): Unit``
 
 **scalaCode** The self-contained Spark application written in Scala.
 For example, an application that reads from CDAP stream with name ``streamName``, 
 performs a simple word count logic and logs the result can be written as:
 
-    import co.cask.cdap.api.spark._
+    import io.cdap.cdap.api.spark._
     import org.apache.spark._
     import org.slf4j._
 

docs/ScalaSparkSink-sparksink.md

@@ -45,9 +45,9 @@ This will perform a word count on the input field ``'body'``, then write out the
 
 The following imports are included automatically and are ready for the user code to use:
 
-      import co.cask.cdap.api.data.format._
-      import co.cask.cdap.api.data.schema._;
-      import co.cask.cdap.etl.api.batch._
+      import io.cdap.cdap.api.data.format._
+      import io.cdap.cdap.api.data.schema._;
+      import io.cdap.cdap.etl.api.batch._
       import org.apache.spark._
       import org.apache.spark.api.java._
       import org.apache.spark.rdd._

widgets/ScalaSparkProgram-sparkprogram.json

@@ -19,7 +19,7 @@
           "label": "Scala",
           "name": "scalaCode",
           "widget-attributes": {
-            "default": "import co.cask.cdap.api.spark._\nimport org.apache.spark._\nimport org.slf4j._\n\nclass SparkProgram extends SparkMain {\n  import SparkProgram._\n\n  override def run(implicit sec: SparkExecutionContext): Unit = {\n    LOG.info(\"Spark Program Started\")\n\n    val sc = new SparkContext\n\n    LOG.info(\"Spark Program Completed\")\n  }\n}\n\nobject SparkProgram {\n  val LOG = LoggerFactory.getLogger(getClass())\n}"
+            "default": "import io.cdap.cdap.api.spark._\nimport org.apache.spark._\nimport org.slf4j._\n\nclass SparkProgram extends SparkMain {\n  import SparkProgram._\n\n  override def run(implicit sec: SparkExecutionContext): Unit = {\n    LOG.info(\"Spark Program Started\")\n\n    val sc = new SparkContext\n\n    LOG.info(\"Spark Program Completed\")\n  }\n}\n\nobject SparkProgram {\n  val LOG = LoggerFactory.getLogger(getClass())\n}"
           }
         },
         {