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