
    i1                        d dl Z d dlmZmZmZmZ d dlmZmZ d dl	Z	g dZ
 edd      Z G d d	ee         Z G d
 dee         Z G d dee         Z G d dee         Z G d dee         Z G d deee            Zy)    N)IterableIteratorSequenceSized)GenericTypeVar)BatchSamplerRandomSamplerSamplerSequentialSamplerSubsetRandomSamplerWeightedRandomSampler_T_coT)	covariantc                   "    e Zd ZdZdee   fdZy)r   a  Base class for all Samplers.

    Every Sampler subclass has to provide an :meth:`__iter__` method, providing a
    way to iterate over indices or lists of indices (batches) of dataset elements,
    and may provide a :meth:`__len__` method that returns the length of the returned iterators.

    Example:
        >>> # xdoctest: +SKIP
        >>> class AccedingSequenceLengthSampler(Sampler[int]):
        >>>     def __init__(self, data: List[str]) -> None:
        >>>         self.data = data
        >>>
        >>>     def __len__(self) -> int:
        >>>         return len(self.data)
        >>>
        >>>     def __iter__(self) -> Iterator[int]:
        >>>         sizes = torch.tensor([len(x) for x in self.data])
        >>>         yield from torch.argsort(sizes).tolist()
        >>>
        >>> class AccedingSequenceLengthBatchSampler(Sampler[List[int]]):
        >>>     def __init__(self, data: List[str], batch_size: int) -> None:
        >>>         self.data = data
        >>>         self.batch_size = batch_size
        >>>
        >>>     def __len__(self) -> int:
        >>>         return (len(self.data) + self.batch_size - 1) // self.batch_size
        >>>
        >>>     def __iter__(self) -> Iterator[List[int]]:
        >>>         sizes = torch.tensor([len(x) for x in self.data])
        >>>         for batch in torch.chunk(torch.argsort(sizes), len(self)):
        >>>             yield batch.tolist()

    .. note:: The :meth:`__len__` method isn't strictly required by
              :class:`~torch.utils.data.DataLoader`, but is expected in any
              calculation involving the length of a :class:`~torch.utils.data.DataLoader`.
    returnc                     t         N)NotImplementedErrorselfs    R/var/www/html/engine/venv/lib/python3.12/site-packages/torch/utils/data/sampler.py__iter__zSampler.__iter__B   s    !!    N)__name__
__module____qualname____doc__r   r   r    r   r   r   r      s    #J"(5/ "r   r   c                   J    e Zd ZU dZeed<   deddfdZdee   fdZ	defdZ
y)r   zSamples elements sequentially, always in the same order.

    Args:
        data_source (Sized): data source to sample from. Must implement __len__.
    data_sourcer   Nc                     || _         y r   )r!   )r   r!   s     r   __init__zSequentialSampler.__init__j   s
    &r   c                 P    t        t        t        | j                                    S r   )iterrangelenr!   r   s    r   r   zSequentialSampler.__iter__m   s    E#d../011r   c                 ,    t        | j                        S r   )r'   r!   r   s    r   __len__zSequentialSampler.__len__p   s    4##$$r   )r   r   r   r   r   __annotations__r#   r   intr   r)   r   r   r   r   r   a   s>     'E 'd '2(3- 2% %r   r   c            	           e Zd ZU dZeed<   eed<   	 	 	 ddedededz  ddfdZe	defd       Z
dee   fd	Zdefd
Zy)r
   a  Samples elements randomly. If without replacement, then sample from a shuffled dataset.

    If with replacement, then user can specify :attr:`num_samples` to draw.

    Args:
        data_source (Sized): data source to sample from. Must implement __len__.
        replacement (bool): samples are drawn on-demand with replacement if ``True``, default=``False``
        num_samples (int): number of samples to draw, default=`len(dataset)`.
        generator (Generator): Generator used in sampling.
    r!   replacementNnum_samplesr   c                 "   || _         || _        || _        || _        t	        | j                  t
              st        d| j                         t	        | j                  t              r| j                  dk  rt        d| j                         y )N;replacement should be a boolean value, but got replacement=r   Dnum_samples should be a positive integer value, but got num_samples=)
r!   r-   _num_samples	generator
isinstancebool	TypeErrorr.   r+   
ValueError)r   r!   r-   r.   r3   s        r   r#   zRandomSampler.__init__   s     '&'"$**D1MdN^N^M_`  $**C0D4D4D4IVW[WgWgVhi  5Jr   c                 \    | j                   t        | j                        S | j                   S r   )r2   r'   r!   r   s    r   r.   zRandomSampler.num_samples   s-     $t''((   r   c              #     K   t        | j                        }| j                  pt        t	        j
                  dt        j                        j                         j                               }t	        j                         }|j                  |       n| j                  }| j                  rt        | j                  dz        D ]?  }t	        j                  |dt        j                  |      j                         E d {    A t	        j                  || j                  dz  ft        j                  |      j                         E d {    y t        | j                  |z        D ]/  }t	        j                   ||      j                         E d {    1 t	        j                   ||      j                         d | j                  |z   E d {    y 7 7 7 H7 w)Nr   dtype    )r<   )highsizer;   r3   r3   )r'   r!   r3   r+   torchemptyint64random_item	Generatormanual_seedr-   r&   r.   randinttolistrandperm)r   nseedr3   _s        r   r   zRandomSampler.__iter__   s      !>>!u{{2U[[9AACHHJKD)I!!$'I4++r12  ==ekkY&(  }}&&+-kk#	
 fh  4++q01 K >>!yAHHJJJK~~a9=DDF&$""Q&   KsJ   C=G"?G AG"GAG"G>G"G G"G"G" G"c                     | j                   S r   r.   r   s    r   r)   zRandomSampler.__len__       r   )FNN)r   r   r   r   r   r*   r5   r+   r#   propertyr.   r   r   r)   r   r   r   r
   r
   t   s    	 
 ""&  4Z	 
, !S ! !(3- 6   r   r
   c                   X    e Zd ZU dZee   ed<   ddee   ddfdZdee   fdZ	defdZ
y)	r   zSamples elements randomly from a given list of indices, without replacement.

    Args:
        indices (sequence): a sequence of indices
        generator (Generator): Generator used in sampling.
    indicesNr   c                      || _         || _        y r   )rR   r3   )r   rR   r3   s      r   r#   zSubsetRandomSampler.__init__   s    "r   c              #      K   t        j                  t        | j                        | j                        j                         D ]  }| j                  |     y wNr?   )r@   rI   r'   rR   r3   rH   )r   is     r   r   zSubsetRandomSampler.__iter__   sD     DLL 1T^^LSSU 	"A,,q/!	"s   AAc                 ,    t        | j                        S r   )r'   rR   r   s    r   r)   zSubsetRandomSampler.__len__   s    4<<  r   r   )r   r   r   r   r   r+   r*   r#   r   r   r)   r   r   r   r   r      sF     c]# #$ #"(3- "! !r   r   c            	           e Zd ZU dZej
                  ed<   eed<   eed<   	 	 d
de	e
   dededdfdZdee   fdZdefd	Zy)r   a  Samples elements from ``[0,..,len(weights)-1]`` with given probabilities (weights).

    Args:
        weights (sequence)   : a sequence of weights, not necessary summing up to one
        num_samples (int): number of samples to draw
        replacement (bool): if ``True``, samples are drawn with replacement.
            If not, they are drawn without replacement, which means that when a
            sample index is drawn for a row, it cannot be drawn again for that row.
        generator (Generator): Generator used in sampling.

    Example:
        >>> # xdoctest: +IGNORE_WANT("non-deterministic")
        >>> list(
        ...     WeightedRandomSampler(
        ...         [0.1, 0.9, 0.4, 0.7, 3.0, 0.6], 5, replacement=True
        ...     )
        ... )
        [4, 4, 1, 4, 5]
        >>> list(
        ...     WeightedRandomSampler(
        ...         [0.9, 0.4, 0.05, 0.2, 0.3, 0.1], 5, replacement=False
        ...     )
        ... )
        [0, 1, 4, 3, 2]
    weightsr.   r-   Nr   c                    t        |t              rt        |t              s|dk  rt        d|       t        |t              st        d|       t	        j
                  |t        j                        }t        |j                        dk7  r!t        dt        |j                               || _
        || _        || _        || _        y )Nr   r1   r0   r:      z=weights should be a 1d sequence but given weights have shape )r4   r+   r5   r7   r@   	as_tensordoubler'   shapetuplerY   r.   r-   r3   )r   rY   r.   r-   r3   weights_tensors         r   r#   zWeightedRandomSampler.__init__   s     ;,+t,aVWbVcd  +t,Mk][  E~##$)&&+N,@,@&A%BD 
 &&&"r   c              #      K   t        j                  | j                  | j                  | j                  | j
                        }t        |j                               E d {    y 7 wrU   )r@   multinomialrY   r.   r-   r3   r%   rH   )r   rand_tensors     r   r   zWeightedRandomSampler.__iter__  sL     ''LL$**D,<,<
 **,---s   AA( A&!A(c                     | j                   S r   rN   r   s    r   r)   zWeightedRandomSampler.__len__  rO   r   )TN)r   r   r   r   r@   Tensorr*   r+   r5   r   floatr#   r   r   r)   r   r   r   r   r      ss    4 \\ !#%# # 	# 
#@.(3- .   r   r   c                   ^    e Zd ZdZdee   ee   z  dededdfdZde	e
e      fdZdefd	Zy)
r	   a  Wraps another sampler to yield a mini-batch of indices.

    Args:
        sampler (Sampler or Iterable): Base sampler. Can be any iterable object
        batch_size (int): Size of mini-batch.
        drop_last (bool): If ``True``, the sampler will drop the last batch if
            its size would be less than ``batch_size``

    Example:
        >>> list(
        ...     BatchSampler(
        ...         SequentialSampler(range(10)), batch_size=3, drop_last=False
        ...     )
        ... )
        [[0, 1, 2], [3, 4, 5], [6, 7, 8], [9]]
        >>> list(
        ...     BatchSampler(SequentialSampler(range(10)), batch_size=3, drop_last=True)
        ... )
        [[0, 1, 2], [3, 4, 5], [6, 7, 8]]
    sampler
batch_size	drop_lastr   Nc                     t        |t              rt        |t              s|dk  rt        d|       t        |t              st        d|       || _        || _        || _        y )Nr   zBbatch_size should be a positive integer value, but got batch_size=z7drop_last should be a boolean value, but got drop_last=)r4   r+   r5   r7   rh   ri   rj   )r   rh   ri   rj   s       r   r#   zBatchSampler.__init__4  sr     :s+*d+QTU_T`a  )T*I)U  $"r   c              #   8  K   t        | j                        }| j                  r'|g| j                  z  }t	        |ddiD ]  }g | 
 y g t        j                  || j                        }|r*| g t        j                  || j                        }|r)y y w)NstrictF)r%   rh   rj   ri   zip	itertoolsislice)r   sampler_iterargsbatch_droplastbatchs        r   r   zBatchSampler.__iter__M  s     DLL)>> >DOO3D"%t":E": ('''( Gi&&|T__EFEJ)**<IJ s   BBBc                     | j                   r"t        | j                        | j                  z  S t        | j                        | j                  z   dz
  | j                  z  S )Nr[   )rj   r'   rh   ri   r   s    r   r)   zBatchSampler.__len__Z  sI    
 >>t||$77%7!;OOr   )r   r   r   r   r   r+   r   r5   r#   r   listr   r)   r   r   r   r	   r	     sd    *#-# # 	#
 
#2K(49- KP Pr   r	   )ro   collections.abcr   r   r   r   typingr   r   r@   __all__r   r   r+   r   r
   r   r   rv   r	   r   r   r   <module>rz      s     ? ? #  	4('"gen '"J% %&H GCL H V!'#, !,F GCL F RDP749% DPr   