mirror of
https://github.com/apache/druid.git
synced 2025-02-24 03:26:04 +00:00
Use the latest Apache DataSketches release 2.0.0 (#10917)
* use the latest Apache DataSketches release 2.0.0 * updated datasketches version Co-authored-by: AlexanderSaydakov <AlexanderSaydakov@users.noreply.github.com>
This commit is contained in:
parent
07902f607b
commit
f930cf14d6
@ -23,9 +23,9 @@ import com.fasterxml.jackson.annotation.JsonCreator;
|
|||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import com.google.common.base.Preconditions;
|
import com.google.common.base.Preconditions;
|
||||||
import org.apache.datasketches.Util;
|
import org.apache.datasketches.Util;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSetOperationBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSetOperationBuilder;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUnion;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUnion;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.query.aggregation.AggregateCombiner;
|
import org.apache.druid.query.aggregation.AggregateCombiner;
|
||||||
import org.apache.druid.query.aggregation.Aggregator;
|
import org.apache.druid.query.aggregation.Aggregator;
|
||||||
|
@ -19,8 +19,8 @@
|
|||||||
|
|
||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.query.aggregation.Aggregator;
|
import org.apache.druid.query.aggregation.Aggregator;
|
||||||
import org.apache.druid.segment.BaseDoubleColumnValueSelector;
|
import org.apache.druid.segment.BaseDoubleColumnValueSelector;
|
||||||
import org.apache.druid.segment.DimensionSelector;
|
import org.apache.druid.segment.DimensionSelector;
|
||||||
@ -33,7 +33,7 @@ import java.util.List;
|
|||||||
/**
|
/**
|
||||||
* This aggregator builds sketches from raw data.
|
* This aggregator builds sketches from raw data.
|
||||||
* The input is in the form of a key and array of double values.
|
* The input is in the form of a key and array of double values.
|
||||||
* The output is {@link org.apache.datasketches.tuple.ArrayOfDoublesSketch}.
|
* The output is {@link org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch}.
|
||||||
*/
|
*/
|
||||||
public class ArrayOfDoublesSketchBuildAggregator implements Aggregator
|
public class ArrayOfDoublesSketchBuildAggregator implements Aggregator
|
||||||
{
|
{
|
||||||
|
@ -21,9 +21,9 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
|
|
||||||
import com.google.common.util.concurrent.Striped;
|
import com.google.common.util.concurrent.Striped;
|
||||||
import org.apache.datasketches.memory.WritableMemory;
|
import org.apache.datasketches.memory.WritableMemory;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketches;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketches;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.query.aggregation.BufferAggregator;
|
import org.apache.druid.query.aggregation.BufferAggregator;
|
||||||
import org.apache.druid.query.monomorphicprocessing.RuntimeShapeInspector;
|
import org.apache.druid.query.monomorphicprocessing.RuntimeShapeInspector;
|
||||||
import org.apache.druid.segment.BaseDoubleColumnValueSelector;
|
import org.apache.druid.segment.BaseDoubleColumnValueSelector;
|
||||||
@ -41,7 +41,7 @@ import java.util.concurrent.locks.ReadWriteLock;
|
|||||||
/**
|
/**
|
||||||
* This aggregator builds sketches from raw data.
|
* This aggregator builds sketches from raw data.
|
||||||
* The input is in the form of a key and array of double values.
|
* The input is in the form of a key and array of double values.
|
||||||
* The output is {@link org.apache.datasketches.tuple.ArrayOfDoublesSketch}.
|
* The output is {@link org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch}.
|
||||||
*/
|
*/
|
||||||
public class ArrayOfDoublesSketchBuildBufferAggregator implements BufferAggregator
|
public class ArrayOfDoublesSketchBuildBufferAggregator implements BufferAggregator
|
||||||
{
|
{
|
||||||
|
@ -22,7 +22,7 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
import com.fasterxml.jackson.core.JsonGenerator;
|
import com.fasterxml.jackson.core.JsonGenerator;
|
||||||
import com.fasterxml.jackson.databind.JsonSerializer;
|
import com.fasterxml.jackson.databind.JsonSerializer;
|
||||||
import com.fasterxml.jackson.databind.SerializerProvider;
|
import com.fasterxml.jackson.databind.SerializerProvider;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
|
@ -19,9 +19,9 @@
|
|||||||
|
|
||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSetOperationBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSetOperationBuilder;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUnion;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUnion;
|
||||||
import org.apache.druid.query.aggregation.Aggregator;
|
import org.apache.druid.query.aggregation.Aggregator;
|
||||||
import org.apache.druid.segment.BaseObjectColumnValueSelector;
|
import org.apache.druid.segment.BaseObjectColumnValueSelector;
|
||||||
|
|
||||||
|
@ -21,10 +21,10 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
|
|
||||||
import com.google.common.util.concurrent.Striped;
|
import com.google.common.util.concurrent.Striped;
|
||||||
import org.apache.datasketches.memory.WritableMemory;
|
import org.apache.datasketches.memory.WritableMemory;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSetOperationBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSetOperationBuilder;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketches;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketches;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUnion;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUnion;
|
||||||
import org.apache.druid.query.aggregation.BufferAggregator;
|
import org.apache.druid.query.aggregation.BufferAggregator;
|
||||||
import org.apache.druid.query.monomorphicprocessing.RuntimeShapeInspector;
|
import org.apache.druid.query.monomorphicprocessing.RuntimeShapeInspector;
|
||||||
import org.apache.druid.segment.BaseObjectColumnValueSelector;
|
import org.apache.druid.segment.BaseObjectColumnValueSelector;
|
||||||
|
@ -19,7 +19,7 @@
|
|||||||
|
|
||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.druid.data.input.InputRow;
|
import org.apache.druid.data.input.InputRow;
|
||||||
import org.apache.druid.segment.GenericColumnSerializer;
|
import org.apache.druid.segment.GenericColumnSerializer;
|
||||||
import org.apache.druid.segment.column.ColumnBuilder;
|
import org.apache.druid.segment.column.ColumnBuilder;
|
||||||
|
@ -23,7 +23,7 @@ import com.fasterxml.jackson.databind.Module;
|
|||||||
import com.fasterxml.jackson.databind.jsontype.NamedType;
|
import com.fasterxml.jackson.databind.jsontype.NamedType;
|
||||||
import com.fasterxml.jackson.databind.module.SimpleModule;
|
import com.fasterxml.jackson.databind.module.SimpleModule;
|
||||||
import com.google.inject.Binder;
|
import com.google.inject.Binder;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.druid.initialization.DruidModule;
|
import org.apache.druid.initialization.DruidModule;
|
||||||
import org.apache.druid.segment.serde.ComplexMetrics;
|
import org.apache.druid.segment.serde.ComplexMetrics;
|
||||||
|
|
||||||
|
@ -20,8 +20,8 @@
|
|||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.memory.Memory;
|
import org.apache.datasketches.memory.Memory;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketches;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketches;
|
||||||
import org.apache.druid.segment.data.ObjectStrategy;
|
import org.apache.druid.segment.data.ObjectStrategy;
|
||||||
|
|
||||||
import javax.annotation.Nullable;
|
import javax.annotation.Nullable;
|
||||||
|
@ -20,13 +20,13 @@
|
|||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.memory.Memory;
|
import org.apache.datasketches.memory.Memory;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesAnotB;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesAnotB;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesCombiner;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesCombiner;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesIntersection;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesIntersection;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSetOperationBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSetOperationBuilder;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketches;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketches;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUnion;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUnion;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.java.util.common.ISE;
|
import org.apache.druid.java.util.common.ISE;
|
||||||
import org.apache.druid.java.util.common.StringUtils;
|
import org.apache.druid.java.util.common.StringUtils;
|
||||||
|
@ -22,7 +22,7 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
import com.fasterxml.jackson.annotation.JsonCreator;
|
import com.fasterxml.jackson.annotation.JsonCreator;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.datasketches.Util;
|
import org.apache.datasketches.Util;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
|
@ -23,8 +23,8 @@ import com.fasterxml.jackson.annotation.JsonCreator;
|
|||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
|
import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
|
||||||
import org.apache.commons.math3.stat.inference.TTest;
|
import org.apache.commons.math3.stat.inference.TTest;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketchIterator;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketchIterator;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
|
@ -21,7 +21,7 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
|
|
||||||
import com.fasterxml.jackson.annotation.JsonCreator;
|
import com.fasterxml.jackson.annotation.JsonCreator;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
|
@ -21,7 +21,7 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
|
|
||||||
import com.fasterxml.jackson.annotation.JsonCreator;
|
import com.fasterxml.jackson.annotation.JsonCreator;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
import org.apache.druid.query.cache.CacheKeyBuilder;
|
import org.apache.druid.query.cache.CacheKeyBuilder;
|
||||||
|
@ -22,8 +22,8 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
import com.fasterxml.jackson.annotation.JsonCreator;
|
import com.fasterxml.jackson.annotation.JsonCreator;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
|
import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketchIterator;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketchIterator;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
|
@ -21,7 +21,7 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
|
|
||||||
import com.fasterxml.jackson.annotation.JsonCreator;
|
import com.fasterxml.jackson.annotation.JsonCreator;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
import org.apache.druid.query.cache.CacheKeyBuilder;
|
import org.apache.druid.query.cache.CacheKeyBuilder;
|
||||||
|
@ -23,8 +23,8 @@ import com.fasterxml.jackson.annotation.JsonCreator;
|
|||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.datasketches.quantiles.DoublesSketch;
|
import org.apache.datasketches.quantiles.DoublesSketch;
|
||||||
import org.apache.datasketches.quantiles.UpdateDoublesSketch;
|
import org.apache.datasketches.quantiles.UpdateDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketchIterator;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketchIterator;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
import org.apache.druid.query.aggregation.datasketches.quantiles.DoublesSketchAggregatorFactory;
|
import org.apache.druid.query.aggregation.datasketches.quantiles.DoublesSketchAggregatorFactory;
|
||||||
|
@ -21,7 +21,7 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
|
|
||||||
import com.fasterxml.jackson.annotation.JsonCreator;
|
import com.fasterxml.jackson.annotation.JsonCreator;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
|
@ -22,8 +22,8 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
import com.fasterxml.jackson.annotation.JsonCreator;
|
import com.fasterxml.jackson.annotation.JsonCreator;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
|
import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketchIterator;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketchIterator;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.query.aggregation.AggregatorUtil;
|
import org.apache.druid.query.aggregation.AggregatorUtil;
|
||||||
import org.apache.druid.query.aggregation.PostAggregator;
|
import org.apache.druid.query.aggregation.PostAggregator;
|
||||||
|
@ -19,8 +19,8 @@
|
|||||||
|
|
||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.query.aggregation.Aggregator;
|
import org.apache.druid.query.aggregation.Aggregator;
|
||||||
|
|
||||||
public class NoopArrayOfDoublesSketchAggregator implements Aggregator
|
public class NoopArrayOfDoublesSketchAggregator implements Aggregator
|
||||||
|
@ -19,8 +19,8 @@
|
|||||||
|
|
||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.query.aggregation.BufferAggregator;
|
import org.apache.druid.query.aggregation.BufferAggregator;
|
||||||
import org.apache.druid.query.monomorphicprocessing.RuntimeShapeInspector;
|
import org.apache.druid.query.monomorphicprocessing.RuntimeShapeInspector;
|
||||||
|
|
||||||
|
@ -123,7 +123,7 @@ public class SketchAggregationTest
|
|||||||
groupByQuery
|
groupByQuery
|
||||||
);
|
);
|
||||||
|
|
||||||
final String expectedSummary = "\n### HeapCompactOrderedSketch SUMMARY: \n"
|
final String expectedSummary = "\n### HeapCompactSketch SUMMARY: \n"
|
||||||
+ " Estimate : 50.0\n"
|
+ " Estimate : 50.0\n"
|
||||||
+ " Upper Bound, 95% conf : 50.0\n"
|
+ " Upper Bound, 95% conf : 50.0\n"
|
||||||
+ " Lower Bound, 95% conf : 50.0\n"
|
+ " Lower Bound, 95% conf : 50.0\n"
|
||||||
|
@ -21,9 +21,9 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import nl.jqno.equalsverifier.EqualsVerifier;
|
import nl.jqno.equalsverifier.EqualsVerifier;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.java.util.common.granularity.Granularities;
|
import org.apache.druid.java.util.common.granularity.Granularities;
|
||||||
import org.apache.druid.query.Druids;
|
import org.apache.druid.query.Druids;
|
||||||
import org.apache.druid.query.aggregation.AggregateCombiner;
|
import org.apache.druid.query.aggregation.AggregateCombiner;
|
||||||
|
@ -23,9 +23,9 @@ import com.fasterxml.jackson.core.JsonProcessingException;
|
|||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import com.google.common.collect.ImmutableMap;
|
import com.google.common.collect.ImmutableMap;
|
||||||
import nl.jqno.equalsverifier.EqualsVerifier;
|
import nl.jqno.equalsverifier.EqualsVerifier;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.jackson.DefaultObjectMapper;
|
import org.apache.druid.jackson.DefaultObjectMapper;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.java.util.common.granularity.Granularities;
|
import org.apache.druid.java.util.common.granularity.Granularities;
|
||||||
|
@ -23,8 +23,8 @@ import com.fasterxml.jackson.core.JsonProcessingException;
|
|||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import com.google.common.collect.ImmutableMap;
|
import com.google.common.collect.ImmutableMap;
|
||||||
import nl.jqno.equalsverifier.EqualsVerifier;
|
import nl.jqno.equalsverifier.EqualsVerifier;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.jackson.DefaultObjectMapper;
|
import org.apache.druid.jackson.DefaultObjectMapper;
|
||||||
import org.apache.druid.java.util.common.IAE;
|
import org.apache.druid.java.util.common.IAE;
|
||||||
import org.apache.druid.java.util.common.granularity.Granularities;
|
import org.apache.druid.java.util.common.granularity.Granularities;
|
||||||
|
@ -22,8 +22,8 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||||
import com.google.common.collect.ImmutableMap;
|
import com.google.common.collect.ImmutableMap;
|
||||||
import nl.jqno.equalsverifier.EqualsVerifier;
|
import nl.jqno.equalsverifier.EqualsVerifier;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.jackson.DefaultObjectMapper;
|
import org.apache.druid.jackson.DefaultObjectMapper;
|
||||||
import org.apache.druid.java.util.common.granularity.Granularities;
|
import org.apache.druid.java.util.common.granularity.Granularities;
|
||||||
import org.apache.druid.query.Druids;
|
import org.apache.druid.query.Druids;
|
||||||
|
@ -22,8 +22,8 @@ package org.apache.druid.query.aggregation.datasketches.tuple;
|
|||||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||||
import com.google.common.collect.ImmutableMap;
|
import com.google.common.collect.ImmutableMap;
|
||||||
import nl.jqno.equalsverifier.EqualsVerifier;
|
import nl.jqno.equalsverifier.EqualsVerifier;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.jackson.DefaultObjectMapper;
|
import org.apache.druid.jackson.DefaultObjectMapper;
|
||||||
import org.apache.druid.java.util.common.granularity.Granularities;
|
import org.apache.druid.java.util.common.granularity.Granularities;
|
||||||
import org.apache.druid.query.Druids;
|
import org.apache.druid.query.Druids;
|
||||||
|
@ -23,8 +23,8 @@ import com.fasterxml.jackson.core.JsonProcessingException;
|
|||||||
import com.google.common.collect.ImmutableMap;
|
import com.google.common.collect.ImmutableMap;
|
||||||
import nl.jqno.equalsverifier.EqualsVerifier;
|
import nl.jqno.equalsverifier.EqualsVerifier;
|
||||||
import org.apache.datasketches.quantiles.DoublesSketch;
|
import org.apache.datasketches.quantiles.DoublesSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.jackson.DefaultObjectMapper;
|
import org.apache.druid.jackson.DefaultObjectMapper;
|
||||||
import org.apache.druid.java.util.common.granularity.Granularities;
|
import org.apache.druid.java.util.common.granularity.Granularities;
|
||||||
import org.apache.druid.query.Druids;
|
import org.apache.druid.query.Druids;
|
||||||
|
@ -19,8 +19,8 @@
|
|||||||
|
|
||||||
package org.apache.druid.query.aggregation.datasketches.tuple;
|
package org.apache.druid.query.aggregation.datasketches.tuple;
|
||||||
|
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketch;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketch;
|
||||||
import org.apache.datasketches.tuple.ArrayOfDoublesUpdatableSketchBuilder;
|
import org.apache.datasketches.tuple.arrayofdoubles.ArrayOfDoublesUpdatableSketchBuilder;
|
||||||
import org.apache.druid.java.util.common.StringUtils;
|
import org.apache.druid.java.util.common.StringUtils;
|
||||||
|
|
||||||
import java.io.BufferedWriter;
|
import java.io.BufferedWriter;
|
||||||
|
@ -3512,7 +3512,7 @@ name: DataSketches
|
|||||||
license_category: binary
|
license_category: binary
|
||||||
module: java-core
|
module: java-core
|
||||||
license_name: Apache License version 2.0
|
license_name: Apache License version 2.0
|
||||||
version: 1.1.0-incubating
|
version: 2.0.0
|
||||||
libraries:
|
libraries:
|
||||||
- org.apache.datasketches: datasketches-java
|
- org.apache.datasketches: datasketches-java
|
||||||
|
|
||||||
|
2
pom.xml
2
pom.xml
@ -83,7 +83,7 @@
|
|||||||
<avatica.version>1.17.0</avatica.version>
|
<avatica.version>1.17.0</avatica.version>
|
||||||
<avro.version>1.9.2</avro.version>
|
<avro.version>1.9.2</avro.version>
|
||||||
<calcite.version>1.21.0</calcite.version>
|
<calcite.version>1.21.0</calcite.version>
|
||||||
<datasketches.version>1.3.0-incubating</datasketches.version>
|
<datasketches.version>2.0.0</datasketches.version>
|
||||||
<datasketches.memory.version>1.3.0</datasketches.memory.version>
|
<datasketches.memory.version>1.3.0</datasketches.memory.version>
|
||||||
<derby.version>10.14.2.0</derby.version>
|
<derby.version>10.14.2.0</derby.version>
|
||||||
<dropwizard.metrics.version>4.0.0</dropwizard.metrics.version>
|
<dropwizard.metrics.version>4.0.0</dropwizard.metrics.version>
|
||||||
|
Loading…
x
Reference in New Issue
Block a user