in e2e-examples/gcs/benchmark_analysis/transform_report.py [0:0]
def transform(args):
result = []
fields = set()
for tsvfile in args.file:
cur = {}
with open(tsvfile) as f:
reader = csv.DictReader(f, delimiter='\t')
for row in reader:
time = row['Time']
tag = row['Tag']
value = row['Throughput']
if tag in cur:
result.append(cur)
cur = {}
cur[tag] = value
if "Time" not in cur:
cur["Time"] = time
fields.add(tag)
if cur:
result.append(cur)
w = csv.DictWriter(sys.stdout, ['Time', ] + list(fields), delimiter='\t')
w.writeheader()
w.writerows(result)