blob: 0b00b1e9fd4e70bc55b40c3772fdaf385badb463 [file]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
config { hasOutput: true, tags: ["req", "udfs"] }
CREATE OR REPLACE FUNCTION ${self()}(sketch BYTES, rank FLOAT64, inclusive BOOL)
RETURNS FLOAT64
LANGUAGE js
OPTIONS (
library=["${dataform.projectConfig.vars.jsBucket}/req_sketch_float.js"],
js_parameter_encoding_mode='STANDARD',
description = '''Returns a value from the sketch that is the best approximation to a value from the original stream with the given rank.
Param sketch: the given sketch in serialized form.
Param rank: rank of a value in the hypothetical sorted stream.
Param inclusive: if true, the given rank is considered inclusive (includes weight of a value)
Returns: an approximate quantile associated with the given rank.
For more information:
- https://datasketches.apache.org/docs/REQ/ReqSketch.html
'''
) AS R"""
if (sketch == null) return null;
try {
var sketchObject = null;
try {
sketchObject = Module.req_sketch_float.deserialize(sketch);
if (sketchObject.isEmpty()) return null;
return sketchObject.getQuantile(rank, inclusive);
} finally {
if (sketchObject != null) sketchObject.delete();
}
} catch (e) {
if (e.message != null) throw e;
throw new Error(Module.getExceptionMessage(e));
}
""";