Class NormalCore

src/NormalCore.hpp:24–52

namespace MIDAS {
struct NormalCore {
	int timestamp = 1;
	int* const index; // Pre-compute the index to-be-modified, thanks to the same structure of CMSs
	CountMinSketch numCurrent, numTotal;

	NormalCore(int numRow, int numColumn):
		index(new int[numRow]),
		numCurrent(numRow, numColumn),
		numTotal(numCurrent) { }

	virtual ~NormalCore() {
		delete[] index;
	}

	static float ComputeScore(float a, float s, float t) {
		return s == 0 || t - 1 == 0 ? 0 : pow((a - s / t) * t, 2) / (s * (t - 1));
	}

	float operator()(int source, int destination, int timestamp) {
		if (this->timestamp < timestamp) {
			numCurrent.ClearAll();
			this->timestamp = timestamp;
		}
		numCurrent.Hash(index, source, destination);
		numCurrent.Add(index);
		numTotal.Add(index);
		return ComputeScore(numCurrent(index), numTotal(index), timestamp);
	}
};
}