Offset — Read Position of Streaming Query

Offset is the base of stream positions that represent progress of a streaming query in json format.

Table 1. Offset Contract (Abstract Methods Only)
Method Description

json

String json()

Converts the offset to JSON format (JSON-encoded offset)

Used when:

Table 2. Offsets
Offset Description

ContinuousMemoryStreamOffset

FileStreamSourceOffset

KafkaSourceOffset

LongOffset

RateStreamOffset

SerializedOffset

JSON-encoded offset that is used when loading an offset from an external storage, e.g. from checkpoint after restart

TextSocketOffset

results matching ""

    No results matching ""