ray.data.Datasource.create_reader

Datasource.create_reader(**read_args) → ray.data.datasource.datasource.Reader

Return a Reader for the given read arguments.

The reader object will be responsible for querying the read metadata, and generating the actual read tasks to retrieve the data blocks upon request.

Parameters

read_args – Additional kwargs to pass to the datasource impl.