Skip to content

Commit

Permalink
Minor tweaks to repartition notebook
Browse files Browse the repository at this point in the history
  • Loading branch information
r-shekhar committed Jun 18, 2017
1 parent 3b5564c commit d623faf
Showing 1 changed file with 15 additions and 13 deletions.
28 changes: 15 additions & 13 deletions 06_repartition/repartition_all_spark.ipynb
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
"cell_type": "code",
"execution_count": 2,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand Down Expand Up @@ -244,7 +244,7 @@
"cell_type": "code",
"execution_count": 4,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand Down Expand Up @@ -466,7 +466,7 @@
"cell_type": "code",
"execution_count": 6,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand Down Expand Up @@ -500,7 +500,7 @@
"cell_type": "code",
"execution_count": 2,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand Down Expand Up @@ -831,7 +831,7 @@
"cell_type": "code",
"execution_count": 3,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand All @@ -843,7 +843,7 @@
"cell_type": "code",
"execution_count": 4,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand Down Expand Up @@ -879,7 +879,7 @@
"cell_type": "code",
"execution_count": 5,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand All @@ -893,14 +893,16 @@
"collapsed": true
},
"source": [
"# Using Dask, Read, and set index on Taxi Dataframe produced using PySpark, then write to disk for easy reading in Dask"
"# Using Dask, Read, and set index on Taxi Dataframe produced using PySpark, then write to disk for easy reading in Dask\n",
"\n",
"For some reason I don't yet understand, this code seems dependent on Dask 0.14.3, and breaks in 0.15."
]
},
{
"cell_type": "code",
"execution_count": 1,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand All @@ -914,7 +916,7 @@
"cell_type": "code",
"execution_count": 2,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand Down Expand Up @@ -1439,7 +1441,7 @@
"cell_type": "code",
"execution_count": 6,
"metadata": {
"collapsed": false
"collapsed": true
},
"outputs": [],
"source": [
Expand All @@ -1452,7 +1454,7 @@
},
{
"cell_type": "code",
"execution_count": null,
"execution_count": 7,
"metadata": {
"collapsed": false,
"scrolled": false
Expand All @@ -1464,7 +1466,7 @@
},
{
"cell_type": "code",
"execution_count": null,
"execution_count": 8,
"metadata": {
"collapsed": false
},
Expand Down

0 comments on commit d623faf

Please sign in to comment.