
    [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dS )    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dS )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    K/var/www/icac/venv/lib/python3.11/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                   R    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
dS )r   zSamples elements sequentially, always in the same order.

    Args:
        data_source (Sized): data source to sample from. Must implement __len__.
    data_sourcer   Nc                     || _         d S r   )r!   )r   r!   s     r   __init__zSequentialSampler.__init__j   s    &r   c                 ^    t          t          t          | j                                      S r   )iterrangelenr!   r   s    r   r   zSequentialSampler.__iter__m   s#    E#d.//001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 2 2 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dS )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!   replacementFNnum_samplesr   c                    || _         || _        || _        || _        t	          | j        t
                    st          d| j                   t	          | j        t                    r| j        dk    rt          d| j                   d S )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1 	`dN^``   $*C00 	D4D4I4IiW[Wgii   5J4Ir   c                 F    | 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        zt          t	          j        dt          j                                                                                            }t	          j	                    }|
                    |           n| j        }| j        rt          | j        dz            D ]<}t	          j        |dt          j        |                                          E d {V  =t	          j        || j        dz  ft          j        |                                          E d {V  d S t          | j        |z            D ]0}t	          j        ||                                          E d {V  1t	          j        ||                                          d | j        |z           E d {V  d S )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99AACCHHJJKKD))I!!$''''I 	4+r122   =ekY  &((        }&+-k#	  
 fhh         4+q011 K K >!yAAAHHJJJJJJJJJJ~a9===DDFF&$"Q&&         r   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 ! ! ! X!(3-    6             r   r
   c                   l    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
dS )	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                 "    || _         || _        d S r   )rR   r3   )r   rR   r3   s      r   r#   zSubsetRandomSampler.__init__   s    "r   c              #      K   t          j        t          | j                  | j                                                  D ]}| j        |         V  d S Nr?   )r@   rI   r'   rR   r3   rH   )r   is     r   r   zSubsetRandomSampler.__iter__   s[      DL 1 1T^LLLSSUU 	" 	"A,q/!!!!	" 	"r   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      s           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dS )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-   TNr   c                    t          |t                    rt          |t                    s|dk    rt          d|           t          |t                    st          d|           t	          j        |t          j                  }t          |j                  dk    r$t          dt          |j                             || _
        || _        || _        || _        d S )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dWbdd   +t,, 	[k[[   EEE~#$$))D&+N,@&A&AD D  
 &&&"r   c              #      K   t          j        | j        | j        | j        | j                  }t          |                                          E d {V  d S rU   )r@   multinomialrY   r.   r-   r3   r%   rH   )r   rand_tensors     r   r   zWeightedRandomSampler.__iter__  sd      'L$*D,<
 
 
 **,,-----------r   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      s          4 \ !# #%# # 	# 
# # # #@.(3- . . . .             r   r   c                   x    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dS )
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|           || _        || _        || _        d S )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  s     :s++	*d++	 QaU_aa   )T** 	U)UU   $"r   c              #     K   t          | j                  }| j        r"|g| j        z  }t	          |ddiD ]}g |V  	d S g t          j        || j                  }|r$|V  g t          j        || j                  }|"d S d S )NstrictF)r%   rh   rj   ri   zip	itertoolsislice)r   sampler_iterargsbatch_droplastbatchs        r   r   zBatchSampler.__iter__M  s      DL))> 		K >DO3D"%t":E":": ( (''''''( ( Gi&|T_EEFE KJ)*<IIJ  K K K K Kr   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    
 > 	Pt|$$77%%7!;OOr   )r   r   r   r   r   r+   r   r5   r#   r   listr   r)   r   r   r   r	   r	     s         *#-# # 	#
 
# # # #2K(49- K K K KP P P P P 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  H  H  H  H GCL H  H  H V! ! ! ! !'#, ! ! !,F  F  F  F  F GCL F  F  F RDP DP DP DP DP749% DP DP DP DP DPr   