Package com.influxdb.query.dsl.functions

Class PivotFlux

java.lang.Object

com.influxdb.query.dsl.Flux

com.influxdb.query.dsl.functions.AbstractParametrizedFlux

com.influxdb.query.dsl.functions.PivotFlux

All Implemented Interfaces:

Expression, HasImports

public final class PivotFlux
extends AbstractParametrizedFlux

Pivot collects values stored vertically (column-wise) in a table and aligns them horizontally (row-wise) into logical sets. See SPEC.

Options

• rowKey - List of columns used to uniquely identify a row for the output. [array of strings]
• columnKey - List of columns used to pivot values onto each row identified by the rowKey. [array of strings]
• valueColumn - Identifies the single column that contains the value to be moved around the pivot [string]

Example

 Flux flux = Flux.from("telegraf")
     .pivot()
         .withRowKey(new String[]{"_time"})
         .withColumnKey(new String[]{"_field"})
         .withValueColumn("_value");
 

Author:

Jakub Bednar (10/10/2018 06:16)

Field Summary

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

functionsParameters, imports

Constructor Summary

Constructors

Constructor	Description
PivotFlux(Flux source)

Method Summary

Modifier and Type	Method	Description
void	collectImports(Set<String> collectedImports)	Collects all imports of the flux.
protected String	operatorName()
PivotFlux	withColumnKey(String[] columnKey)
PivotFlux	withColumnKey(Collection<String> columnKey)
PivotFlux	withRowKey(String[] rowKey)
PivotFlux	withRowKey(Collection<String> rowKey)
PivotFlux	withValueColumn(String valueColumn)

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

PivotFlux

public PivotFlux(@Nonnull
 Flux source)

Method Details

operatorName

@Nonnull
protected String operatorName()

Specified by:

operatorName in class AbstractParametrizedFlux

Returns:

name of function

withRowKey

@Nonnull
public PivotFlux withRowKey(@Nonnull
 String[] rowKey)

Parameters:

rowKey - the columns used to uniquely identify a row for the output.

Returns:

this

withRowKey

@Nonnull
public PivotFlux withRowKey(@Nonnull
 Collection<String> rowKey)

Parameters:

rowKey - the columns used to uniquely identify a row for the output.

Returns:

this

withColumnKey

@Nonnull
public PivotFlux withColumnKey(@Nonnull
 String[] columnKey)

Parameters:

columnKey - the columns used to pivot values onto each row identified by the rowKey.

Returns:

this

withColumnKey

@Nonnull
public PivotFlux withColumnKey(@Nonnull
 Collection<String> columnKey)

Parameters:

columnKey - the columns used to pivot values onto each row identified by the rowKey.

Returns:

this

withValueColumn

@Nonnull
public PivotFlux withValueColumn(@Nonnull
 String valueColumn)

Parameters:

valueColumn - the single column that contains the value to be moved around the pivot

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