This is an automated email from the ASF dual-hosted git repository.
adarshsanjeev pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 9d77ef04f40 Cleanup usages of stopwatch (#16478)
add 21f725f33e8 Add octet streaming of sketchs in MSQ (#16269)
No new revisions were added by this update.
Summary of changes:
benchmarks/pom.xml | 6 +
.../druid/benchmark/MsqSketchesBenchmark.java | 146 ++++++++++++++++
.../msq/indexing/client/SketchResponseHandler.java | 100 +++++++++++
.../msq/indexing/client/WorkerChatHandler.java | 52 +++++-
.../apache/druid/msq/rpc/BaseWorkerClientImpl.java | 32 ++--
.../statistics/ClusterByStatisticsSnapshot.java | 17 +-
.../DelegateOrMinKeyCollectorSnapshot.java | 17 ++
.../druid/msq/statistics/DistinctKeySnapshot.java | 10 +-
.../druid/msq/statistics/KeyCollectorSnapshot.java | 2 +
.../QuantilesSketchKeyCollectorSnapshot.java | 17 ++
.../serde/ClusterByStatisticsSnapshotSerde.java | 194 +++++++++++++++++++++
.../statistics/serde/DelegateOrMinSerializer.java | 64 +++++++
.../serde/DistinctSnapshotSerializer.java | 60 +++++++
.../serde/KeyCollectorSnapshotDeserializer.java | 143 +++++++++++++++
.../serde/KeyCollectorSnapshotSerializer.java | 53 ++++++
.../serde/QuantilesSnapshotSerializer.java | 56 ++++++
.../druid/msq/indexing/WorkerChatHandlerTest.java | 8 +-
.../ClusterByStatisticsCollectorImplTest.java | 15 +-
.../serde/KeyCollectorSnapshotSerializerTest.java | 92 ++++++++++
.../client/response/BytesFullResponseHolder.java | 16 ++
.../response/BytesFullResponseHolderTest.java | 108 ++++++++++++
21 files changed, 1171 insertions(+), 37 deletions(-)
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/MsqSketchesBenchmark.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/client/SketchResponseHandler.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/serde/ClusterByStatisticsSnapshotSerde.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/serde/DelegateOrMinSerializer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/serde/DistinctSnapshotSerializer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/serde/KeyCollectorSnapshotDeserializer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/serde/KeyCollectorSnapshotSerializer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/serde/QuantilesSnapshotSerializer.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/serde/KeyCollectorSnapshotSerializerTest.java
create mode 100644
processing/src/test/java/org/apache/druid/java/util/http/client/response/BytesFullResponseHolderTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
