(mockfs)
| 270 | |
| 271 | @pytest.fixture |
| 272 | def dataset(mockfs): |
| 273 | format = ds.ParquetFileFormat() |
| 274 | selector = fs.FileSelector('subdir', recursive=True) |
| 275 | options = ds.FileSystemFactoryOptions('subdir') |
| 276 | options.partitioning = ds.DirectoryPartitioning( |
| 277 | pa.schema([ |
| 278 | pa.field('group', pa.int32()), |
| 279 | pa.field('key', pa.string()) |
| 280 | ]) |
| 281 | ) |
| 282 | factory = ds.FileSystemDatasetFactory(mockfs, selector, format, options) |
| 283 | return factory.finish() |
| 284 | |
| 285 | |
| 286 | @pytest.fixture(params=[ |
nothing calls this directly
no test coverage detected