(self, piece, table)
| 79 | return concat_tables(self._tables) |
| 80 | |
| 81 | def validate_schemas(self, piece, table): |
| 82 | if not self.schema.equals(table.schema): |
| 83 | raise ValueError(f'Schema in {piece} was different. \n' |
| 84 | f'{self.schema}\n\nvs\n\n{table.schema}') |
| 85 | |
| 86 | def read_pandas(self, columns=None, use_threads=True): |
| 87 | """ |