#32 spark notebook with Chronix samples

Author: adersberger

chronix-infrastructure-local/Chronix Spark Samples.json

@@ -77,7 +77,7 @@
     },
     {
       "title": "Create RDD, calculate statistics & create sQL Table",
-      "text": "%spark\nimport de.qaware.chronix.spark.api.java.ChronixSparkContext\nimport org.apache.spark.api.java.JavaSparkContext\nimport org.apache.solr.client.solrj.SolrQuery\nimport de.qaware.chronix.storage.solr.ChronixSolrCloudStorage\n\n// Create RDD\nval csc = new ChronixSparkContext(new JavaSparkContext(sc))\nval query = new SolrQuery(\"*:*\")\nval rdd = csc.query(query, \"localhost:9983\", \"chronix\", new ChronixSolrCloudStorage())\n\n// Calculate statistics (number of overall observations)\nrdd.countObservations()\n\n// Create DataFrame and register table\nval timeseries = rdd.toDataFrame(sqlContext)\ntimeseries.registerTempTable(\"timeseries\")",
+      "text": "%spark\nimport de.qaware.chronix.spark.api.java.ChronixSparkContext\nimport org.apache.spark.api.java.JavaSparkContext\nimport org.apache.solr.client.solrj.SolrQuery\nimport de.qaware.chronix.storage.solr.ChronixSolrCloudStorage\n\n// Create RDD\nval csc = new ChronixSparkContext(new JavaSparkContext(sc))\nval query = new SolrQuery(\"process:global\")\nval rdd = csc.query(query, \"localhost:9983\", \"chronix\", new ChronixSolrCloudStorage())\n\n// Calculate statistics (number of overall observations)\nrdd.countObservations()\n\n// Create DataFrame and register table\nval timeseries = rdd.toDataFrame(sqlContext)\ntimeseries.registerTempTable(\"timeseries\")",
       "dateUpdated": "May 7, 2016 3:53:23 PM",
       "config": {
         "colWidth": 12,