o bi@szddlZddlmZddlmZmZddlmZmZddl m Z eGdddZ Gdd d e Z Gd d d ej d ZdS) N) dataclass)AnyList)Block DataBatch) ObjectRefc@"eZdZUdZeed<eed<dS)BatchzA batch of data with a corresponding index. Attributes: batch_idx: The global index of this batch so that downstream operations can maintain ordering. data: The batch of data. batch_idxdataN)__name__ __module__ __qualname____doc__int__annotations__rrr`/home/ubuntu/.local/lib/python3.10/site-packages/ray/data/_internal/block_batching/interfaces.pyr s  r c@r) CollatedBatchaHA batch of collated data with a corresponding index. Attributes: batch_idx: The global index of this batch so that downstream operations can maintain ordering. data: The batch of data which is the output of a user provided collate_fn Therefore, the type of this data can be Any. r r N)r r rrrrrrrrrrs  rc@s4eZdZdZejdeeefddZ ddZ dS)BlockPrefetcherz!Interface for prefetching blocks.blockscCdS)z*Prefetch the provided blocks to this node.Nr)selfrrrrprefetch_blocks(szBlockPrefetcher.prefetch_blockscCr)z'Stop prefetching and release resources.Nr)rrrrstop-szBlockPrefetcher.stopN) r r rrabcabstractmethodrrrrrrrrrr%s  r) metaclass)r dataclassesrtypingrrray.data.blockrr ray.typesrr rABCMetarrrrrs