Package com.influxdb.query.dsl.functions

Class AbstractParametrizedFlux

java.lang.Object

com.influxdb.query.dsl.Flux

com.influxdb.query.dsl.functions.AbstractParametrizedFlux

All Implemented Interfaces:

Expression, HasImports

Direct Known Subclasses:

AbstractFunctionCallFlux, AggregateWindow, ArrayFromFlux, ColumnsFlux, CountFlux, CovarianceFlux, CumulativeSumFlux, DerivativeFlux, DifferenceFlux, DistinctFlux, DropFlux, DuplicateFlux, FillFlux, FilterFlux, FirstFlux, FreestyleExpression, FromFlux, GroupFlux, IntegralFlux, InterpolateLinearFlux, JoinFlux, KeepFlux, LastFlux, LimitFlux, MapFlux, MaxFlux, MeanFlux, MinFlux, PivotFlux, QuantileFlux, RangeFlux, ReduceFlux, RenameFlux, SampleFlux, SetFlux, SkewFlux, SortFlux, SpreadFlux, StddevFlux, SumFlux, TailFlux, TimeShiftFlux, ToBoolFlux, ToDurationFlux, ToFloatFlux, ToFlux, ToIntFlux, ToStringFlux, ToTimeFlux, ToUIntFlux, TruncateTimeColumnFlux, UnionFlux, WindowFlux, YieldFlux

public abstract class AbstractParametrizedFlux
extends Flux

Author:

Jakub Bednar (bednar@github) (27/06/2018 14:03)

Field Summary

Fields inherited from class com.influxdb.query.dsl.Flux

functionsParameters, imports

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractParametrizedFlux()
protected	AbstractParametrizedFlux(Flux source)

Method Summary

Modifier and Type	Method	Description
void	appendActual(Map<String,Object> parameters, StringBuilder builder)	Append actual Flux function to Flux query.
protected void	beforeAppendOperatorName(StringBuilder operator, Map<String,Object> parameters)	Possibility to customize function.
void	collectImports(Set<String> collectedImports)	Collects all imports of the flux.
protected abstract String	operatorName()

Methods inherited from class com.influxdb.query.dsl.Flux

addImport, aggregateWindow, aggregateWindow, arrayFrom, arrayFrom, asVariable, columns, columns, count, count, covariance, covariance, covariance, covariance, covariance, covariance, covariance, covariance, covariance, cumulativeSum, cumulativeSum, cumulativeSum, derivative, derivative, difference, difference, difference, difference, difference, difference, distinct, distinct, drop, drop, drop, drop, duplicate, duplicate, expression, fill, fill, filter, filter, first, from, from, from, function, getImports, group, groupBy, groupBy, groupBy, groupExcept, groupExcept, groupExcept, integral, integral, interpolateLinear, interpolateLinear, join, join, keep, keep, keep, keep, last, last, limit, limit, limit, map, map, max, max, mean, mean, min, min, pivot, pivot, pivot, quantile, quantile, quantile, quantile, quantile, range, range, range, range, range, range, range, reduce, reduce, rename, rename, rename, sample, sample, sample, set, set, skew, skew, sort, sort, sort, sort, sort, sort, spread, spread, stddev, stddev, sum, sum, tail, tail, tail, timeShift, timeShift, timeShift, timeShift, to, to, to, to, to, to, to, to, toBool, toDuration, toFloat, toInt, toString, toString, toString, toStringConvert, toTime, toUInt, truncateTimeColumn, union, window, window, window, window, window, window, window, withFunction, withFunctionNamed, withPipedFunction, withPropertyNamed, withPropertyNamed, withPropertyValue, withPropertyValue, withPropertyValueEscaped, yield, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

AbstractParametrizedFlux

protected AbstractParametrizedFlux()

AbstractParametrizedFlux

protected AbstractParametrizedFlux(@Nonnull
 Flux source)

Method Details

appendActual

public void appendActual(@Nonnull
 Map<String,Object> parameters,
 @Nonnull
 StringBuilder builder)

Description copied from class: Flux

Append actual Flux function to Flux query.

Parameters:

parameters - named parameters for Flux query

builder - Flux query chaing

operatorName

@Nonnull
protected abstract String operatorName()

Returns:

name of function

beforeAppendOperatorName

protected void beforeAppendOperatorName(@Nonnull
 StringBuilder operator,
 @Nonnull
 Map<String,Object> parameters)

Possibility to customize function.

Parameters:

operator - current Flux function

parameters - parameters

See Also:

• JoinFlux

collectImports

public void collectImports(@Nonnull
 Set<String> collectedImports)

Description copied from class: Flux

Collects all imports of the flux.

Overrides:

collectImports in class Flux

Parameters:

collectedImports - a set to be filled by the used imports