Package com.influxdb.query.dsl.functions

Class SortFlux

java.lang.Object

com.influxdb.query.dsl.Flux

com.influxdb.query.dsl.functions.AbstractParametrizedFlux

com.influxdb.query.dsl.functions.SortFlux

All Implemented Interfaces:

Expression, HasImports

public final class SortFlux
extends AbstractParametrizedFlux

Sorts the results by the specified columns Default sort is ascending. See SPEC.

Options

• columns - List of columns used to sort; precedence from left to right. Default is ["value"] [array of strings]
• desc - Sort results descending. Default false [bool]

Example

 Flux flux = Flux
     .from("telegraf")
     .sort(new String[]{"region", "value"});

     from(bucket:"telegraf")
          |> filter(fn: (r) => r["_measurement"] == "system" AND r["_field"] == "uptime")
          |> range(start:-12h)
          |> sort(desc: true)
 

Author:

Jakub Bednar (bednar@github) (25/06/2018 13:20)

Field Summary

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

functionsParameters, imports

Constructor Summary

Constructors

Constructor	Description
SortFlux(Flux flux)

Method Summary

Modifier and Type	Method	Description
void	collectImports(Set<String> collectedImports)	Collects all imports of the flux.
protected String	operatorName()
SortFlux	withColumns(String[] columns)
SortFlux	withColumns(Collection<String> columns)
SortFlux	withDesc(boolean desc)

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

SortFlux

public SortFlux(@Nonnull
 Flux flux)

Method Details

operatorName

@Nonnull
protected String operatorName()

Specified by:

operatorName in class AbstractParametrizedFlux

Returns:

name of function

withDesc

@Nonnull
public SortFlux withDesc(boolean desc)

Parameters:

desc - use the descending sorting

Returns:

this

withColumns

@Nonnull
public SortFlux withColumns(@Nonnull
 String[] columns)

Parameters:

columns - columns used to sort

Returns:

this

withColumns

@Nonnull
public SortFlux withColumns(@Nonnull
 Collection<String> columns)

Parameters:

columns - columns used to sort

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