Class Increase
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.Increase
- All Implemented Interfaces:
NamedWriteable,Writeable,PostAnalysisPlanVerificationAware,Resolvable,OptionalArgument,ToAggregator
The
increase() function calculates the absolute increase of a counter field in a time window.
It is similar to the rate() function, but instead of calculating the per-second average rate of increase,
it calculates the total increase over the time window.-
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
ConstructorsConstructorDescriptionIncrease(StreamInput in) Increase(Source source, Expression field) Increase(Source source, Expression field, Expression timestamp) -
Method Summary
Modifier and TypeMethodDescriptiondataType()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) booleanprotected Expression.TypeResolutionsupplier()toString()withFilter(Expression filter) Attach a filter to the aggregate function.Methods inherited from class org.elasticsearch.xpack.esql.expression.function.aggregate.TimeSeriesAggregateFunction
aggregateInputReferencesMethods inherited from class org.elasticsearch.xpack.esql.expression.function.aggregate.AggregateFunction
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, 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
-
Increase
-
Increase
-
Increase
- Throws:
IOException
-
-
Method Details
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable
-
info
- Specified by:
infoin classNode<Expression>
-
replaceChildren
- Specified by:
replaceChildrenin classNode<Expression>
-
withFilter
Description copied from class:AggregateFunctionAttach a filter to the aggregate function.- Specified by:
withFilterin classAggregateFunction
-
dataType
- Specified by:
dataTypein classExpression
-
resolveType
- Overrides:
resolveTypein classAggregateFunction
-
supplier
- Specified by:
supplierin interfaceToAggregator
-
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:
-
toString
- Overrides:
toStringin classExpression
-
requiredTimeSeriesSource
public boolean requiredTimeSeriesSource()- Overrides:
requiredTimeSeriesSourcein classTimeSeriesAggregateFunction
-