java 如何在GCP数据流模板中提及必需和可选参数?

pxy2qtax  于 2023-01-04  发布在  Java
关注(0)|答案(1)|浏览(114)

我创建了一个使用一些必需参数和可选参数的自定义数据流模板。我可以创建模板,但当我在数据流UI中打开它时,它不显示我声明的必需参数。
我得到了一个注解@Validation.Required,但它也不起作用。我遗漏了什么吗?

我的选项类是

package org.example;

import org.apache.beam.sdk.extensions.gcp.options.GcpOptions;
import org.apache.beam.sdk.options.Default;
import org.apache.beam.sdk.options.Description;
import org.apache.beam.sdk.options.Validation;
import org.apache.beam.sdk.options.ValueProvider;

public interface TestOptions extends GcpOptions {
    @Description("Project Id")
    @Default.String("Project Id")
    ValueProvider<String> getProjectId();
    void setProjectId(ValueProvider<String> value);

    @Validation.Required
    @Description("Path to the input file")
    @Default.String("gs://nikhil-test-bucket/Test/input.txt")
    ValueProvider<String> getInputFile();
    void setInputFile(ValueProvider<String> value);

    @Validation.Required
    @Description("Path to the output file")
    @Default.String("gs://nikhil-test-bucket/Test/output.txt")
    ValueProvider<String> getOutputFile();
    void setOutputFile(ValueProvider<String> value);

    @Description("Path to the Config file")
    @Default.String("gs://nikhil-test-bucket/Test/config.txt")
    ValueProvider<String> getConfigFile();
    void setConfigFile(ValueProvider<String> value);
}
gudnpqoy

gudnpqoy1#

Dataflow UI读取_metadata文件(也称为spec)以获取参数列表,而不是实际的源代码。
在元数据参数中,可以为任何参数指定"isOptional": true

相关问题