Keep parquet data in hexadecimal format

This commit is contained in:
2026-07-09 23:39:25 +02:00
parent ce20587591
commit 6edb160761
2 changed files with 3 additions and 4 deletions
View File
+3 -4
View File
@@ -76,12 +76,11 @@ def parse_csv(csv_path: PathLike) -> pl.LazyFrame:
expr = (
pl.col("Data").str.strip_chars().str.split(" ")
.list.get(i, null_on_oob=True)
.str.to_integer(base=16, strict=False)
.alias(f"b{i}").cast(pl.UInt8)
.alias(f"b{i}")
)
byte_exprs.append(expr)
lf = lf.with_columns(byte_exprs).drop("Data")
lf = lf.with_columns(byte_exprs)
return lf.with_columns([
pl.col("DLC").cast(pl.UInt8),
@@ -112,5 +111,5 @@ if __name__ == '__main__':
elif args.command == "parquet":
print(f"[*] Processing {args.input_csv}...")
lf = parse_csv(args.input_csv)
save_parquet(lf, args.output_parquet)
lf.sink_parquet(args.output_parquet)
print(f"[+] Saved parquet file to {args.output_parquet}")