最新

Pydoc

最新のタイムスタンプを持つ要素を取得します。

例

次の例では、収穫日のタイムスタンプを持つ農産物のPCollectionを使用してパイプラインを作成します。

Latestを使用して、PCollectionから最新のタイムスタンプを持つ要素を取得します。

例1：最新の要素をグローバルに取得

Latest.Globally()を使用して、PCollection全体で最新のタイムスタンプを持つ要素を取得します。

例2：各キーの最新の要素を取得

Latest.PerKey()を使用して、キーと値のPCollectionで各キーの最新のタイムスタンプを持つ要素を取得します。

関連する変換

• Sampleは、コレクション内の要素をランダムにいくつか取得します。

Pydoc