This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/asf-site by this push: new 94e2904 Publishing website 2019/11/11 21:32:22 at commit 063ee99 94e2904 is described below commit 94e2904436b2b6202ba41d93ce019ed824490110 Author: jenkins <bui...@apache.org> AuthorDate: Mon Nov 11 21:32:22 2019 +0000 Publishing website 2019/11/11 21:32:22 at commit 063ee99 --- website/generated-content/documentation/index.html | 1 + .../io/built-in/google-bigquery/index.html | 1 + .../documentation/io/built-in/hadoop/index.html | 1 + .../documentation/io/built-in/hcatalog/index.html | 1 + .../documentation/io/built-in/index.html | 1 + .../documentation/io/built-in/parquet/index.html | 1 + .../documentation/io/developing-io-java/index.html | 1 + .../io/developing-io-overview/index.html | 1 + .../io/developing-io-python/index.html | 1 + .../documentation/io/testing/index.html | 1 + .../documentation/patterns/custom-io/index.html | 1 + .../patterns/custom-windows/index.html | 1 + .../patterns/file-processing/index.html | 1 + .../documentation/patterns/overview/index.html | 1 + .../patterns/pipeline-options/index.html | 1 + .../documentation/patterns/side-inputs/index.html | 1 + .../pipelines/create-your-pipeline/index.html | 1 + .../pipelines/design-your-pipeline/index.html | 1 + .../pipelines/test-your-pipeline/index.html | 1 + .../documentation/programming-guide/index.html | 1 + .../resources/learning-resources/index.html | 1 + .../resources/videos-and-podcasts/index.html | 1 + .../documentation/runners/jstorm/index.html | 1 + .../documentation/runtime/environments/index.html | 1 + .../documentation/runtime/model/index.html | 1 + .../aggregation/approximatequantiles/index.html | 1 + .../java/aggregation/approximateunique/index.html | 3 + .../java/aggregation/cogroupbykey/index.html | 1 + .../transforms/java/aggregation/combine/index.html | 1 + .../java/aggregation/combinewithcontext/index.html | 1 + .../transforms/java/aggregation/count/index.html | 1 + .../java/aggregation/distinct/index.html | 1 + .../java/aggregation/groupbykey/index.html | 1 + .../java/aggregation/groupintobatches/index.html | 1 + .../java/aggregation/{mean => hllcount}/index.html | 66 ++++++++++++++-------- .../transforms/java/aggregation/latest/index.html | 1 + .../transforms/java/aggregation/max/index.html | 1 + .../transforms/java/aggregation/mean/index.html | 1 + .../transforms/java/aggregation/min/index.html | 1 + .../transforms/java/aggregation/sample/index.html | 1 + .../transforms/java/aggregation/sum/index.html | 1 + .../transforms/java/aggregation/top/index.html | 1 + .../transforms/java/elementwise/filter/index.html | 1 + .../java/elementwise/flatmapelements/index.html | 1 + .../transforms/java/elementwise/keys/index.html | 1 + .../transforms/java/elementwise/kvswap/index.html | 1 + .../java/elementwise/mapelements/index.html | 1 + .../transforms/java/elementwise/pardo/index.html | 1 + .../java/elementwise/partition/index.html | 1 + .../transforms/java/elementwise/regex/index.html | 1 + .../transforms/java/elementwise/reify/index.html | 1 + .../java/elementwise/tostring/index.html | 1 + .../transforms/java/elementwise/values/index.html | 1 + .../java/elementwise/withkeys/index.html | 1 + .../java/elementwise/withtimestamps/index.html | 1 + .../transforms/java/other/create/index.html | 1 + .../transforms/java/other/flatten/index.html | 1 + .../transforms/java/other/passert/index.html | 1 + .../transforms/java/other/view/index.html | 1 + .../transforms/java/other/window/index.html | 1 + .../transforms/java/overview/index.html | 2 + .../aggregation/approximatequantiles/index.html | 1 + .../aggregation/approximateunique/index.html | 1 + .../python/aggregation/cogroupbykey/index.html | 1 + .../python/aggregation/combineglobally/index.html | 1 + .../aggregation/combinewithcontext/index.html | 1 + .../transforms/python/aggregation/count/index.html | 1 + .../python/aggregation/distinct/index.html | 1 + .../python/aggregation/groupbykey/index.html | 1 + .../python/aggregation/groupintobatches/index.html | 1 + .../python/aggregation/latest/index.html | 1 + .../transforms/python/aggregation/max/index.html | 1 + .../transforms/python/aggregation/mean/index.html | 1 + .../transforms/python/aggregation/min/index.html | 1 + .../python/aggregation/sample/index.html | 1 + .../transforms/python/aggregation/sum/index.html | 1 + .../transforms/python/aggregation/top/index.html | 1 + .../python/elementwise/filter/index.html | 1 + .../python/elementwise/flatmap/index.html | 1 + .../transforms/python/elementwise/keys/index.html | 1 + .../python/elementwise/kvswap/index.html | 1 + .../transforms/python/elementwise/map/index.html | 1 + .../transforms/python/elementwise/pardo/index.html | 1 + .../python/elementwise/partition/index.html | 1 + .../transforms/python/elementwise/regex/index.html | 1 + .../transforms/python/elementwise/reify/index.html | 1 + .../python/elementwise/tostring/index.html | 1 + .../python/elementwise/values/index.html | 1 + .../python/elementwise/withkeys/index.html | 1 + .../python/elementwise/withtimestamps/index.html | 1 + .../transforms/python/other/create/index.html | 1 + .../transforms/python/other/flatten/index.html | 1 + .../transforms/python/other/passert/index.html | 1 + .../transforms/python/other/reshuffle/index.html | 1 + .../transforms/python/other/view/index.html | 1 + .../transforms/python/other/windowinto/index.html | 1 + .../transforms/python/overview/index.html | 1 + 97 files changed, 142 insertions(+), 23 deletions(-) diff --git a/website/generated-content/documentation/index.html b/website/generated-content/documentation/index.html index f3e8496..c83e767 100644 --- a/website/generated-content/documentation/index.html +++ b/website/generated-content/documentation/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/built-in/google-bigquery/index.html b/website/generated-content/documentation/io/built-in/google-bigquery/index.html index 6970803..0fad805 100644 --- a/website/generated-content/documentation/io/built-in/google-bigquery/index.html +++ b/website/generated-content/documentation/io/built-in/google-bigquery/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/built-in/hadoop/index.html b/website/generated-content/documentation/io/built-in/hadoop/index.html index ffa074a..53cd014 100644 --- a/website/generated-content/documentation/io/built-in/hadoop/index.html +++ b/website/generated-content/documentation/io/built-in/hadoop/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/built-in/hcatalog/index.html b/website/generated-content/documentation/io/built-in/hcatalog/index.html index af8de20..b52453d 100644 --- a/website/generated-content/documentation/io/built-in/hcatalog/index.html +++ b/website/generated-content/documentation/io/built-in/hcatalog/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/built-in/index.html b/website/generated-content/documentation/io/built-in/index.html index ab04ca1..95120d7 100644 --- a/website/generated-content/documentation/io/built-in/index.html +++ b/website/generated-content/documentation/io/built-in/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/built-in/parquet/index.html b/website/generated-content/documentation/io/built-in/parquet/index.html index d800d76..05b9e19 100644 --- a/website/generated-content/documentation/io/built-in/parquet/index.html +++ b/website/generated-content/documentation/io/built-in/parquet/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/developing-io-java/index.html b/website/generated-content/documentation/io/developing-io-java/index.html index fda0766..262947c 100644 --- a/website/generated-content/documentation/io/developing-io-java/index.html +++ b/website/generated-content/documentation/io/developing-io-java/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/developing-io-overview/index.html b/website/generated-content/documentation/io/developing-io-overview/index.html index f2ad792..da12dc9 100644 --- a/website/generated-content/documentation/io/developing-io-overview/index.html +++ b/website/generated-content/documentation/io/developing-io-overview/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/developing-io-python/index.html b/website/generated-content/documentation/io/developing-io-python/index.html index 2b0fb81..43a6def 100644 --- a/website/generated-content/documentation/io/developing-io-python/index.html +++ b/website/generated-content/documentation/io/developing-io-python/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/io/testing/index.html b/website/generated-content/documentation/io/testing/index.html index 7da9ac0..5a7b21c 100644 --- a/website/generated-content/documentation/io/testing/index.html +++ b/website/generated-content/documentation/io/testing/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/patterns/custom-io/index.html b/website/generated-content/documentation/patterns/custom-io/index.html index ffe0d44..339fa57 100644 --- a/website/generated-content/documentation/patterns/custom-io/index.html +++ b/website/generated-content/documentation/patterns/custom-io/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/patterns/custom-windows/index.html b/website/generated-content/documentation/patterns/custom-windows/index.html index c241358..477f157 100644 --- a/website/generated-content/documentation/patterns/custom-windows/index.html +++ b/website/generated-content/documentation/patterns/custom-windows/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/patterns/file-processing/index.html b/website/generated-content/documentation/patterns/file-processing/index.html index 6e2a372..2dff880 100644 --- a/website/generated-content/documentation/patterns/file-processing/index.html +++ b/website/generated-content/documentation/patterns/file-processing/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/patterns/overview/index.html b/website/generated-content/documentation/patterns/overview/index.html index 6924d21..cff50ac 100644 --- a/website/generated-content/documentation/patterns/overview/index.html +++ b/website/generated-content/documentation/patterns/overview/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/patterns/pipeline-options/index.html b/website/generated-content/documentation/patterns/pipeline-options/index.html index 74fe7ab..e42fd50 100644 --- a/website/generated-content/documentation/patterns/pipeline-options/index.html +++ b/website/generated-content/documentation/patterns/pipeline-options/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/patterns/side-inputs/index.html b/website/generated-content/documentation/patterns/side-inputs/index.html index d688379..97baf97 100644 --- a/website/generated-content/documentation/patterns/side-inputs/index.html +++ b/website/generated-content/documentation/patterns/side-inputs/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/pipelines/create-your-pipeline/index.html b/website/generated-content/documentation/pipelines/create-your-pipeline/index.html index b965646..e8e9e13 100644 --- a/website/generated-content/documentation/pipelines/create-your-pipeline/index.html +++ b/website/generated-content/documentation/pipelines/create-your-pipeline/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/pipelines/design-your-pipeline/index.html b/website/generated-content/documentation/pipelines/design-your-pipeline/index.html index f7d911c..90d550a 100644 --- a/website/generated-content/documentation/pipelines/design-your-pipeline/index.html +++ b/website/generated-content/documentation/pipelines/design-your-pipeline/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/pipelines/test-your-pipeline/index.html b/website/generated-content/documentation/pipelines/test-your-pipeline/index.html index cedc4f9..638c7a1 100644 --- a/website/generated-content/documentation/pipelines/test-your-pipeline/index.html +++ b/website/generated-content/documentation/pipelines/test-your-pipeline/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/programming-guide/index.html b/website/generated-content/documentation/programming-guide/index.html index 817c1fe..7816a1a 100644 --- a/website/generated-content/documentation/programming-guide/index.html +++ b/website/generated-content/documentation/programming-guide/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/resources/learning-resources/index.html b/website/generated-content/documentation/resources/learning-resources/index.html index 6368489..1590198 100644 --- a/website/generated-content/documentation/resources/learning-resources/index.html +++ b/website/generated-content/documentation/resources/learning-resources/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/resources/videos-and-podcasts/index.html b/website/generated-content/documentation/resources/videos-and-podcasts/index.html index 615b1a2..5635aaf 100644 --- a/website/generated-content/documentation/resources/videos-and-podcasts/index.html +++ b/website/generated-content/documentation/resources/videos-and-podcasts/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/runners/jstorm/index.html b/website/generated-content/documentation/runners/jstorm/index.html index dd994ed..6120a34 100644 --- a/website/generated-content/documentation/runners/jstorm/index.html +++ b/website/generated-content/documentation/runners/jstorm/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/runtime/environments/index.html b/website/generated-content/documentation/runtime/environments/index.html index ed21fde..7fcb7ea 100644 --- a/website/generated-content/documentation/runtime/environments/index.html +++ b/website/generated-content/documentation/runtime/environments/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/runtime/model/index.html b/website/generated-content/documentation/runtime/model/index.html index 0130c7e..83a4f34 100644 --- a/website/generated-content/documentation/runtime/model/index.html +++ b/website/generated-content/documentation/runtime/model/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/approximatequantiles/index.html b/website/generated-content/documentation/transforms/java/aggregation/approximatequantiles/index.html index 771b695..dd33cac 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/approximatequantiles/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/approximatequantiles/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/approximateunique/index.html b/website/generated-content/documentation/transforms/java/aggregation/approximateunique/index.html index 401cadd..069eaf7 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/approximateunique/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/approximateunique/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> @@ -497,6 +498,8 @@ of key-value pairs.</p> <h2 id="related-transforms">Related transforms</h2> <ul> + <li><a href="/documentation/transforms/java/aggregation/hllcount">HllCount</a> +estimates the number of distinct elements and creates re-aggregatable sketches using the HyperLogLog++ algorithm.</li> <li><a href="/documentation/transforms/java/aggregation/count">Count</a> counts the number of elements within each aggregation.</li> <li><a href="/documentation/transforms/java/aggregation/distinct">Distinct</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/cogroupbykey/index.html b/website/generated-content/documentation/transforms/java/aggregation/cogroupbykey/index.html index 0b3c4e8..f781378 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/cogroupbykey/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/cogroupbykey/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/combine/index.html b/website/generated-content/documentation/transforms/java/aggregation/combine/index.html index 7d8bbf4..c45e2d5 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/combine/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/combine/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/combinewithcontext/index.html b/website/generated-content/documentation/transforms/java/aggregation/combinewithcontext/index.html index 68b3a60..40a3597 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/combinewithcontext/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/combinewithcontext/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/count/index.html b/website/generated-content/documentation/transforms/java/aggregation/count/index.html index 2607353..14bafb3 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/count/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/count/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/distinct/index.html b/website/generated-content/documentation/transforms/java/aggregation/distinct/index.html index 10e2791..31033b7 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/distinct/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/distinct/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/groupbykey/index.html b/website/generated-content/documentation/transforms/java/aggregation/groupbykey/index.html index aa20f1f..0259d90 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/groupbykey/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/groupbykey/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/groupintobatches/index.html b/website/generated-content/documentation/transforms/java/aggregation/groupintobatches/index.html index d4acfb7..dbb435e 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/groupintobatches/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/groupintobatches/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/mean/index.html b/website/generated-content/documentation/transforms/java/aggregation/hllcount/index.html similarity index 82% copy from website/generated-content/documentation/transforms/java/aggregation/mean/index.html copy to website/generated-content/documentation/transforms/java/aggregation/hllcount/index.html index 97fb682..9a6c80e 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/mean/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/hllcount/index.html @@ -28,7 +28,7 @@ <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1"> - <title>Mean</title> + <title>HllCount</title> <meta name="description" content="Apache Beam is an open source, unified model and set of language-specific SDKs for defining and executing data processing workflows, and also data ingestion and integration flows, supporting Enterprise Integration Patterns (EIPs) and Domain Specific Languages (DSLs). Dataflow pipelines simplify the mechanics of large-scale batch and streaming data processing and can run on a number of runtimes like Apache Flink, Apache Spark, and Google Cloud Dataflow [...] "> <link href="https://fonts.googleapis.com/css?family=Roboto:100,300,400" rel="stylesheet"> @@ -42,7 +42,7 @@ <script src="/js/fix-menu.js"></script> <script src="/js/section-nav.js"></script> <script src="/js/page-nav.js"></script> - <link rel="canonical" href="https://beam.apache.org/documentation/transforms/java/aggregation/mean/" data-proofer-ignore> + <link rel="canonical" href="https://beam.apache.org/documentation/transforms/java/aggregation/hllcount/" data-proofer-ignore> <link rel="shortcut icon" type="image/x-icon" href="/images/favicon.ico"> <link rel="alternate" type="application/rss+xml" title="Apache Beam" href="https://beam.apache.org/feed.xml"> <link rel="stylesheet" href="https://use.fontawesome.com/releases/v5.4.1/css/all.css" integrity="sha384-5sAR7xN1Nv6T6+dT2mhtzEpVJvfS3NScPQTrOxhwjIuvcA67KV2R5Jz6kr4abQsz" crossorigin="anonymous"> @@ -144,7 +144,7 @@ GitHub links will not resolve until the markdown source is available on the master branch. New pages would fail validation during development / PR test automation. --> - <a href="https://github.com/apache/beam/edit/master/website/src/documentation/transforms/java/aggregation/mean.md" data-proofer-ignore> + <a href="https://github.com/apache/beam/edit/master/website/src/documentation/transforms/java/aggregation/hllcount.md" data-proofer-ignore> <i class="far fa-edit fa-lg" alt="Edit on GitHub" title="Edit on GitHub"></i> </a> </li> @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> @@ -480,46 +481,65 @@ 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. --> -<h1 id="mean">Mean</h1> +<h1 id="latest">Latest</h1> <table align="left"> - <a target="_blank" class="button" href="https://beam.apache.org/releases/javadoc/current/index.html?org/apache/beam/sdk/transforms/Mean.html"> + <a target="_blank" class="button" href="https://beam.apache.org/releases/javadoc/current/index.html?org/apache/beam/sdk/extensions/zetasketch/HllCount.html"> <img src="https://beam.apache.org/images/logos/sdks/java.png" width="20px" height="20px" alt="Javadoc" /> Javadoc </a> </table> -<p><br /> -Transforms for computing the arithmetic mean of the elements in a collection, -or the mean of the values associated with each key in a collection of key-value pairs.</p> +<p><br /></p> + +<p>Estimates the number of distinct elements in a data stream using the +<a href="http://static.googleusercontent.com/media/research.google.com/en/us/pubs/archive/40671.pdf">HyperLogLog++ algorithm</a>. +The respective transforms to create and merge sketches, and to extract from them, are:</p> <ul> - <li><code class="highlighter-rouge">Mean.globally()</code> returns a transform that then returns a collection whose contents is the mean of the input collection’s elements. If there are no elements in the input collection, it returns 0.</li> - <li><code class="highlighter-rouge">Mean.perKey()</code> returns a transform that returns a collection that contains an output element mapping each distinct key in the input collection to the mean of the values associated with that key in the input collection.</li> + <li><code class="highlighter-rouge">HllCount.Init</code> aggregates inputs into HLL++ sketches.</li> + <li><code class="highlighter-rouge">HllCount.MergePartial</code> merges HLL++ sketches into a new sketch.</li> + <li><code class="highlighter-rouge">HllCount.Extract</code> extracts the estimated count of distinct elements from HLL++ sketches.</li> </ul> +<p>You can read more about what a sketch is at https://github.com/google/zetasketch.</p> + <h2 id="examples">Examples</h2> -<p><strong>Example 1</strong>: get the mean of a <code class="highlighter-rouge">PCollection</code> of <code class="highlighter-rouge">Longs</code>.</p> +<p><strong>Example 1</strong>: creates a long-type sketch for a <code class="highlighter-rouge">PCollection<Long></code> with a custom precision:</p> +<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">PCollection</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="n">input</span> <span class="o">=</span> <span class="o">...;</span> + <span class="kt">int</span> <span class="n">p</span> <span class="o">=</span> <span class="o">...;</span> + <span class="n">PCollection</span><span class="o"><</span><span class="kt">byte</span><span class="o">[]></span> <span class="n">sketch</span> <span class="o">=</span> <span class="n">input</span><span class="o">.</span><span class="na">apply</span><span class="o">(</span><span class="n">HllCount</span><span class="o">.</span><span class="na">Init</span><span class="o">.</span><span class="na">forLongs</span><span class="o">().</span><span class="na">withPrecision</span><span clas [...] +</code></pre> +</div> -<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">PCollection</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">input</span> <span class="o">=</span> <span class="o">...;</span> -<span class="n">PCollection</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">mean</span> <span class="o">=</span> <span class="n">input</span><span class="o">.</span><span class="na">apply</span><span class="o">(</span><span class="n">Mean</span><span class="o">.</span><span class="na">globally</span><span class="o">());</span> +<p><strong>Example 2</strong>: creates a bytes-type sketch for a <code class="highlighter-rouge">PCollection<KV<String, byte[]>></code>:</p> +<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">PCollection</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">input</span> <span class="o">=</span> <span class="o">...;</span> + <span class="n">PCollection</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">sketch</span> <span class="o">=</span> <span class="n">input</span><span class="o">.</span><span class="na">apply</span><span class="o">(</span><span class="n">HllCount</span><span class="o">.</span><span class="na">Init</span><span class="o">.</ [...] </code></pre> </div> -<p><strong>Example 2</strong>: calculate the mean of the <code class="highlighter-rouge">Integers</code> associated with each unique key (which is of type <code class="highlighter-rouge">String</code>).</p> +<p><strong>Example 3</strong>: merges existing sketches in a <code class="highlighter-rouge">PCollection<byte[]></code> into a new sketch, +which summarizes the union of the inputs that were aggregated in the merged sketches:</p> +<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">PCollection</span><span class="o"><</span><span class="kt">byte</span><span class="o">[]></span> <span class="n">sketches</span> <span class="o">=</span> <span class="o">...;</span> + <span class="n">PCollection</span><span class="o"><</span><span class="kt">byte</span><span class="o">[]></span> <span class="n">mergedSketch</span> <span class="o">=</span> <span class="n">sketches</span><span class="o">.</span><span class="na">apply</span><span class="o">(</span><span class="n">HllCount</span><span class="o">.</span><span class="na">MergePartial</span><span class="o">.</span><span class="na">globally</span><span class="o">());</span> +</code></pre> +</div> + +<p><strong>Example 4</strong>: estimates the count of distinct elements in a <code class="highlighter-rouge">PCollection<String></code>:</p> +<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">PCollection</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">input</span> <span class="o">=</span> <span class="o">...;</span> + <span class="n">PCollection</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="n">countDistinct</span> <span class="o">=</span> + <span class="n">input</span><span class="o">.</span><span class="na">apply</span><span class="o">(</span><span class="n">HllCount</span><span class="o">.</span><span class="na">Init</span><span class="o">.</span><span class="na">forStrings</span><span class="o">().</span><span class="na">globally</span><span class="o">()).</span><span class="na">apply</span><span class="o">(</span><span class="n">HllCount</span><span class="o">.</span><span class="na">Extract</span><span class="o">. [...] +</code></pre> +</div> -<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">PCollection</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Integer</span><span class="o">>></span> <span class="n">input</span> <span class="o">=</span> <span class="o">...;</span> -<span class="n">PCollection</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Integer</span><span class="o">>></span> <span class="n">meanPerKey</span> <span class="o">=</span> - <span class="n">input</span><span class="o">.</span><span class="na">apply</span><span class="o">(</span><span class="n">Mean</span><span class="o">.</span><span class="na">perKey</span><span class="o">());</span> +<p><strong>Example 5</strong>: extracts the count distinct estimate from an existing sketch:</p> +<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">PCollection</span><span class="o"><</span><span class="kt">byte</span><span class="o">[]></span> <span class="n">sketch</span> <span class="o">=</span> <span class="o">...;</span> + <span class="n">PCollection</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="n">countDistinct</span> <span class="o">=</span> <span class="n">sketch</span><span class="o">.</span><span class="na">apply</span><span class="o">(</span><span class="n">HllCount</span><span class="o">.</span><span class="na">Extract</span><span class="o">.</span><span class="na">globally</span><span class="o">());</span> </code></pre> </div> <h2 id="related-transforms">Related transforms</h2> <ul> - <li><a href="/documentation/transforms/java/aggregation/max">Max</a> -for computing maximum values in a collection</li> - <li><a href="/documentation/transforms/java/aggregation/min">Min</a> -for computing maximum values in a collection</li> - <li><a href="/documentation/transforms/java/aggregation/combine">Combine</a> -for combining all values associated with a key to a single result</li> + <li><a href="/documentation/transforms/java/aggregation/approximateunique">ApproximateUnique</a> +estimates the number of distinct elements or values in key-value pairs (but does not expose sketches; also less accurate than <code class="highlighter-rouge">HllCount</code>).</li> </ul> </div> diff --git a/website/generated-content/documentation/transforms/java/aggregation/latest/index.html b/website/generated-content/documentation/transforms/java/aggregation/latest/index.html index 307a584..8386810 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/latest/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/latest/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/max/index.html b/website/generated-content/documentation/transforms/java/aggregation/max/index.html index 48c8a97..01362f2c 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/max/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/max/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/mean/index.html b/website/generated-content/documentation/transforms/java/aggregation/mean/index.html index 97fb682..fbb00aa 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/mean/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/mean/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/min/index.html b/website/generated-content/documentation/transforms/java/aggregation/min/index.html index 7e3847e..cf38b28 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/min/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/min/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/sample/index.html b/website/generated-content/documentation/transforms/java/aggregation/sample/index.html index 9ab10fd..bd4030f 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/sample/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/sample/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/sum/index.html b/website/generated-content/documentation/transforms/java/aggregation/sum/index.html index 81cd2d2..bd3c89b 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/sum/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/sum/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/aggregation/top/index.html b/website/generated-content/documentation/transforms/java/aggregation/top/index.html index 5210a41..ad84add 100644 --- a/website/generated-content/documentation/transforms/java/aggregation/top/index.html +++ b/website/generated-content/documentation/transforms/java/aggregation/top/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/filter/index.html b/website/generated-content/documentation/transforms/java/elementwise/filter/index.html index b2ba06e..17a78d3 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/filter/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/filter/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/flatmapelements/index.html b/website/generated-content/documentation/transforms/java/elementwise/flatmapelements/index.html index 47a26be..8c89422 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/flatmapelements/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/flatmapelements/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/keys/index.html b/website/generated-content/documentation/transforms/java/elementwise/keys/index.html index b31188a..9ec33d5 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/keys/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/keys/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/kvswap/index.html b/website/generated-content/documentation/transforms/java/elementwise/kvswap/index.html index 82e7dd3..b14938d 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/kvswap/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/kvswap/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/mapelements/index.html b/website/generated-content/documentation/transforms/java/elementwise/mapelements/index.html index 86add7a..fb19755 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/mapelements/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/mapelements/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/pardo/index.html b/website/generated-content/documentation/transforms/java/elementwise/pardo/index.html index 1ca0b6f..41519cd 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/pardo/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/pardo/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/partition/index.html b/website/generated-content/documentation/transforms/java/elementwise/partition/index.html index 41a5eed..b8e45cb 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/partition/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/partition/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/regex/index.html b/website/generated-content/documentation/transforms/java/elementwise/regex/index.html index 5edcae4..b96b79a 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/regex/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/regex/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/reify/index.html b/website/generated-content/documentation/transforms/java/elementwise/reify/index.html index 6f0b3eb..2eb550c 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/reify/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/reify/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/tostring/index.html b/website/generated-content/documentation/transforms/java/elementwise/tostring/index.html index 012aca0..c071a8b 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/tostring/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/tostring/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/values/index.html b/website/generated-content/documentation/transforms/java/elementwise/values/index.html index 3b4d5fe..89ba10c 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/values/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/values/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/withkeys/index.html b/website/generated-content/documentation/transforms/java/elementwise/withkeys/index.html index 8a56408..0572a94 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/withkeys/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/withkeys/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/elementwise/withtimestamps/index.html b/website/generated-content/documentation/transforms/java/elementwise/withtimestamps/index.html index b0c8b71..38332f4 100644 --- a/website/generated-content/documentation/transforms/java/elementwise/withtimestamps/index.html +++ b/website/generated-content/documentation/transforms/java/elementwise/withtimestamps/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/other/create/index.html b/website/generated-content/documentation/transforms/java/other/create/index.html index 6684307..ba0366e 100644 --- a/website/generated-content/documentation/transforms/java/other/create/index.html +++ b/website/generated-content/documentation/transforms/java/other/create/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/other/flatten/index.html b/website/generated-content/documentation/transforms/java/other/flatten/index.html index b061322..39b56e3 100644 --- a/website/generated-content/documentation/transforms/java/other/flatten/index.html +++ b/website/generated-content/documentation/transforms/java/other/flatten/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/other/passert/index.html b/website/generated-content/documentation/transforms/java/other/passert/index.html index 36d78ec..2dff593 100644 --- a/website/generated-content/documentation/transforms/java/other/passert/index.html +++ b/website/generated-content/documentation/transforms/java/other/passert/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/other/view/index.html b/website/generated-content/documentation/transforms/java/other/view/index.html index 3f106d6..3ede707 100644 --- a/website/generated-content/documentation/transforms/java/other/view/index.html +++ b/website/generated-content/documentation/transforms/java/other/view/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/other/window/index.html b/website/generated-content/documentation/transforms/java/other/window/index.html index 339ccb4..9079ba1 100644 --- a/website/generated-content/documentation/transforms/java/other/window/index.html +++ b/website/generated-content/documentation/transforms/java/other/window/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/java/overview/index.html b/website/generated-content/documentation/transforms/java/overview/index.html index 132cfc3..dfc094d 100644 --- a/website/generated-content/documentation/transforms/java/overview/index.html +++ b/website/generated-content/documentation/transforms/java/overview/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> @@ -520,6 +521,7 @@ limitations under the License. <tr><td><a href="/documentation/transforms/java/aggregation/groupbykey">GroupByKey</a></td><td>Takes a keyed collection of elements and produces a collection where each element consists of a key and all values associated with that key.</td></tr> <tr><td><a href="/documentation/transforms/java/aggregation/groupintobatches">GroupIntoBatches</a></td><td>Batches values associated with keys into <code>Iterable</code> batches of some size. Each batch contains elements associated with a specific key.</td></tr> + <tr><td><a href="/documentation/transforms/java/aggregation/hllcount">HllCount</a></td><td>Estimates the number of distinct elements and creates re-aggregatable sketches using the HyperLogLog++ algorithm.</td></tr> <tr><td><a href="/documentation/transforms/java/aggregation/latest">Latest</a></td><td>Selects the latest element within each aggregation according to the implicit timestamp.</td></tr> <tr><td><a href="/documentation/transforms/java/aggregation/max">Max</a></td><td>Outputs the maximum element within each aggregation.</td></tr> <tr><td><a href="/documentation/transforms/java/aggregation/mean">Mean</a></td><td>Computes the average within each aggregation.</td></tr> diff --git a/website/generated-content/documentation/transforms/python/aggregation/approximatequantiles/index.html b/website/generated-content/documentation/transforms/python/aggregation/approximatequantiles/index.html index 9ecc500..7b30644 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/approximatequantiles/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/approximatequantiles/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/approximateunique/index.html b/website/generated-content/documentation/transforms/python/aggregation/approximateunique/index.html index ee258fd..77be6a9 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/approximateunique/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/approximateunique/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/cogroupbykey/index.html b/website/generated-content/documentation/transforms/python/aggregation/cogroupbykey/index.html index cf9a1d3..bb63149 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/cogroupbykey/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/cogroupbykey/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/combineglobally/index.html b/website/generated-content/documentation/transforms/python/aggregation/combineglobally/index.html index 0d84f17..885e688 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/combineglobally/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/combineglobally/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/combinewithcontext/index.html b/website/generated-content/documentation/transforms/python/aggregation/combinewithcontext/index.html index 08e5936..961f333 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/combinewithcontext/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/combinewithcontext/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/count/index.html b/website/generated-content/documentation/transforms/python/aggregation/count/index.html index 278d035..a516b8f 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/count/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/count/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/distinct/index.html b/website/generated-content/documentation/transforms/python/aggregation/distinct/index.html index 35f1aed..1fdd966 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/distinct/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/distinct/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/groupbykey/index.html b/website/generated-content/documentation/transforms/python/aggregation/groupbykey/index.html index d05f30e..d4ef686 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/groupbykey/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/groupbykey/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/groupintobatches/index.html b/website/generated-content/documentation/transforms/python/aggregation/groupintobatches/index.html index e05fb65..937f784 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/groupintobatches/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/groupintobatches/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/latest/index.html b/website/generated-content/documentation/transforms/python/aggregation/latest/index.html index 173b5dc..cbfea55 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/latest/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/latest/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/max/index.html b/website/generated-content/documentation/transforms/python/aggregation/max/index.html index e4bc98d..8a08308 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/max/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/max/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/mean/index.html b/website/generated-content/documentation/transforms/python/aggregation/mean/index.html index dc878c9..b3cbaa8 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/mean/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/mean/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/min/index.html b/website/generated-content/documentation/transforms/python/aggregation/min/index.html index 8c6b88c..6489c34 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/min/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/min/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/sample/index.html b/website/generated-content/documentation/transforms/python/aggregation/sample/index.html index 95d2353..f9a9bc4 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/sample/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/sample/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/sum/index.html b/website/generated-content/documentation/transforms/python/aggregation/sum/index.html index ec7df3c..c9de6a7 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/sum/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/sum/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/aggregation/top/index.html b/website/generated-content/documentation/transforms/python/aggregation/top/index.html index fca8282..ee42c95 100644 --- a/website/generated-content/documentation/transforms/python/aggregation/top/index.html +++ b/website/generated-content/documentation/transforms/python/aggregation/top/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/filter/index.html b/website/generated-content/documentation/transforms/python/elementwise/filter/index.html index 84f45e5..41c0f0a 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/filter/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/filter/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/flatmap/index.html b/website/generated-content/documentation/transforms/python/elementwise/flatmap/index.html index 19aa9a2..970374c 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/flatmap/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/flatmap/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/keys/index.html b/website/generated-content/documentation/transforms/python/elementwise/keys/index.html index efd72cc..b9f8193 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/keys/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/keys/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/kvswap/index.html b/website/generated-content/documentation/transforms/python/elementwise/kvswap/index.html index 01d2167..ea6e97e 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/kvswap/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/kvswap/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/map/index.html b/website/generated-content/documentation/transforms/python/elementwise/map/index.html index 4b84bce..ee58773 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/map/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/map/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/pardo/index.html b/website/generated-content/documentation/transforms/python/elementwise/pardo/index.html index 77e8306..0539f5f 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/pardo/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/pardo/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/partition/index.html b/website/generated-content/documentation/transforms/python/elementwise/partition/index.html index 186b2e0..2940016 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/partition/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/partition/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/regex/index.html b/website/generated-content/documentation/transforms/python/elementwise/regex/index.html index 10943af..37eb48d 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/regex/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/regex/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/reify/index.html b/website/generated-content/documentation/transforms/python/elementwise/reify/index.html index 27e54a5..4bf30e6 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/reify/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/reify/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/tostring/index.html b/website/generated-content/documentation/transforms/python/elementwise/tostring/index.html index 7c45ec5..01c89c5 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/tostring/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/tostring/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/values/index.html b/website/generated-content/documentation/transforms/python/elementwise/values/index.html index 280cff5..9da5070 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/values/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/values/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/withkeys/index.html b/website/generated-content/documentation/transforms/python/elementwise/withkeys/index.html index 6284340..f8fab7b 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/withkeys/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/withkeys/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/elementwise/withtimestamps/index.html b/website/generated-content/documentation/transforms/python/elementwise/withtimestamps/index.html index decd9e5..8b92b3c 100644 --- a/website/generated-content/documentation/transforms/python/elementwise/withtimestamps/index.html +++ b/website/generated-content/documentation/transforms/python/elementwise/withtimestamps/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/other/create/index.html b/website/generated-content/documentation/transforms/python/other/create/index.html index daad516..66c8785 100644 --- a/website/generated-content/documentation/transforms/python/other/create/index.html +++ b/website/generated-content/documentation/transforms/python/other/create/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/other/flatten/index.html b/website/generated-content/documentation/transforms/python/other/flatten/index.html index f5cd6a0..cfad58c 100644 --- a/website/generated-content/documentation/transforms/python/other/flatten/index.html +++ b/website/generated-content/documentation/transforms/python/other/flatten/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/other/passert/index.html b/website/generated-content/documentation/transforms/python/other/passert/index.html index 61da4cd..e86e278 100644 --- a/website/generated-content/documentation/transforms/python/other/passert/index.html +++ b/website/generated-content/documentation/transforms/python/other/passert/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/other/reshuffle/index.html b/website/generated-content/documentation/transforms/python/other/reshuffle/index.html index 4522300..1394dfc 100644 --- a/website/generated-content/documentation/transforms/python/other/reshuffle/index.html +++ b/website/generated-content/documentation/transforms/python/other/reshuffle/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/other/view/index.html b/website/generated-content/documentation/transforms/python/other/view/index.html index d4fe252..6d30074 100644 --- a/website/generated-content/documentation/transforms/python/other/view/index.html +++ b/website/generated-content/documentation/transforms/python/other/view/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/other/windowinto/index.html b/website/generated-content/documentation/transforms/python/other/windowinto/index.html index 4e9c74a..6b4a067 100644 --- a/website/generated-content/documentation/transforms/python/other/windowinto/index.html +++ b/website/generated-content/documentation/transforms/python/other/windowinto/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li> diff --git a/website/generated-content/documentation/transforms/python/overview/index.html b/website/generated-content/documentation/transforms/python/overview/index.html index 9dcc3b6..92f7e6c 100644 --- a/website/generated-content/documentation/transforms/python/overview/index.html +++ b/website/generated-content/documentation/transforms/python/overview/index.html @@ -374,6 +374,7 @@ <li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li> <li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li> <li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li> + <li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li> <li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li> <li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li> <li><a href="/documentation/transforms/java/aggregation/mean/">Mean</a></li>