地圖元素

Javadoc 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()));