reportLatestOffset

Renvoie l'offset le plus récent disponible.

L'information est utilisée pour signaler le dernier décalage dans le statut de la query de streaming. La source peut renvoyer None s’il n’y a pas de données à traiter ou si la source ne prend pas en charge cette méthode.

Syntaxe

reportLatestOffset()

Renvoie

dict OU None

Un dict ou dict récursif dont la clé et la valeur sont des types primitifs, ce qui inclut Entier, Chaîne et Booléen. Renvoie None si la source ne prend pas en charge la déclaration du dernier offset.

Exemples

Python

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