def __init__()

in datafusion_ray/core.py [0:0]

• 7 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(
        self,
        internal_df: DFRayDataFrameInternal,
        supervisor,  # ray.actor.ActorHandle[DFRayContextSupervisor],
        batch_size=8192,
        partitions_per_processor: int | None = None,
        prefetch_buffer_size=0,