in datafusion_ray/core.py [0:0]
def __init__(
self,
batch_size: int = 8192,
prefetch_buffer_size: int = 0,
partitions_per_processor: int | None = None,
processor_pool_min: int = 1,
processor_pool_max: int = 100,