Apache Beam Initializer 的中文名称为“初始值设定器”，它是 Apache Beam 编程模型中的一个重要组件，用于在多个并发执行的数据处理任务之前提供共享数据，从而减少资源的重复利用。下面是一个使用 Initializer 的示例代码：

import apache_beam as beam

class CustomDoFn(beam.DoFn):
    def process(self, element, shared_value):
        ...
        # 使用共享数据 shared_value ...

with beam.Pipeline() as p:
    shared_value = p | beam.Create([shared_data])
    data = p | beam.Create([data1, data2, data3])
    results = data | beam.ParDo(CustomDoFn(), beam.pvalue.AsSingleton(shared_value))

在上述代码中，我们定义了一个 CustomDoFn 类，这是一个继承自 beam.DoFn 的自定义 DoFn 类。在类中，我们通过 process 方法来处理数据，并使用 shared_value 共享数据进行计算。注意，我们使用 beam.pvalue.AsSingleton 将 shared_value 转换为 PValue 类型，并在 ParDo 操作中将其传递给 CustomDoFn。这样，在并发执行多个 CustomDoFn 实例时，它们可以共享相同的 shared_value 数据。