You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datasketches.apache.org by al...@apache.org on 2024/10/16 03:02:34 UTC
(datasketches-bigquery) branch use-ref created (now 49c6766)
This is an automated email from the ASF dual-hosted git repository.
alsay pushed a change to branch use-ref
in repository https://gitbox.apache.org/repos/asf/datasketches-bigquery.git
at 49c6766 use ref()
This branch includes the following new commits:
new 49c6766 use ref()
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datasketches.apache.org
For additional commands, e-mail: commits-help@datasketches.apache.org
(datasketches-bigquery) 01/01: use ref()
Posted by al...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
alsay pushed a commit to branch use-ref
in repository https://gitbox.apache.org/repos/asf/datasketches-bigquery.git
commit 49c6766165de9daee21af0bf1de987002a26a1e0
Author: AlexanderSaydakov <Al...@users.noreply.github.com>
AuthorDate: Tue Oct 15 20:02:11 2024 -0700
use ref()
---
README.md | 3 ++-
cpc/sqlx/cpc_sketch_agg_int64.sqlx | 2 +-
cpc/sqlx/cpc_sketch_agg_string.sqlx | 2 +-
cpc/sqlx/cpc_sketch_agg_union.sqlx | 2 +-
cpc/sqlx/cpc_sketch_get_estimate.sqlx | 2 +-
cpc/sqlx/cpc_sketch_get_estimate_and_bounds.sqlx | 2 +-
cpc/sqlx/cpc_sketch_to_string.sqlx | 2 +-
cpc/sqlx/cpc_sketch_union.sqlx | 2 +-
hll/sqlx/hll_sketch_agg_int64.sqlx | 2 +-
hll/sqlx/hll_sketch_agg_string.sqlx | 2 +-
hll/sqlx/hll_sketch_agg_union.sqlx | 2 +-
hll/sqlx/hll_sketch_union.sqlx | 2 +-
substitute_and_run.sh | 6 +++++-
theta/sqlx/theta_sketch_a_not_b.sqlx | 2 +-
theta/sqlx/theta_sketch_agg_int64.sqlx | 2 +-
theta/sqlx/theta_sketch_agg_string.sqlx | 2 +-
theta/sqlx/theta_sketch_agg_union.sqlx | 2 +-
theta/sqlx/theta_sketch_get_estimate.sqlx | 2 +-
theta/sqlx/theta_sketch_get_estimate_and_bounds.sqlx | 2 +-
theta/sqlx/theta_sketch_get_num_retained.sqlx | 2 +-
theta/sqlx/theta_sketch_get_theta.sqlx | 2 +-
theta/sqlx/theta_sketch_intersection.sqlx | 2 +-
theta/sqlx/theta_sketch_jaccard_similarity.sqlx | 2 +-
theta/sqlx/theta_sketch_to_string.sqlx | 2 +-
theta/sqlx/theta_sketch_union.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_a_not_b.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_agg_int64.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_agg_string.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_agg_union.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_filter_low_high.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_from_theta_sketch.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_get_estimate.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_get_estimate_and_bounds.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_get_num_retained.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_get_sum_estimate_and_bounds.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_get_theta.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_intersection.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_jaccard_similarity.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_to_string.sqlx | 2 +-
tuple/sqlx/tuple_sketch_int64_union.sqlx | 2 +-
40 files changed, 45 insertions(+), 40 deletions(-)
diff --git a/README.md b/README.md
index 59d0714..3181270 100644
--- a/README.md
+++ b/README.md
@@ -42,11 +42,12 @@ page for how to contact us.
- Requires setting environment variables
- GCS_BUCKET: to hold compiled artifacts
+ - BQ_PROJECT: location of stored SQL functions (routines)
- BQ_DATASET: location of stored SQL functions (routines)
```
make # performs compilation
-make install # upload to $GCS_BUCKET & create functions in $BQ_DATASET
+make install # upload to $GCS_BUCKET & create functions in $BQ_PROJECT.$BQ_DATASET
make test # runs predefined tests in BQ
```
diff --git a/cpc/sqlx/cpc_sketch_agg_int64.sqlx b/cpc/sqlx/cpc_sketch_agg_int64.sqlx
index b2dd385..d3ab550 100644
--- a/cpc/sqlx/cpc_sketch_agg_int64.sqlx
+++ b/cpc/sqlx/cpc_sketch_agg_int64.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/CPC/CpcSketches.html
'''
) AS (
- $BQ_DATASET.cpc_sketch_agg_int64_lgk_seed(value, STRUCT<BYTEINT, INT64>(NULL, NULL))
+ ${ref("cpc_sketch_agg_int64_lgk_seed")}(value, STRUCT<BYTEINT, INT64>(NULL, NULL))
);
diff --git a/cpc/sqlx/cpc_sketch_agg_string.sqlx b/cpc/sqlx/cpc_sketch_agg_string.sqlx
index b773a19..dbb19f9 100644
--- a/cpc/sqlx/cpc_sketch_agg_string.sqlx
+++ b/cpc/sqlx/cpc_sketch_agg_string.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/CPC/CpcSketches.html
'''
) AS (
- $BQ_DATASET.cpc_sketch_agg_string_lgk_seed(str, STRUCT<BYTEINT, INT64>(NULL, NULL))
+ ${ref("cpc_sketch_agg_string_lgk_seed")}(str, STRUCT<BYTEINT, INT64>(NULL, NULL))
);
diff --git a/cpc/sqlx/cpc_sketch_agg_union.sqlx b/cpc/sqlx/cpc_sketch_agg_union.sqlx
index af679a3..fc3c88a 100644
--- a/cpc/sqlx/cpc_sketch_agg_union.sqlx
+++ b/cpc/sqlx/cpc_sketch_agg_union.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/CPC/CpcSketches.html
'''
) AS (
- $BQ_DATASET.cpc_sketch_agg_union_lgk_seed(sketch, STRUCT<BYTEINT, INT64>(NULL, NULL))
+ ${ref("cpc_sketch_agg_union_lgk_seed")}(sketch, STRUCT<BYTEINT, INT64>(NULL, NULL))
);
diff --git a/cpc/sqlx/cpc_sketch_get_estimate.sqlx b/cpc/sqlx/cpc_sketch_get_estimate.sqlx
index 9a77467..184f613 100644
--- a/cpc/sqlx/cpc_sketch_get_estimate.sqlx
+++ b/cpc/sqlx/cpc_sketch_get_estimate.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/CPC/CpcSketches.html
'''
) AS (
- $BQ_DATASET.cpc_sketch_get_estimate_seed(sketch, NULL)
+ ${ref("cpc_sketch_get_estimate_seed")}(sketch, NULL)
);
diff --git a/cpc/sqlx/cpc_sketch_get_estimate_and_bounds.sqlx b/cpc/sqlx/cpc_sketch_get_estimate_and_bounds.sqlx
index ba8b214..466bb22 100644
--- a/cpc/sqlx/cpc_sketch_get_estimate_and_bounds.sqlx
+++ b/cpc/sqlx/cpc_sketch_get_estimate_and_bounds.sqlx
@@ -35,5 +35,5 @@ For more information:
- https://datasketches.apache.org/docs/CPC/CpcSketches.html
'''
) AS (
- $BQ_DATASET.cpc_sketch_get_estimate_and_bounds_seed(sketch, num_std_devs, NULL)
+ ${ref("cpc_sketch_get_estimate_and_bounds_seed")}(sketch, num_std_devs, NULL)
);
diff --git a/cpc/sqlx/cpc_sketch_to_string.sqlx b/cpc/sqlx/cpc_sketch_to_string.sqlx
index 83014e2..c885b14 100644
--- a/cpc/sqlx/cpc_sketch_to_string.sqlx
+++ b/cpc/sqlx/cpc_sketch_to_string.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/CPC/CpcSketches.html
'''
) AS (
- $BQ_DATASET.cpc_sketch_to_string_seed(sketch, NULL)
+ ${ref("cpc_sketch_to_string_seed")}(sketch, NULL)
);
diff --git a/cpc/sqlx/cpc_sketch_union.sqlx b/cpc/sqlx/cpc_sketch_union.sqlx
index 53e135c..1a44f39 100644
--- a/cpc/sqlx/cpc_sketch_union.sqlx
+++ b/cpc/sqlx/cpc_sketch_union.sqlx
@@ -33,5 +33,5 @@ For more information:
- https://datasketches.apache.org/docs/CPC/CpcSketches.html
'''
) AS (
- $BQ_DATASET.cpc_sketch_union_lgk_seed(sketchA, sketchB, NULL, NULL)
+ ${ref("cpc_sketch_union_lgk_seed")}(sketchA, sketchB, NULL, NULL)
);
diff --git a/hll/sqlx/hll_sketch_agg_int64.sqlx b/hll/sqlx/hll_sketch_agg_int64.sqlx
index ee1956d..6a02f00 100644
--- a/hll/sqlx/hll_sketch_agg_int64.sqlx
+++ b/hll/sqlx/hll_sketch_agg_int64.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/HLL/HllSketches.html
'''
) AS (
- $BQ_DATASET.hll_sketch_agg_int64_lgk_type(value, STRUCT<BYTEINT, STRING>(NULL, NULL))
+ ${ref("hll_sketch_agg_int64_lgk_type")}(value, STRUCT<BYTEINT, STRING>(NULL, NULL))
);
diff --git a/hll/sqlx/hll_sketch_agg_string.sqlx b/hll/sqlx/hll_sketch_agg_string.sqlx
index c3023a7..36f637e 100644
--- a/hll/sqlx/hll_sketch_agg_string.sqlx
+++ b/hll/sqlx/hll_sketch_agg_string.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/HLL/HllSketches.html
'''
) AS (
- $BQ_DATASET.hll_sketch_agg_string_lgk_type(str, STRUCT<BYTEINT, STRING>(NULL, NULL))
+ ${ref("hll_sketch_agg_string_lgk_type")}(str, STRUCT<BYTEINT, STRING>(NULL, NULL))
);
diff --git a/hll/sqlx/hll_sketch_agg_union.sqlx b/hll/sqlx/hll_sketch_agg_union.sqlx
index bd06eb9..ed33b11 100644
--- a/hll/sqlx/hll_sketch_agg_union.sqlx
+++ b/hll/sqlx/hll_sketch_agg_union.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/HLL/HllSketches.html
'''
) AS (
- $BQ_DATASET.hll_sketch_agg_union_lgk_type(sketch, STRUCT<BYTEINT, STRING>(NULL, NULL))
+ ${ref("hll_sketch_agg_union_lgk_type")}(sketch, STRUCT<BYTEINT, STRING>(NULL, NULL))
);
diff --git a/hll/sqlx/hll_sketch_union.sqlx b/hll/sqlx/hll_sketch_union.sqlx
index 5d6839b..47b151f 100644
--- a/hll/sqlx/hll_sketch_union.sqlx
+++ b/hll/sqlx/hll_sketch_union.sqlx
@@ -33,5 +33,5 @@ For more information:
- https://datasketches.apache.org/docs/HLL/HllSketches.html
'''
) AS (
- $BQ_DATASET.hll_sketch_union_lgk_type(sketchA, sketchB, NULL, NULL)
+ ${ref("hll_sketch_union_lgk_type")}(sketchA, sketchB, NULL, NULL)
);
diff --git a/substitute_and_run.sh b/substitute_and_run.sh
index 95f2abb..3648474 100755
--- a/substitute_and_run.sh
+++ b/substitute_and_run.sh
@@ -2,6 +2,10 @@
FILE=$1
+if [ -u $BQ_PROJECT ]; then
+ echo "environment variable BQ_PROJECT must be set"
+ exit
+fi
if [ -u $BQ_DATASET ]; then
echo "environment variable BQ_DATASET must be set"
exit
@@ -13,4 +17,4 @@ fi
FUNC=${FILE##*/}
FUNC=${FUNC%%.*}
-sed -e "s/\${self()}/${BQ_DATASET}.${FUNC}/;s/\$GCS_BUCKET/${GCS_BUCKET}/g;s/\$BQ_DATASET/${BQ_DATASET}/g" ${FILE} | grep -v -e"^config" | bq query --nouse_legacy_sql
+sed -e "s/\${self()}/\`${BQ_PROJECT}.${BQ_DATASET}.${FUNC}\`/;s/\$GCS_BUCKET/${GCS_BUCKET}/g;s/\$BQ_DATASET/${BQ_DATASET}/g;s/\${ref(\"\([^\"]*\)\")}/\`${BQ_PROJECT}.${BQ_DATASET}.\1\`/g" ${FILE} | grep -v -e"^config" | bq query --nouse_legacy_sql
diff --git a/theta/sqlx/theta_sketch_a_not_b.sqlx b/theta/sqlx/theta_sketch_a_not_b.sqlx
index 996e591..5c4648b 100644
--- a/theta/sqlx/theta_sketch_a_not_b.sqlx
+++ b/theta/sqlx/theta_sketch_a_not_b.sqlx
@@ -33,5 +33,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_a_not_b_seed(sketchA, sketchB, NULL)
+ ${ref("theta_sketch_a_not_b_seed")}(sketchA, sketchB, NULL)
);
diff --git a/theta/sqlx/theta_sketch_agg_int64.sqlx b/theta/sqlx/theta_sketch_agg_int64.sqlx
index 6dcda57..3cd6420 100644
--- a/theta/sqlx/theta_sketch_agg_int64.sqlx
+++ b/theta/sqlx/theta_sketch_agg_int64.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_agg_int64_lgk_seed_p(value, STRUCT<BYTEINT, INT64, FLOAT64>(NULL, NULL, NULL))
+ ${ref("theta_sketch_agg_int64_lgk_seed_p")}(value, STRUCT<BYTEINT, INT64, FLOAT64>(NULL, NULL, NULL))
);
diff --git a/theta/sqlx/theta_sketch_agg_string.sqlx b/theta/sqlx/theta_sketch_agg_string.sqlx
index 1637936..9260d47 100644
--- a/theta/sqlx/theta_sketch_agg_string.sqlx
+++ b/theta/sqlx/theta_sketch_agg_string.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_agg_string_lgk_seed_p(str, STRUCT<BYTEINT, INT64, FLOAT64>(NULL, NULL, NULL))
+ ${ref("theta_sketch_agg_string_lgk_seed_p")}(str, STRUCT<BYTEINT, INT64, FLOAT64>(NULL, NULL, NULL))
);
diff --git a/theta/sqlx/theta_sketch_agg_union.sqlx b/theta/sqlx/theta_sketch_agg_union.sqlx
index 8acc856..195c03d 100644
--- a/theta/sqlx/theta_sketch_agg_union.sqlx
+++ b/theta/sqlx/theta_sketch_agg_union.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_agg_union_lgk_seed(sketch, STRUCT<BYTEINT, INT64>(NULL, NULL))
+ ${ref("theta_sketch_agg_union_lgk_seed")}(sketch, STRUCT<BYTEINT, INT64>(NULL, NULL))
);
diff --git a/theta/sqlx/theta_sketch_get_estimate.sqlx b/theta/sqlx/theta_sketch_get_estimate.sqlx
index 0d33f4c..18f5ec1 100644
--- a/theta/sqlx/theta_sketch_get_estimate.sqlx
+++ b/theta/sqlx/theta_sketch_get_estimate.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_get_estimate_seed(sketch, NULL)
+ ${ref("theta_sketch_get_estimate_seed")}(sketch, NULL)
);
diff --git a/theta/sqlx/theta_sketch_get_estimate_and_bounds.sqlx b/theta/sqlx/theta_sketch_get_estimate_and_bounds.sqlx
index 305e369..a4b22ab 100644
--- a/theta/sqlx/theta_sketch_get_estimate_and_bounds.sqlx
+++ b/theta/sqlx/theta_sketch_get_estimate_and_bounds.sqlx
@@ -38,5 +38,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_get_estimate_and_bounds_seed(sketch, num_std_devs, NULL)
+ ${ref("theta_sketch_get_estimate_and_bounds_seed")}(sketch, num_std_devs, NULL)
);
diff --git a/theta/sqlx/theta_sketch_get_num_retained.sqlx b/theta/sqlx/theta_sketch_get_num_retained.sqlx
index 1626f39..aec61a2 100644
--- a/theta/sqlx/theta_sketch_get_num_retained.sqlx
+++ b/theta/sqlx/theta_sketch_get_num_retained.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_get_num_retained_seed(sketch, NULL)
+ ${ref("theta_sketch_get_num_retained_seed")}(sketch, NULL)
);
diff --git a/theta/sqlx/theta_sketch_get_theta.sqlx b/theta/sqlx/theta_sketch_get_theta.sqlx
index 2665c55..fed49a3 100644
--- a/theta/sqlx/theta_sketch_get_theta.sqlx
+++ b/theta/sqlx/theta_sketch_get_theta.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_get_theta_seed(sketch, NULL)
+ ${ref("theta_sketch_get_theta_seed")}(sketch, NULL)
);
diff --git a/theta/sqlx/theta_sketch_intersection.sqlx b/theta/sqlx/theta_sketch_intersection.sqlx
index 041ed49..d76869d 100644
--- a/theta/sqlx/theta_sketch_intersection.sqlx
+++ b/theta/sqlx/theta_sketch_intersection.sqlx
@@ -33,5 +33,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_intersection_seed(sketchA, sketchB, NULL)
+ ${ref("theta_sketch_intersection_seed")}(sketchA, sketchB, NULL)
);
diff --git a/theta/sqlx/theta_sketch_jaccard_similarity.sqlx b/theta/sqlx/theta_sketch_jaccard_similarity.sqlx
index 9cd81c7..8a07258 100644
--- a/theta/sqlx/theta_sketch_jaccard_similarity.sqlx
+++ b/theta/sqlx/theta_sketch_jaccard_similarity.sqlx
@@ -36,5 +36,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_jaccard_similarity_seed(sketchA, sketchB, NULL)
+ ${ref("theta_sketch_jaccard_similarity_seed")}(sketchA, sketchB, NULL)
);
diff --git a/theta/sqlx/theta_sketch_to_string.sqlx b/theta/sqlx/theta_sketch_to_string.sqlx
index 8fbb060..ad833aa 100644
--- a/theta/sqlx/theta_sketch_to_string.sqlx
+++ b/theta/sqlx/theta_sketch_to_string.sqlx
@@ -32,5 +32,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_to_string_seed(sketch, NULL)
+ ${ref("theta_sketch_to_string_seed")}(sketch, NULL)
);
diff --git a/theta/sqlx/theta_sketch_union.sqlx b/theta/sqlx/theta_sketch_union.sqlx
index 66328df..aba1ef4 100644
--- a/theta/sqlx/theta_sketch_union.sqlx
+++ b/theta/sqlx/theta_sketch_union.sqlx
@@ -33,5 +33,5 @@ For more information:
- https://datasketches.apache.org/docs/Theta/ThetaSketches.html
'''
) AS (
- $BQ_DATASET.theta_sketch_union_lgk_seed(sketchA, sketchB, NULL, NULL)
+ ${ref("theta_sketch_union_lgk_seed")}(sketchA, sketchB, NULL, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_a_not_b.sqlx b/tuple/sqlx/tuple_sketch_int64_a_not_b.sqlx
index 5c28db8..dc140d9 100644
--- a/tuple/sqlx/tuple_sketch_int64_a_not_b.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_a_not_b.sqlx
@@ -35,5 +35,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_a_not_b_seed(sketchA, sketchB, NULL)
+ ${ref("tuple_sketch_int64_a_not_b_seed")}(sketchA, sketchB, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_agg_int64.sqlx b/tuple/sqlx/tuple_sketch_int64_agg_int64.sqlx
index e7f8b32..a047bed 100644
--- a/tuple/sqlx/tuple_sketch_int64_agg_int64.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_agg_int64.sqlx
@@ -36,5 +36,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_agg_int64_lgk_seed_p_mode(key, value, STRUCT<BYTEINT, INT64, FLOAT64, STRING>(NULL, NULL, NULL, NULL))
+ ${ref("tuple_sketch_int64_agg_int64_lgk_seed_p_mode")}(key, value, STRUCT<BYTEINT, INT64, FLOAT64, STRING>(NULL, NULL, NULL, NULL))
);
diff --git a/tuple/sqlx/tuple_sketch_int64_agg_string.sqlx b/tuple/sqlx/tuple_sketch_int64_agg_string.sqlx
index f3aab64..59766be 100644
--- a/tuple/sqlx/tuple_sketch_int64_agg_string.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_agg_string.sqlx
@@ -36,5 +36,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_agg_string_lgk_seed_p_mode(key, value, STRUCT<BYTEINT, INT64, FLOAT64, STRING>(NULL, NULL, NULL, NULL))
+ ${ref("tuple_sketch_int64_agg_string_lgk_seed_p_mode")}(key, value, STRUCT<BYTEINT, INT64, FLOAT64, STRING>(NULL, NULL, NULL, NULL))
);
diff --git a/tuple/sqlx/tuple_sketch_int64_agg_union.sqlx b/tuple/sqlx/tuple_sketch_int64_agg_union.sqlx
index 464e22b..17f5387 100644
--- a/tuple/sqlx/tuple_sketch_int64_agg_union.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_agg_union.sqlx
@@ -34,5 +34,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_agg_union_lgk_seed_mode(sketch, STRUCT<lg_k BYTEINT, seed INT64, mode STRING>(NULL, NULL, NULL))
+ ${ref("tuple_sketch_int64_agg_union_lgk_seed_mode")}(sketch, STRUCT<lg_k BYTEINT, seed INT64, mode STRING>(NULL, NULL, NULL))
);
diff --git a/tuple/sqlx/tuple_sketch_int64_filter_low_high.sqlx b/tuple/sqlx/tuple_sketch_int64_filter_low_high.sqlx
index 63b1d8c..7751fff 100644
--- a/tuple/sqlx/tuple_sketch_int64_filter_low_high.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_filter_low_high.sqlx
@@ -38,5 +38,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_filter_low_high_seed(sketch, low, high, NULL)
+ ${ref("tuple_sketch_int64_filter_low_high_seed")}(sketch, low, high, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_from_theta_sketch.sqlx b/tuple/sqlx/tuple_sketch_int64_from_theta_sketch.sqlx
index 5e829c2..5f2950b 100644
--- a/tuple/sqlx/tuple_sketch_int64_from_theta_sketch.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_from_theta_sketch.sqlx
@@ -34,5 +34,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_from_theta_sketch_seed(sketch, value, NULL)
+ ${ref("tuple_sketch_int64_from_theta_sketch_seed")}(sketch, value, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_get_estimate.sqlx b/tuple/sqlx/tuple_sketch_int64_get_estimate.sqlx
index 0e5386a..bf11c35 100644
--- a/tuple/sqlx/tuple_sketch_int64_get_estimate.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_get_estimate.sqlx
@@ -34,5 +34,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_get_estimate_seed(sketch, NULL)
+ ${ref("tuple_sketch_int64_get_estimate_seed")}(sketch, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_get_estimate_and_bounds.sqlx b/tuple/sqlx/tuple_sketch_int64_get_estimate_and_bounds.sqlx
index d5db1fa..8bfbdde 100644
--- a/tuple/sqlx/tuple_sketch_int64_get_estimate_and_bounds.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_get_estimate_and_bounds.sqlx
@@ -40,5 +40,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_get_estimate_and_bounds_seed(sketch, num_std_devs, NULL)
+ ${ref("tuple_sketch_int64_get_estimate_and_bounds_seed")}(sketch, num_std_devs, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_get_num_retained.sqlx b/tuple/sqlx/tuple_sketch_int64_get_num_retained.sqlx
index 8a7bd1b..693af9c 100644
--- a/tuple/sqlx/tuple_sketch_int64_get_num_retained.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_get_num_retained.sqlx
@@ -34,5 +34,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_get_num_retained_seed(sketch, NULL)
+ ${ref("tuple_sketch_int64_get_num_retained_seed")}(sketch, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_get_sum_estimate_and_bounds.sqlx b/tuple/sqlx/tuple_sketch_int64_get_sum_estimate_and_bounds.sqlx
index 4775551..9905c1f 100644
--- a/tuple/sqlx/tuple_sketch_int64_get_sum_estimate_and_bounds.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_get_sum_estimate_and_bounds.sqlx
@@ -41,5 +41,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_get_sum_estimate_and_bounds_seed(sketch, num_std_devs, NULL)
+ ${ref("tuple_sketch_int64_get_sum_estimate_and_bounds_seed")}(sketch, num_std_devs, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_get_theta.sqlx b/tuple/sqlx/tuple_sketch_int64_get_theta.sqlx
index 4fa9528..1e73d7f 100644
--- a/tuple/sqlx/tuple_sketch_int64_get_theta.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_get_theta.sqlx
@@ -34,5 +34,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_get_theta_seed(sketch, NULL)
+ ${ref("tuple_sketch_int64_get_theta_seed")}(sketch, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_intersection.sqlx b/tuple/sqlx/tuple_sketch_int64_intersection.sqlx
index 8d8a82e..7d694c1 100644
--- a/tuple/sqlx/tuple_sketch_int64_intersection.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_intersection.sqlx
@@ -35,5 +35,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_intersection_seed_mode(sketchA, sketchB, NULL, NULL)
+ ${ref("tuple_sketch_int64_intersection_seed_mode")}(sketchA, sketchB, NULL, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_jaccard_similarity.sqlx b/tuple/sqlx/tuple_sketch_int64_jaccard_similarity.sqlx
index 108cacd..6cd3dc9 100644
--- a/tuple/sqlx/tuple_sketch_int64_jaccard_similarity.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_jaccard_similarity.sqlx
@@ -37,5 +37,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_jaccard_similarity_seed(sketchA, sketchB, null)
+ ${ref("tuple_sketch_int64_jaccard_similarity_seed")}(sketchA, sketchB, null)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_to_string.sqlx b/tuple/sqlx/tuple_sketch_int64_to_string.sqlx
index c83d12a..74bea37 100644
--- a/tuple/sqlx/tuple_sketch_int64_to_string.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_to_string.sqlx
@@ -34,5 +34,5 @@ For more information:
- https://datasketches.apache.org/docs/Tuple/TupleSketches.html
'''
) AS (
- $BQ_DATASET.tuple_sketch_int64_to_string_seed(sketch, NULL)
+ ${ref("tuple_sketch_int64_to_string_seed")}(sketch, NULL)
);
diff --git a/tuple/sqlx/tuple_sketch_int64_union.sqlx b/tuple/sqlx/tuple_sketch_int64_union.sqlx
index 90d6fc4..79d6d03 100644
--- a/tuple/sqlx/tuple_sketch_int64_union.sqlx
+++ b/tuple/sqlx/tuple_sketch_int64_union.sqlx
@@ -36,5 +36,5 @@ For more information:
'''
)
AS (
- $BQ_DATASET.tuple_sketch_int64_union_lgk_seed_mode(sketchA, sketchB, NULL, NULL, NULL)
+ ${ref("tuple_sketch_int64_union_lgk_seed_mode")}(sketchA, sketchB, NULL, NULL, NULL)
);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datasketches.apache.org
For additional commands, e-mail: commits-help@datasketches.apache.org