Class MaxFlux

All Implemented Interfaces:
Expression, HasImports

public final class MaxFlux extends AbstractParametrizedFlux
Returns the max value within the results. See SPEC.

Options

  • column - The column to use to calculate the maximum value [string]. Default is _value.

Example

 Flux flux = Flux
     .from("telegraf")
     .range(-12L, ChronoUnit.HOURS)
     .window(10L, ChronoUnit.MINUTES)
     .max();
 
Author:
Jakub Bednar (bednar@github) (25/06/2018 09:49)
  • Constructor Details

    • MaxFlux

      public MaxFlux(@Nonnull Flux source)
  • Method Details

    • operatorName

      @Nonnull protected String operatorName()
      Specified by:
      operatorName in class AbstractParametrizedFlux
      Returns:
      name of function
    • withColumn

      @Nonnull public MaxFlux withColumn(@Nonnull String column)
      Parameters:
      column - The column to use to calculate the maximum value.
      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