From 3e645b5e586077fdcb59454dc5a9e05c64823191 Mon Sep 17 00:00:00 2001 From: Nathan TeBlunthuis Date: Tue, 8 Mar 2022 20:17:20 -0800 Subject: [PATCH 1/1] bugfix. column name text_chars --- wikiq | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/wikiq b/wikiq index 2cb0c3a..fb198f3 100755 --- a/wikiq +++ b/wikiq @@ -254,7 +254,7 @@ class RevDataBase(): pa.field("title",pa.string()), pa.field("namespace",pa.int32()), pa.field("deleted",pa.bool_()), - pa.field("test_chars",pa.int32()), + pa.field("text_chars",pa.int32()), pa.field("revert",pa.bool_()), pa.field("reverteds",pa.list_(pa.int64())), pa.field("sha1",pa.string()), @@ -661,7 +661,7 @@ class WikiqParser(): outtable = rows_to_table(self.parquet_buffer, self.schema) if self.pq_writer is None: - self.pq_writer = pq.ParquetWriter(self.output_file, schema, flavor='spark') + self.pq_writer = pq.ParquetWriter(self.output_file, self.schema, flavor='spark') self.pq_writer.write_table(outtable) self.parquet_buffer = [] -- 2.39.5