(multisourcefs)
| 3172 | |
| 3173 | |
| 3174 | def test_dataset_union(multisourcefs): |
| 3175 | child = ds.FileSystemDatasetFactory( |
| 3176 | multisourcefs, fs.FileSelector('/plain'), |
| 3177 | format=ds.ParquetFileFormat() |
| 3178 | ) |
| 3179 | factory = ds.UnionDatasetFactory([child]) |
| 3180 | |
| 3181 | # TODO(bkietz) reintroduce factory.children property |
| 3182 | assert len(factory.inspect_schemas()) == 1 |
| 3183 | assert all(isinstance(s, pa.Schema) for s in factory.inspect_schemas()) |
| 3184 | assert factory.inspect_schemas()[0].equals(child.inspect()) |
| 3185 | assert factory.inspect().equals(child.inspect()) |
| 3186 | assert isinstance(factory.finish(), ds.Dataset) |
| 3187 | |
| 3188 | |
| 3189 | def test_union_dataset_from_other_datasets(tempdir, multisourcefs): |
nothing calls this directly
no test coverage detected