(Experimental) RandomAccessDataset API
(Experimental) RandomAccessDataset API#
- class ray.data.random_access_dataset.RandomAccessDataset(dataset: Dataset[T], key: str, num_workers: int)[source]#
A class that provides distributed, random access to a Dataset.
See:
Dataset.to_random_access_dataset()
.PublicAPI (beta): This API is in beta and may change before becoming stable.
- get_async(key: Any) ray.types.ObjectRef[Optional[ray.data.block.T]] [source]#
Asynchronously finds the record for a single key.
- Parameters
key – The key of the record to find.
- Returns
ObjectRef containing the record (in pydict form), or None if not found.