在Apache Beam中实现根据文件名写入文件可以通过在ParDo中使用FileBasedSink实现。以下是一个用于在Apache Beam中创建文件的示例：

import os
import apache_beam as beam
from apache_beam.io import filebasedsink

class WriteToFile(beam.DoFn):
    def process(self, element, *args, **kwargs):
        # 获取文件名
        filename = element['filename']
        # 将数据写入文件
        yield beam.io.Write(
            element,
            file_path_prefix=os.path.join('output', filename),
            file_name_suffix='.csv')

def run():
    # 打开Beam管道
    with beam.Pipeline() as p:
        # 创建数据
        data = [
            {'filename': 'file1'},
            {'filename': 'file2'},
            {'filename': 'file3'}
        ]
        # 将数据集转换为PCollection
        pc = p | 'Create PC' >> beam.Create(data)
        # 在ParDo中使用FileBasedSink写入文件
        pc | 'Write to File' >> beam.ParDo(WriteToFile())

if __name__ == '__main__':
    run()

上述代码演示了如何使用FileBasedSink在Apache Beam中根据文件名写入文件。在这个例子中，我们定义了一个名为WriteToFile的ParDo，该ParDo将每个元素写入具有特定文件名的文件中。我们将Pipeline的数据集转换为PCollection并将其传递给WriteToFile ParDo。在WriteToFile ParDo中，我们使用FileBasedSink将数据写入具有指定文件名的文件中。在这个例子中，我们将所有文件都写入到output目录中，但你可以自己决定文件路径和文件扩展名。