### Question:
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);  }### Answer:
@Test void integralByParameter() { Flux flux = Flux .from("telegraf") .integral() .withUnit(5L, ChronoUnit.MINUTES); Assertions.assertThat(flux.toString()).isEqualToIgnoringWhitespace("from(bucket:\"telegraf\") |> integral(unit: 5m)"); }
@Test void integralByString() { Flux flux = Flux .from("telegraf") .integral() .withUnit("10m6h"); Assertions.assertThat(flux.toString()).isEqualToIgnoringWhitespace("from(bucket:\"telegraf\") |> integral(unit: 10m6h)"); }