blob: 47937155458e63ee8c9efafbe86277852b704e52 (
plain) (
blame)
1
2
3
4
5
6
|
/* syntax version 1 */
USE plato;
$serialize = Udf(ReservoirSampling::Serialize, String);
$merge = Udf(ReservoirSampling::Merge, String);
SELECT $serialize(ReservoirSampling::Add(ReservoirSampling::Deserialize($serialize($merge(ReservoirSampling::Create("abc", 123ul), ReservoirSampling::Create("cde", 123ul))), 321)));
|