テーブルAPIの時間属性 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

テーブルAPIの時間属性

データストリーム内の各レコードには、そのレコードに関連するイベントがいつ発生したかを定義する複数のタイムスタンプがあります。

  • イベント時間」:レコードを作成したイベントがいつ発生したかを定義するユーザー定義のタイムスタンプ。

  • 取り込み時間」:アプリケーションがデータストリームからレコードを取得した時刻。

  • 処理時間」:アプリケーションがレコードを処理した時間。

Apache Flink Table がレコード時間に基づいてウィンドウAPIを作成する場合、 setStreamTimeCharacteristicメソッドを使用して、これらのタイムスタンプのうちどれを使用するかを定義します。

テーブル でタイムスタンプを使用する方法の詳細についてはAPI、Apache Flink ドキュメントの「時間属性」と「タイムリーストリーム処理」を参照してください。