diff --git a/L1 - Introduction to Apache Spark/L1_interactive_bike_analysis_python_with_rdd.ipynb b/L1 - Introduction to Apache Spark/L1_interactive_bike_analysis_python_with_rdd.ipynb index 0e98192..d235fb2 100644 --- a/L1 - Introduction to Apache Spark/L1_interactive_bike_analysis_python_with_rdd.ipynb +++ b/L1 - Introduction to Apache Spark/L1_interactive_bike_analysis_python_with_rdd.ipynb @@ -70,18 +70,6 @@ "sc = SparkContext(conf=conf)" ] }, - { - "cell_type": "code", - "execution_count": 133, - "id": "47896fd0-906e-413d-8980-3948d73a3067", - "metadata": {}, - "outputs": [], - "source": [ - "tripData = sc.textFile(\"tripd_with_error.csv\")\n", - "tripsHeader = tripData.first()\n", - "trips = tripData.filter(lambda row: row != tripsHeader).map(lambda row: row.split(\",\", -1))" - ] - }, { "cell_type": "code", "execution_count": 10,