### Question:
AggregateWindow extends AbstractParametrizedFlux { public AggregateWindow(@Nonnull final Flux source) { super(source); } AggregateWindow(@Nonnull final Flux source); @Nonnull AggregateWindow withEvery(@Nonnull final Long every, @Nonnull final ChronoUnit everyUnit); @Nonnull AggregateWindow withEvery(@Nonnull final String every); @Nonnull AggregateWindow withFunction(@Nonnull final String function); @Nonnull AggregateWindow withAggregateFunction(@Nonnull final String namedFunction); @Nonnull AggregateWindow withColumn(@Nonnull final String column); @Nonnull AggregateWindow withTimeSrc(@Nonnull final String timeSrc); @Nonnull AggregateWindow withTimeDst(@Nonnull final String timeDst); @Nonnull AggregateWindow withCreateEmpty(final boolean createEmpty);  }### Answer:
@Test void aggregateWindow() { Flux flux = Flux .from("telegraf") .aggregateWindow(10L, ChronoUnit.SECONDS, "mean"); Assertions.assertThat(flux.toString()).isEqualToIgnoringWhitespace("from(bucket:\"telegraf\") |> aggregateWindow(every: 10s, fn: mean)"); }