Package com.influxdb.query.dsl.functions

Class ExpressionFlux

java.lang.Object

com.influxdb.query.dsl.Flux

com.influxdb.query.dsl.functions.ExpressionFlux

All Implemented Interfaces:

Expression, HasImports

public final class ExpressionFlux
extends Flux

The custom Flux expression.

Example

     Flux.from("telegraf")
          .expression("map(fn: (r) => r._value * r._value)")
          .expression("sum()")
 

Author:

Jakub Bednar (bednar@github) (27/06/2018 11:21)

Field Summary

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

functionsParameters, imports

Constructor Summary

Constructors

Constructor	Description
ExpressionFlux(Flux source, String expression)

Method Summary

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

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, elapsed, elapsed, elapsed, elapsed, 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

ExpressionFlux

public ExpressionFlux(@Nonnull
 Flux source,
 @Nonnull
 String expression)

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

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