(func_maker)
| 728 | |
| 729 | |
| 730 | def _test_datasource1_udt(func_maker): |
| 731 | schema = datasource1_schema() |
| 732 | func = func_maker() |
| 733 | func_name = func_maker.__name__ |
| 734 | func_args = datasource1_args(func, func_name) |
| 735 | pc.register_tabular_function(*func_args) |
| 736 | n = 3 |
| 737 | for item in pc.call_tabular_function(func_name): |
| 738 | n -= 1 |
| 739 | assert item == _record_batch_for_range(schema, n) |
| 740 | |
| 741 | |
| 742 | def test_udt_datasource1_direct(): |
no test coverage detected