a ==ic@s<ddlmZddlmZmZddlmZGdddeZdS))schema) ModelLayerget_layer_class)SamplingTrainableMixincs.eZdZd fdd ZddZddZZS) SamplingTrainTsampling_trainc  stt|j||fi|t|}t|ts2Jd|vs>Jt|jtj sTJdd|vs`J||_ |j rxd|vsxJ||j fd|i||_ fdd|j j D|j _|j j|_|j j|_dS)Nindicesz6input_record.indices is expected to be a schema.Scalarinput sampling_prob output_dimscs g|]}jt|dqS)Z_sampled)netZNextBlobstr).0Zblobmodelt/home/droni/.local/share/virtualenvs/DPS-5Je3_V2c/lib/python3.9/site-packages/caffe2/python/layers/sampling_train.py /sz*SamplingTrain.__init__..)superr__init__r issubclassr isinstancerrZScalarsubtract_log_oddr _prediction_layer param_blobstrain_param_blobsparams output_schema) selfr input_recordZprediction_layerr rnamekwargsZ layer_class __class__rrrs8       zSamplingTrain.__init__cCs|j|dS)N)radd_ops)rr rrrr$8szSamplingTrain.add_opscCst|jj|jjD]\}}|||jg|q|j||jsHdS| |j | d}|j | |g| ddddS)Nlog_q) broadcastZ use_grad_hack)ziprrrZGatherrr add_train_opsrLogr ZNextScopedBlobSubr)rr Z full_blobZ sampled_blobr%rrrr);s   zSamplingTrain.add_train_ops)Tr)__name__ __module__ __qualname__rr$r) __classcell__rrr"rr s *rN)Z caffe2.pythonrZcaffe2.python.layers.layersrrZ-caffe2.python.layers.sampling_trainable_mixinrrrrrrs