(multisourcefs)
| 1212 | |
| 1213 | @pytest.mark.parquet |
| 1214 | def test_make_fragment(multisourcefs): |
| 1215 | parquet_format = ds.ParquetFileFormat() |
| 1216 | dataset = ds.dataset('/plain', filesystem=multisourcefs, |
| 1217 | format=parquet_format) |
| 1218 | |
| 1219 | for path in dataset.files: |
| 1220 | fragment = parquet_format.make_fragment(path, multisourcefs) |
| 1221 | assert fragment.row_groups == [0] |
| 1222 | |
| 1223 | row_group_fragment = parquet_format.make_fragment(path, multisourcefs, |
| 1224 | row_groups=[0]) |
| 1225 | for f in [fragment, row_group_fragment]: |
| 1226 | assert isinstance(f, ds.ParquetFileFragment) |
| 1227 | assert f.path == path |
| 1228 | assert isinstance(f.filesystem, type(multisourcefs)) |
| 1229 | assert row_group_fragment.row_groups == [0] |
| 1230 | |
| 1231 | |
| 1232 | @pytest.mark.parquet |
nothing calls this directly
no test coverage detected