(tempdir, dataset_reader)
| 3702 | |
| 3703 | @pytest.mark.filterwarnings("ignore:pyarrow.feather:FutureWarning") |
| 3704 | def test_feather_format(tempdir, dataset_reader): |
| 3705 | from pyarrow.feather import write_feather |
| 3706 | |
| 3707 | table = pa.table({'a': pa.array([1, 2, 3], type="int8"), |
| 3708 | 'b': pa.array([.1, .2, .3], type="float64")}) |
| 3709 | |
| 3710 | basedir = tempdir / "feather_dataset" |
| 3711 | basedir.mkdir() |
| 3712 | write_feather(table, str(basedir / "data.feather")) |
| 3713 | |
| 3714 | dataset = ds.dataset(basedir, format=ds.IpcFileFormat()) |
| 3715 | result = dataset_reader.to_table(dataset) |
| 3716 | assert result.equals(table) |
| 3717 | |
| 3718 | assert_dataset_fragment_convenience_methods(dataset) |
| 3719 | |
| 3720 | dataset = ds.dataset(basedir, format="feather") |
| 3721 | result = dataset_reader.to_table(dataset) |
| 3722 | assert result.equals(table) |
| 3723 | |
| 3724 | # ARROW-8641 - column selection order |
| 3725 | result = dataset_reader.to_table(dataset, columns=["b", "a"]) |
| 3726 | assert result.column_names == ["b", "a"] |
| 3727 | result = dataset_reader.to_table(dataset, columns=["a", "a"]) |
| 3728 | assert result.column_names == ["a", "a"] |
| 3729 | |
| 3730 | # error with Feather v1 files |
| 3731 | write_feather(table, str(basedir / "data1.feather"), version=1) |
| 3732 | with pytest.raises(ValueError): |
| 3733 | dataset_reader.to_table(ds.dataset(basedir, format="feather")) |
| 3734 | |
| 3735 | |
| 3736 | @pytest.mark.pandas |
nothing calls this directly
no test coverage detected