DeltaSourceOffset — Streaming Offset Of DeltaSource

DeltaSourceOffset is a streaming Offset for DeltaSource.

DeltaSourceOffset is created (via apply utility) when DeltaSource is requested for the latest offset and a batch (for the given starting and ending offsets).

DeltaSourceOffset uses the version 1.

Creating DeltaSourceOffset Instance

DeltaSourceOffset takes the following to be created:

  • Source Version (always 1)

  • Reservoir ID (aka Table ID)

  • Reservoir Version

  • Index

  • isStartingVersion flag

Creating DeltaSourceOffset Instance — apply Utility

apply(
  reservoirId: String,
  reservoirVersion: Long,
  index: Long,
  isStartingVersion: Boolean): DeltaSourceOffset
apply(
  reservoirId: String,
  offset: Offset): DeltaSourceOffset

apply creates a new DeltaSourceOffset (for the version and the given arguments) or converts the given Offset to a DeltaSourceOffset.

apply is used when DeltaSource is requested for the latest offset and a batch (for the given starting and ending offsets).

json Method

json: String
json is part of the Offset contract to serialize an offset to JSON.

json…​FIXME

validateSourceVersion Internal Utility

validateSourceVersion(
  json: String): Unit

validateSourceVersion…​FIXME

validateSourceVersion is used when…​FIXME