我创建了一个使用一些必需参数和可选参数的自定义数据流模板。我可以创建模板,但当我在数据流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);
}
1条答案
按热度按时间gudnpqoy1#
Dataflow UI读取
_metadata
文件(也称为spec)以获取参数列表,而不是实际的源代码。在元数据参数中,可以为任何参数指定
"isOptional": true
。