レポート最新オフセット

利用可能な最新のオフセットを返します。

この情報は、ストリーミングクエリの状態における最新のオフセットを報告するために使用されます。処理するデータがない場合、またはソースがこのメソッドをサポートしていない場合、ソースはNoneを返すことができます。

構文

reportLatestOffset()

戻り値

dict または None

キーと値がプリミティブ型である辞書または再帰辞書。プリミティブ型には、Integer、S、 Boolean含まれます。 ソースが最新のオフセットの報告をサポートしていない場合は、 Noneを返します。

例

Python

def reportLatestOffset(self):
    return {"partition-1": {"index": 100}, "partition-2": {"index": 200}}