Sign in
apache
/
hamilton
/
refs/heads/generic-with-columns
/
.
/
examples
/
parallelism
/
file_processing
/
aggregate_data.py
blob: 952a17d295a9e7ca85cbc84a3897b675041f6a53 [
file
] [
log
] [
blame
]
import
pandas
as
pd
from
hamilton
.
htypes
import
Collect
def
statistics_by_city
(
statistics
:
Collect
[
dict
])
->
pd
.
DataFrame
:
"""Joins all data together"""
return
pd
.
DataFrame
.
from_records
(
statistics
).
set_index
(
"city"
)
