Source code for pycbc.events.ranking

""" This module contains functions for calculating single-ifo ranking
statistic values
"""
import numpy


[docs]def effsnr(snr, reduced_x2, fac=250.): """Calculate the effective SNR statistic. See (S5y1 paper) for definition. """ snr = numpy.array(snr, ndmin=1, dtype=numpy.float64) rchisq = numpy.array(reduced_x2, ndmin=1, dtype=numpy.float64) esnr = snr / (1 + snr ** 2 / fac) ** 0.25 / rchisq ** 0.25 # If snr input is float, return a float. Otherwise return numpy array. if hasattr(snr, '__len__'): return esnr else: return esnr[0]
[docs]def newsnr(snr, reduced_x2, q=6., n=2.): """Calculate the re-weighted SNR statistic ('newSNR') from given SNR and reduced chi-squared values. See http://arxiv.org/abs/1208.3491 for definition. Previous implementation in glue/ligolw/lsctables.py """ nsnr = numpy.array(snr, ndmin=1, dtype=numpy.float64) reduced_x2 = numpy.array(reduced_x2, ndmin=1, dtype=numpy.float64) # newsnr is only different from snr if reduced chisq > 1 ind = numpy.where(reduced_x2 > 1.)[0] nsnr[ind] *= (0.5 * (1. + reduced_x2[ind] ** (q/n))) ** (-1./q) # If snr input is float, return a float. Otherwise return numpy array. if hasattr(snr, '__len__'): return nsnr else: return nsnr[0]
[docs]def newsnr_sgveto(snr, brchisq, sgchisq): """ Combined SNR derived from NewSNR and Sine-Gaussian Chisq""" nsnr = numpy.array(newsnr(snr, brchisq), ndmin=1) sgchisq = numpy.array(sgchisq, ndmin=1) t = numpy.array(sgchisq > 4, ndmin=1) if len(t): nsnr[t] = nsnr[t] / (sgchisq[t] / 4.0) ** 0.5 # If snr input is float, return a float. Otherwise return numpy array. if hasattr(snr, '__len__'): return nsnr else: return nsnr[0]
[docs]def newsnr_sgveto_psdvar(snr, brchisq, sgchisq, psd_var_val, min_expected_psdvar=0.65): """ Combined SNR derived from SNR, reduced Allen chisq, sine-Gaussian chisq and PSD variation statistic""" # If PSD var is lower than the 'minimum usually expected value' stop this # being used in the statistic. This low value might arise because a # significant fraction of the "short" PSD period was gated (for instance). psd_var_val = numpy.array(psd_var_val, copy=True) psd_var_val[psd_var_val < min_expected_psdvar] = 1. scaled_snr = snr * (psd_var_val ** -0.5) scaled_brchisq = brchisq * (psd_var_val ** -1.) nsnr = newsnr_sgveto(scaled_snr, scaled_brchisq, sgchisq) # If snr input is float, return a float. Otherwise return numpy array. if hasattr(snr, '__len__'): return nsnr else: return nsnr[0]
[docs]def newsnr_sgveto_psdvar_threshold(snr, brchisq, sgchisq, psd_var_val, min_expected_psdvar=0.65, brchisq_threshold=10.0, psd_var_val_threshold=10.0): """ newsnr_sgveto_psdvar with thresholds applied. This is the newsnr_sgveto_psdvar statistic with additional options to threshold on chi-squared or PSD variation. """ nsnr = newsnr_sgveto_psdvar(snr, brchisq, sgchisq, psd_var_val, min_expected_psdvar=min_expected_psdvar) nsnr = numpy.array(nsnr, ndmin=1) nsnr[brchisq > brchisq_threshold] = 1. nsnr[psd_var_val > psd_var_val_threshold] = 1. # If snr input is float, return a float. Otherwise return numpy array. if hasattr(snr, '__len__'): return nsnr else: return nsnr[0]
[docs]def newsnr_sgveto_psdvar_scaled(snr, brchisq, sgchisq, psd_var_val, scaling=0.33, min_expected_psdvar=0.65): """ Combined SNR derived from NewSNR, Sine-Gaussian Chisq and scaled PSD variation statistic. """ nsnr = numpy.array(newsnr_sgveto(snr, brchisq, sgchisq), ndmin=1) psd_var_val = numpy.array(psd_var_val, ndmin=1, copy=True) psd_var_val[psd_var_val < min_expected_psdvar] = 1. # Default scale is 0.33 as tuned from analysis of data from O2 chunks nsnr = nsnr / psd_var_val ** scaling # If snr input is float, return a float. Otherwise return numpy array. if hasattr(snr, '__len__'): return nsnr else: return nsnr[0]
[docs]def newsnr_sgveto_psdvar_scaled_threshold(snr, bchisq, sgchisq, psd_var_val, threshold=2.0): """ Combined SNR derived from NewSNR and Sine-Gaussian Chisq, and scaled psd variation. """ nsnr = newsnr_sgveto_psdvar_scaled(snr, bchisq, sgchisq, psd_var_val) nsnr = numpy.array(nsnr, ndmin=1) nsnr[bchisq > threshold] = 1. # If snr input is float, return a float. Otherwise return numpy array. if hasattr(snr, '__len__'): return nsnr else: return nsnr[0]
[docs]def get_snr(trigs): """ Return SNR from a trigs/dictionary object Parameters ---------- trigs: dict of numpy.ndarrays, h5py group (or similar dict-like object) Dictionary-like object holding single detector trigger information. 'snr' is a required key Returns ------- numpy.ndarray Array of snr values """ return numpy.array(trigs['snr'][:], ndmin=1, dtype=numpy.float32)
[docs]def get_newsnr(trigs): """ Calculate newsnr ('reweighted SNR') for a trigs/dictionary object Parameters ---------- trigs: dict of numpy.ndarrays, h5py group (or similar dict-like object) Dictionary-like object holding single detector trigger information. 'chisq_dof', 'snr', and 'chisq' are required keys Returns ------- numpy.ndarray Array of newsnr values """ dof = 2. * trigs['chisq_dof'][:] - 2. nsnr = newsnr(trigs['snr'][:], trigs['chisq'][:] / dof) return numpy.array(nsnr, ndmin=1, dtype=numpy.float32)
[docs]def get_newsnr_sgveto(trigs): """ Calculate newsnr re-weigthed by the sine-gaussian veto Parameters ---------- trigs: dict of numpy.ndarrays, h5py group (or similar dict-like object) Dictionary-like object holding single detector trigger information. 'chisq_dof', 'snr', 'sg_chisq' and 'chisq' are required keys Returns ------- numpy.ndarray Array of newsnr values """ dof = 2. * trigs['chisq_dof'][:] - 2. nsnr_sg = newsnr_sgveto(trigs['snr'][:], trigs['chisq'][:] / dof, trigs['sg_chisq'][:]) return numpy.array(nsnr_sg, ndmin=1, dtype=numpy.float32)
[docs]def get_newsnr_sgveto_psdvar(trigs): """ Calculate snr re-weighted by Allen chisq, sine-gaussian veto and psd variation statistic Parameters ---------- trigs: dict of numpy.ndarrays Dictionary holding single detector trigger information. 'chisq_dof', 'snr', 'chisq' and 'psd_var_val' are required keys Returns ------- numpy.ndarray Array of newsnr values """ dof = 2. * trigs['chisq_dof'][:] - 2. nsnr_sg_psd = \ newsnr_sgveto_psdvar(trigs['snr'][:], trigs['chisq'][:] / dof, trigs['sg_chisq'][:], trigs['psd_var_val'][:]) return numpy.array(nsnr_sg_psd, ndmin=1, dtype=numpy.float32)
[docs]def get_newsnr_sgveto_psdvar_threshold(trigs): """ Calculate newsnr re-weighted by the sine-gaussian veto and scaled psd variation statistic Parameters ---------- trigs: dict of numpy.ndarrays Dictionary holding single detector trigger information. 'chisq_dof', 'snr', 'chisq' and 'psd_var_val' are required keys Returns ------- numpy.ndarray Array of newsnr values """ dof = 2. * trigs['chisq_dof'][:] - 2. nsnr_sg_psdt = newsnr_sgveto_psdvar_threshold( trigs['snr'][:], trigs['chisq'][:] / dof, trigs['sg_chisq'][:], trigs['psd_var_val'][:] ) return numpy.array(nsnr_sg_psdt, ndmin=1, dtype=numpy.float32)
[docs]def get_newsnr_sgveto_psdvar_scaled(trigs): """ Calculate newsnr re-weighted by the sine-gaussian veto and scaled psd variation statistic Parameters ---------- trigs: dict of numpy.ndarrays Dictionary holding single detector trigger information. 'chisq_dof', 'snr', 'chisq' and 'psd_var_val' are required keys Returns ------- numpy.ndarray Array of newsnr values """ dof = 2. * trigs['chisq_dof'][:] - 2. nsnr_sg_psdscale = \ newsnr_sgveto_psdvar_scaled( trigs['snr'][:], trigs['chisq'][:] / dof, trigs['sg_chisq'][:], trigs['psd_var_val'][:]) return numpy.array(nsnr_sg_psdscale, ndmin=1, dtype=numpy.float32)
[docs]def get_newsnr_sgveto_psdvar_scaled_threshold(trigs): """ Calculate newsnr re-weighted by the sine-gaussian veto and scaled psd variation statistic. A further threshold is applied to the reduced chisq. Parameters ---------- trigs: dict of numpy.ndarrays Dictionary holding single detector trigger information. 'chisq_dof', 'snr', 'chisq' and 'psd_var_val' are required keys Returns ------- numpy.ndarray Array of newsnr values """ dof = 2. * trigs['chisq_dof'][:] - 2. nsnr_sg_psdt = \ newsnr_sgveto_psdvar_scaled_threshold( trigs['snr'][:], trigs['chisq'][:] / dof, trigs['sg_chisq'][:], trigs['psd_var_val'][:]) return numpy.array(nsnr_sg_psdt, ndmin=1, dtype=numpy.float32)
sngls_ranking_function_dict = { 'snr': get_snr, 'newsnr': get_newsnr, 'new_snr': get_newsnr, 'newsnr_sgveto': get_newsnr_sgveto, 'newsnr_sgveto_psdvar': get_newsnr_sgveto_psdvar, 'newsnr_sgveto_psdvar_threshold': get_newsnr_sgveto_psdvar_threshold, 'newsnr_sgveto_psdvar_scaled': get_newsnr_sgveto_psdvar_scaled, 'newsnr_sgveto_psdvar_scaled_threshold': get_newsnr_sgveto_psdvar_scaled_threshold, } # Lists of datasets required in the trigs object for each function required_datasets = {} required_datasets['snr'] = ['snr'] required_datasets['newsnr'] = required_datasets['snr'] + ['chisq', 'chisq_dof'] required_datasets['new_snr'] = required_datasets['newsnr'] required_datasets['newsnr_sgveto'] = required_datasets['newsnr'] + ['sg_chisq'] required_datasets['newsnr_sgveto_psdvar'] = \ required_datasets['newsnr_sgveto'] + ['psd_var_val'] required_datasets['newsnr_sgveto_psdvar_threshold'] = \ required_datasets['newsnr_sgveto_psdvar'] required_datasets['newsnr_sgveto_psdvar_scaled'] = \ required_datasets['newsnr_sgveto_psdvar'] required_datasets['newsnr_sgveto_psdvar_scaled_threshold'] = \ required_datasets['newsnr_sgveto_psdvar']
[docs]def get_sngls_ranking_from_trigs(trigs, statname, **kwargs): """ Return ranking for all trigs given a statname. Compute the single-detector ranking for a list of input triggers for a specific statname. Parameters ----------- trigs: dict of numpy.ndarrays, SingleDetTriggers or ReadByTemplate Dictionary holding single detector trigger information. statname: The statistic to use. """ # Identify correct function try: sngl_func = sngls_ranking_function_dict[statname] except KeyError as exc: err_msg = 'Single-detector ranking {} not recognized'.format(statname) raise ValueError(err_msg) from exc # NOTE: In the sngl_funcs all the kwargs are explicitly stated, so any # kwargs sent here must be known to the function. return sngl_func(trigs, **kwargs)