code: def flush(self):
          
          self.log.info('Flushing tables and arrays to disk...')
          for tab in self._tables.values():
              tab.flush()
          self._write_ndarrays_cache_to_disk()
docs: Flush tables and arrays to disk