query filters

Author: DataKnox

SQL/DP500/spark query/sql_query.ipynb

@@ -39,7 +39,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "df.createOrReplaceTempView(\"vw_sales\")"
+    "1"
    ]
   },
   {
@@ -52,6 +52,17 @@
     "display(sales_df)"
    ]
   },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "sales_df = spark.sql(\"SELECT * FROM vw_sales\")\n",
+    "filter_df = sales_df.select(\"SalesOrderID\",\"OrderQty\").where((sales_df[\"CarrierTrackingNumber\"]==\"4911-403C-98\"))\n",
+    "display(filter_df)"
+   ]
+  },
   {
    "cell_type": "code",
    "execution_count": 1,