()
| 695 | |
| 696 | |
| 697 | def datasource1_generator(): |
| 698 | schema = datasource1_schema() |
| 699 | |
| 700 | def batch_gen(ctx): |
| 701 | for n in range(3, 0, -1): |
| 702 | # ctx = |
| 703 | yield _record_batch_for_range(schema, n - 1) |
| 704 | return make_udt_func(schema, batch_gen) |
| 705 | |
| 706 | |
| 707 | def datasource1_exception(): |
nothing calls this directly
no test coverage detected