Package com.influxdb.query.dsl.functions

Class RangeFlux

java.lang.Object

com.influxdb.query.dsl.Flux

com.influxdb.query.dsl.functions.AbstractParametrizedFlux

com.influxdb.query.dsl.functions.RangeFlux

All Implemented Interfaces:

Expression, HasImports

public final class RangeFlux
extends AbstractParametrizedFlux

Filters the results by time boundaries. See SPEC.

Options

• start - Specifies the oldest time to be included in the results [duration or timestamp]
• stop - Specifies the exclusive newest time to be included in the results. Defaults to "now". [duration or timestamp]

Example

 Flux flux = Flux
     .from("telegraf")
     .range(-12L, -1L, ChronoUnit.HOURS)
 

Author:

Jakub Bednar (bednar@github) (26/06/2018 07:04)

Field Summary

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

functionsParameters, imports

Constructor Summary

Constructors

Constructor	Description
RangeFlux(Flux flux)

Method Summary

Modifier and Type	Method	Description
void	collectImports(Set<String> collectedImports)	Collects all imports of the flux.
protected String	operatorName()
RangeFlux	withStart(Long start)
RangeFlux	withStart(Long start, ChronoUnit unit)
RangeFlux	withStart(String start)
RangeFlux	withStart(Instant start)
RangeFlux	withStop(Long stop)
RangeFlux	withStop(Long stop, ChronoUnit unit)
RangeFlux	withStop(String stop)
RangeFlux	withStop(Instant stop)

Methods inherited from class com.influxdb.query.dsl.functions.AbstractParametrizedFlux

appendActual, beforeAppendOperatorName

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

RangeFlux

public RangeFlux(@Nonnull
 Flux flux)

Method Details

operatorName

@Nonnull
protected String operatorName()

Specified by:

operatorName in class AbstractParametrizedFlux

Returns:

name of function

withStart

@Nonnull
public RangeFlux withStart(@Nonnull
 Instant start)

Parameters:

start - Specifies the oldest time to be included in the results

Returns:

this

withStart

@Nonnull
public RangeFlux withStart(@Nonnull
 Long start,
 @Nonnull
 ChronoUnit unit)

Parameters:

start - Specifies the oldest time to be included in the results

unit - a ChronoUnit determining how to interpret the start parameter

Returns:

this

withStart

@Nonnull
public RangeFlux withStart(@Nonnull
 String start)

Parameters:

start - Specifies the oldest time to be included in the results

Returns:

this

withStart

@Nonnull
public RangeFlux withStart(Long start)

Parameters:

start - Specifies the oldest time (Unix timestamp in seconds) to be included in the results

Returns:

this

withStop

@Nonnull
public RangeFlux withStop(@Nonnull
 Instant stop)

Parameters:

stop - Specifies the exclusive newest time to be included in the results

Returns:

this

withStop

@Nonnull
public RangeFlux withStop(@Nonnull
 Long stop,
 @Nonnull
 ChronoUnit unit)

Parameters:

stop - Specifies the exclusive newest time to be included in the results

unit - a ChronoUnit determining how to interpret the start parameter

Returns:

this

withStop

@Nonnull
public RangeFlux withStop(@Nonnull
 String stop)

Parameters:

stop - Specifies the exclusive newest time to be included in the results

Returns:

this

withStop

@Nonnull
public RangeFlux withStop(Long stop)

Parameters:

stop - Specifies the exclusive newest time (Unix timestamp in seconds) to be included in the results

Returns:

this

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