Class CountDistinctOverTime
java.lang.Object
org.elasticsearch.xpack.esql.core.tree.Node<Expression>
org.elasticsearch.xpack.esql.core.expression.Expression
org.elasticsearch.xpack.esql.core.expression.function.Function
org.elasticsearch.xpack.esql.expression.function.aggregate.AggregateFunction
org.elasticsearch.xpack.esql.expression.function.aggregate.TimeSeriesAggregateFunction
org.elasticsearch.xpack.esql.expression.function.aggregate.CountDistinctOverTime
- All Implemented Interfaces:
NamedWriteable,Writeable,PostAnalysisPlanVerificationAware,Resolvable,OptionalArgument
Similar to
CountDistinct, but it is used to calculate the distinct count of values over a time series from the given field.-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.xpack.esql.core.expression.Expression
Expression.TypeResolutionNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionCountDistinctOverTime(Source source, Expression field, Expression precision) CountDistinctOverTime(Source source, Expression field, Expression filter, Expression precision) -
Method Summary
Modifier and TypeMethodDescriptiondataType()protected NodeInfo<CountDistinctOverTime> info()Returns the aggregation function to be used in the first aggregation stage, which is grouped by `_tsid` (and `time_bucket`).replaceChildren(List<Expression> newChildren) protected Expression.TypeResolutionwithFilter(Expression filter) Attach a filter to the aggregate function.Methods inherited from class org.elasticsearch.xpack.esql.expression.function.aggregate.AggregateFunction
deprecatedWriteParams, equals, field, filter, hasFilter, hashCode, parameters, postAnalysisPlanVerification, readGenericAggregateFunction, withParameters, writeToMethods inherited from class org.elasticsearch.xpack.esql.core.expression.function.Function
arguments, functionName, nodeString, nullableMethods inherited from class org.elasticsearch.xpack.esql.core.expression.Expression
canonical, canonicalize, childrenResolved, fold, foldable, propertiesToString, references, resolved, semanticEquals, semanticHash, toString, typeResolvedMethods inherited from class org.elasticsearch.xpack.esql.core.tree.Node
anyMatch, children, collect, collectFirstChildren, collectLeaves, doCollectFirst, forEachDown, forEachDown, forEachDownMayReturnEarly, forEachProperty, forEachPropertyDown, forEachPropertyOnly, forEachPropertyUp, forEachUp, forEachUp, nodeName, nodeProperties, replaceChildrenSameSize, source, sourceLocation, sourceText, transformChildren, transformDown, transformDown, transformDown, transformNodeProps, transformPropertiesDown, transformPropertiesOnly, transformPropertiesUp, transformUp, transformUp, transformUp
-
Field Details
-
ENTRY
-
-
Constructor Details
-
CountDistinctOverTime
-
CountDistinctOverTime
public CountDistinctOverTime(Source source, Expression field, Expression filter, Expression precision)
-
-
Method Details
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable
-
withFilter
Description copied from class:AggregateFunctionAttach a filter to the aggregate function.- Specified by:
withFilterin classAggregateFunction
-
info
- Specified by:
infoin classNode<Expression>
-
replaceChildren
- Specified by:
replaceChildrenin classNode<Expression>
-
resolveType
- Overrides:
resolveTypein classAggregateFunction
-
dataType
- Specified by:
dataTypein classExpression
-
perTimeSeriesAggregation
Description copied from class:TimeSeriesAggregateFunctionReturns the aggregation function to be used in the first aggregation stage, which is grouped by `_tsid` (and `time_bucket`).- Specified by:
perTimeSeriesAggregationin classTimeSeriesAggregateFunction- See Also:
-