ray.data.Datasource.get_read_tasks

Datasource.get_read_tasks(parallelism: int) → List[ReadTask]

执行读取并返回读取任务。

参数:

parallelism – 请求的读取并行性。如果可能，读取任务的数量应等于此值。

返回:

可以并行执行的读取任务列表，用于从数据源读取块。