bugfix
This commit is contained in:
parent
ae870fed0b
commit
9a0c157ebb
2
wikiq
2
wikiq
@ -593,7 +593,7 @@ class WikiqParser():
|
|||||||
self.pq_writer = pq.ParquetWriter(self.output_file, schema, flavor='spark')
|
self.pq_writer = pq.ParquetWriter(self.output_file, schema, flavor='spark')
|
||||||
|
|
||||||
self.pq_writer.write_table(outtable)
|
self.pq_writer.write_table(outtable)
|
||||||
self.output_buffer = []
|
self.parquet_buffer = []
|
||||||
|
|
||||||
def print_rev_data(self, rev_data):
|
def print_rev_data(self, rev_data):
|
||||||
if self.output_parquet is False:
|
if self.output_parquet is False:
|
||||||
|
Loading…
Reference in New Issue
Block a user