def __init__()

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,