Проблема NestedValueProvider

Question

Я пытаюсь использовать NestedValueProvider , как в примере, представленном в документации облачной платформы Google https://cloud.google.com/dataflow/docs/templates/creating-templates, но выдает исключение: невозможно сериализовать NestedValueProvider {value = RuntimeValueProvider {propertyName= дата, по умолчанию = ноль}, переводчик =}

@Description("Processing date")
@Validation.Required
ValueProvider<String> getDate();
void setDate(ValueProvider<String> date);

PCollectionTuple lines = this.p
                    .apply("ReadW2", TextIO.read().from(ValueProvider.NestedValueProvider.of(options.getDate(), new SerializableFunction<String, String>() {
                        @Override
                        public String apply(String date) {
                            return "gs://bucketname/" + date;
                        }
                    })))

Answer 1

Теперь это работает для меня, но я не понимаю почему.Я только что преобразовал свой анонимный класс в лямбда-выражение.

PCollectionTuple lines = this.p
                    .apply("ReadW2", TextIO.read().from(NestedValueProvider.of(options.getDate(), (SerializableFunction<String, String>) date -> gs://bucketname/" + date)))