Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
を使用して Managed Service for Apache Flink でイベントを追跡する DataStream API
Apache Flink 用 Managed Service は、次のタイムスタンプを使用してイベントを追跡します。
「Processing Time:」それぞれの操作を実行しているマシンのシステム時間を指します。
「イベント時間:」各イベントが発生デバイスで発生した時刻を指します。
「取り込み時間:」Apache Flink サービス用 Managed Service にイベントが入るまでの時間を指します。
を使用して、ストリーミング環境で使用される時間を設定しますsetStreamTimeCharacteristic。
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime); env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime); env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
タイムスタンプの詳細については、Apache Flink ドキュメントの「ウォーターマークの生成
