@Test void integralByParameter() { Flux flux = Flux .from("telegraf") .integral() .withUnit(5L, ChronoUnit.MINUTES); Assertions.assertThat(flux.toString()).isEqualToIgnoringWhitespace("from(bucket:\"telegraf\") |> integral(unit: 5m)"); }
@Nonnull public IntegralFlux withUnit(@Nonnull final Long duration, @Nonnull final ChronoUnit unit) { Arguments.checkNotNull(duration, "Duration is required"); Arguments.checkNotNull(unit, "ChronoUnit is required"); this.withPropertyValue("unit", duration, unit); return this; }
IntegralFlux extends AbstractParametrizedFlux { @Nonnull public IntegralFlux withUnit(@Nonnull final Long duration, @Nonnull final ChronoUnit unit) { Arguments.checkNotNull(duration, "Duration is required"); Arguments.checkNotNull(unit, "ChronoUnit is required"); this.withPropertyValue("unit", duration, unit); return this; } }
IntegralFlux extends AbstractParametrizedFlux { @Nonnull public IntegralFlux withUnit(@Nonnull final Long duration, @Nonnull final ChronoUnit unit) { Arguments.checkNotNull(duration, "Duration is required"); Arguments.checkNotNull(unit, "ChronoUnit is required"); this.withPropertyValue("unit", duration, unit); return this; } IntegralFlux(@Nonnull final Flux source); }
IntegralFlux extends AbstractParametrizedFlux { @Nonnull public IntegralFlux withUnit(@Nonnull final Long duration, @Nonnull final ChronoUnit unit) { Arguments.checkNotNull(duration, "Duration is required"); Arguments.checkNotNull(unit, "ChronoUnit is required"); this.withPropertyValue("unit", duration, unit); return this; } IntegralFlux(@Nonnull final Flux source); @Nonnull IntegralFlux withUnit(@Nonnull final Long duration, @Nonnull final ChronoUnit unit); @Nonnull IntegralFlux withUnit(@Nonnull final String unit); }
IntegralFlux extends AbstractParametrizedFlux { @Nonnull public IntegralFlux withUnit(@Nonnull final Long duration, @Nonnull final ChronoUnit unit) { Arguments.checkNotNull(duration, "Duration is required"); Arguments.checkNotNull(unit, "ChronoUnit is required"); this.withPropertyValue("unit", duration, unit); return this; } IntegralFlux(@Nonnull final Flux source); @Nonnull IntegralFlux withUnit(@Nonnull final Long duration, @Nonnull final ChronoUnit unit); @Nonnull IntegralFlux withUnit(@Nonnull final String unit);  }