(self, piece, table)
| 69 | return concat_tables(self._tables) |
| 70 | |
| 71 | def validate_schemas(self, piece, table): |
| 72 | if not self.schema.equals(table.schema): |
| 73 | raise ValueError(f'Schema in {piece} was different. \n' |
| 74 | f'{self.schema}\n\nvs\n\n{table.schema}') |
| 75 | |
| 76 | def read_pandas(self, columns=None, use_threads=True): |
| 77 | """ |