地图元素

Javadoc

对集合中的每个元素应用一个简单的 1 对 1 映射函数。

示例

**示例 1**：使用 SimpleFunction 提供映射函数

**示例 2**：使用 SerializableFunction 提供映射函数，这允许使用 Java 8 lambda。由于类型擦除，你需要提供一个提示，指示所需的返回类型。

PCollection<String> lines = Create.of("Hello World", "Beam is fun");
PCollection<Integer> lineLengths = lines.apply(MapElements
    .into(TypeDescriptors.integers())
    .via((String line) -> line.length()));

相关转换

• FlatMapElements 的行为与 Map 相同，但对于每个输入，它可以产生零个或多个输出。
• Filter 在函数只是决定是否输出元素的情况下很有用。
• ParDo 是最通用的元素级映射操作，它还包括其他功能，例如多个输出集合和侧输入。