yql/essentials/udfs/common/reservoir_sampling/test/cases/test_deserialize.sql


1
2
3
4
5
6

/* syntax version 1 */
USE plato;

$serialize = Udf(ReservoirSampling::Serialize, String);
$merge = Udf(ReservoirSampling::Merge, String);
SELECT $serialize(ReservoirSampling::Deserialize($serialize($merge(ReservoirSampling::Create("abc", 123ul), ReservoirSampling::Create("cde", 123ul)))));