docs: public static SourceScheduler newSourcePartitionedSchedulerAsSourceScheduler(
              SqlStageExecution stage,
              PlanNodeId partitionedNode,
              SplitSource splitSource,
              SplitPlacementPolicy splitPlacementPolicy,
              int splitBatchSize,
              boolean groupedExecution)
      {
          return new SourcePartitionedScheduler(stage, partitionedNode, splitSource, splitPlacementPolicy, splitBatchSize, groupedExecution);
      }