koaning commited on
Commit
c834fd5
·
verified ·
1 Parent(s): 792d40d

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +6 -10
app.py CHANGED
@@ -102,13 +102,14 @@ def _(catalog):
102
 
103
  @app.cell
104
  def _(pl):
105
- pl.scan_csv("yellow_tripdata_2015-01.csv").group_by("passenger_count").len().sort("passenger_count").collect()
 
106
  return
107
 
108
 
109
  @app.cell
110
  def _(pl):
111
- pl.read_csv("yellow_tripdata_2015-01.csv").group_by("passenger_count").len().sort("passenger_count")
112
  return
113
 
114
 
@@ -120,24 +121,19 @@ def _(mo):
120
 
121
  @app.cell
122
  def _(pl):
123
- pl.read_csv("yellow_tripdata_2015-01.csv").write_parquet("taxi.parquet", partition_by=["passenger_count"], statistics=True)
124
  return
125
 
126
 
127
  @app.cell
128
  def _(pl):
129
- pl.scan_parquet("taxi.parquet").group_by("passenger_count").len().sort("passenger_count").collect()
130
  return
131
 
132
 
133
  @app.cell
134
  def _(pl):
135
- pl.read_parquet("taxi.parquet").group_by("passenger_count").len().sort("passenger_count")
136
- return
137
-
138
-
139
- @app.cell
140
- def _():
141
  return
142
 
143
 
 
102
 
103
  @app.cell
104
  def _(pl):
105
+ df_orig = pl.read_csv("yellow_tripdata_2015-01.csv.zip")
106
+ df_orig.group_by("passenger_count").len().sort("passenger_count").collect()
107
  return
108
 
109
 
110
  @app.cell
111
  def _(pl):
112
+ df_orig.group_by("passenger_count").len().sort("passenger_count")
113
  return
114
 
115
 
 
121
 
122
  @app.cell
123
  def _(pl):
124
+ df_orig.write_parquet("taxi.parquet", partition_by=["passenger_count"], statistics=True)
125
  return
126
 
127
 
128
  @app.cell
129
  def _(pl):
130
+ df_orig.group_by("passenger_count").len().sort("passenger_count").collect()
131
  return
132
 
133
 
134
  @app.cell
135
  def _(pl):
136
+ df_orig.group_by("passenger_count").len().sort("passenger_count")
 
 
 
 
 
137
  return
138
 
139