使用Apache Beam可以从目录中读取所有文件的解决方法如下所示：

import apache_beam as beam
import glob

# 创建一个自定义的DoFn来读取文件内容
class ReadFileDoFn(beam.DoFn):
    def process(self, element):
        with open(element, 'r') as f:
            yield f.read()

# 创建一个Pipeline对象
with beam.Pipeline() as pipeline:
    # 使用glob模块获取目录中的所有文件路径
    file_paths = glob.glob('/path/to/directory/*')

    # 从文件路径列表创建一个PCollection
    file_paths_pcoll = pipeline | beam.Create(file_paths)

    # 使用ParDo转换来读取文件内容
    file_contents_pcoll = file_paths_pcoll | beam.ParDo(ReadFileDoFn())

    # 打印文件内容
    file_contents_pcoll | beam.Map(print)

在上面的示例中，我们首先创建了一个自定义的DoFn（ReadFileDoFn），它用于读取文件内容。然后，我们使用glob.glob模块获取目录中的所有文件路径，并将它们作为PCollection传递给Pipeline。接下来，我们使用ParDo转换来应用自定义的DoFn来读取文件内容，并将结果作为PCollection传递给下一个步骤。最后，我们使用Map转换将文件内容打印出来。

请注意，在实际使用中，您可能需要根据文件的类型和大小进行适当的处理，以避免处理过多的数据。此外，还可以根据需要进行进一步的数据处理和转换。