データベースから読み取った入力ストリームがあり、さまざまなデバイスからの測定値があります。データベースに記録されたイベントは時系列ではありませんが、通常は 2 分のウィンドウで到着します。ただし、一部のデバイスでは、タイムスタンプが数日前のデータを送信できます。
入力ストリームに CTI を挿入して、せいぜい数分しか経過していない「通常の」データを処理する場合、残りのデータより数日遅れているデバイスのデータを処理するにはどうすればよいですか?
CTI を挿入する前に、入力ストリームをデバイスごとに 1 つのストリームに分割して、「古い」ストリームに他の入力ストリームから独立した CTI を持たせることはできますか?
前もって感謝します。