U d@s<ddlmZddlmZmZddlmZGdddeZdS))schema) ModelLayerget_layer_class)SamplingTrainableMixincs.eZdZd fdd ZddZddZZS) SamplingTrainTsampling_trainc  stt|j||f|t|}t|ts.td|ks:tt|jt j sPtdd|ks\t||_ |j rtd|kstt||j fd|i||_ fdd|j jD|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).0ZblobmodelG/tmp/pip-unpacked-wheel-ua33x9lu/caffe2/python/layers/sampling_train.py /sz*SamplingTrain.__init__..)superr__init__r issubclassrAssertionError isinstancerrZScalarsubtract_log_oddr _prediction_layer param_blobstrain_param_blobsparams output_schema) selfr input_recordZprediction_layerr rnamekwargsZ layer_class __class__rrrs<       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)ziprrrZGatherr r add_train_opsrLogr ZNextScopedBlobZSubr)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