Close the connection to the Parquet file.
(self)
| 1213 | self.writer.write_table(table, row_group_size=row_group_size) |
| 1214 | |
| 1215 | def close(self): |
| 1216 | """ |
| 1217 | Close the connection to the Parquet file. |
| 1218 | """ |
| 1219 | if self.is_open: |
| 1220 | self.writer.close() |
| 1221 | self.is_open = False |
| 1222 | if self._metadata_collector is not None: |
| 1223 | self._metadata_collector.append(self.writer.metadata) |
| 1224 | if self.file_handle is not None: |
| 1225 | self.file_handle.close() |
| 1226 | |
| 1227 | def add_key_value_metadata(self, key_value_metadata): |
| 1228 | """ |