Skip to content

Offset -- Read Position of Streaming Query

Offset is the <> of <> that represent progress of a streaming query in <> format.

[[contract]] .Offset Contract (Abstract Methods Only) [cols="30m,70",options="header",width="100%"] |=== | Method | Description

| json a| [[json]]

[source, java]

String json()

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

Used when:

|===

[[extensions]] .Offsets [cols="30,70",options="header",width="100%"] |=== | Offset | Description

| ContinuousMemoryStreamOffset | [[ContinuousMemoryStreamOffset]]

| FileStreamSourceOffset | [[FileStreamSourceOffset]]

| KafkaSourceOffset | [[KafkaSourceOffset]]

| LongOffset | [[LongOffset]]

| RateStreamOffset | [[RateStreamOffset]]

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

| TextSocketOffset | [[TextSocketOffset]]

|===