def apply_chunks()

in e2e-examples/gcs/benchmark_analysis/analyze_peer.py [0:0]


def apply_chunks(d, chunks):
  tset = set()
  for c in chunks:
      t = datetime.datetime.fromisoformat(c["time"][:19])
      tset.add(t)
      b = c["bytes"]
      d.read_bytes += b
      d.time_map.setdefault(t, TimeData()).read_bytes += b
  d.read_count += 1
  for t in tset:
      d.time_map[t].read_count += 1