最新情報

Javadoc

コレクション内の最新の要素を計算するための変換とCombine.CombineFn。

• Latest.globally()は、値のコレクションを受け取り、最新の暗黙的なタイムスタンプを持つ単一の値を含むコレクションを生成します。
• Latest.perKey()は、キー値のペアのコレクションを受け取り、暗黙的なタイムスタンプに従って、各キーの最新の値を返します。

同じタイムスタンプを持つ要素の場合、出力要素は任意に選択されます。

例

例1：各セッションの最新の値を計算する

 PCollection input = ...;
 PCollection sessioned = input
    .apply(Window.into(Sessions.withGapDuration(Duration.standardMinutes(5)));
 PCollection latestValues = sessioned.apply(Latest.globally());

例2:

関連変換

• Reify は、さまざまなBeam値の明示的および暗黙的な形式間の変換を行います。
• WithTimestamps は、コレクションのすべての要素にタイムスタンプを割り当てます。