org.apache.spark.sql.connector.read.streaming

Interface PartitionOffset

All Superinterfaces:

java.io.Serializable

@Evolving
public interface PartitionOffset
extends java.io.Serializable

Used for per-partition offsets in continuous processing. ContinuousReader implementations will provide a method to merge these into a global Offset.

These offsets must be serializable.

Since:

3.0.0