### Question:
RenameFlux extends AbstractParametrizedFlux { @Nonnull public RenameFlux withFunction(@Nonnull final String function) { Arguments.checkNonEmpty(function, "Function"); this.withFunction("fn: (column)", function); return this; } RenameFlux(@Nonnull final Flux source); @Nonnull RenameFlux withColumns(@Nonnull final Map<String, String> columns); @Nonnull RenameFlux withFunction(@Nonnull final String function);  }### Answer:
@Test void renameByParameters() { Flux flux = Flux .from("telegraf") .rename() .withFunction("\"{column}_new\""); Assertions.assertThat(flux.toString()).isEqualToIgnoringWhitespace("from(bucket:\"telegraf\") |> rename(fn: (column) => \"{column}_new\")"); }