在没有sideInput的情况下,可以使用DoFn的构造函数来将配置注入ParDo。具体步骤如下:
public class Config implements Serializable {
private String value;
public Config(String value) {
this.value = value;
}
public String getValue() {
return value;
}
}
private final Config config;
public MyDoFn(Config config) {
this.config = config;
}
@Override
public void processElement(ProcessContext c) {
// 使用config字段访问配置
String value = config.getValue();
// 处理元素
// ...
}
Config config = new Config("config value");
PCollection<MyElement> input = ...;
PCollection<MyElement> output = input.apply(ParDo.of(new MyDoFn(config)));
这种方法允许将配置注入到ParDo中,而无需使用sideInput。该方法适用于将静态配置传递给DoFn,例如API密钥、数据库连接信息等。
腾讯云相关产品和产品介绍链接地址:
领取专属 10元无门槛券
手把手带您无忧上云