def _preprocess_data()

in svinfer/summary_statistics/summary_statistics.py [0:0]


    def _preprocess_data(self, data: AbstractProcessor):
        logging.info("data is an instance of %s", type(data))
        x = data.prepare_x(self.x_columns)
        z = get_result({
            "m1": x,
            "m2": x * x,
            "m3": x * x * x,
            "m4": x * x * x * x,
        }, data.run_query)
        n = z["sample_size"]
        m1 = z["m1"]
        m2 = z["m2"]
        m3 = z["m3"]
        m4 = z["m4"]
        x_moments = []
        for i in range(len(self.x_columns)):
            x_moments.append(np.array([m1[i], m2[i], m3[i], m4[i]]))
        return x_moments, n