public abstract class Offset
During execution, offsets provided by the data source implementation will be logged and used as
restart checkpoints. Each source should provide an offset implementation which the source can use
to reconstruct a position in the stream up to which data has been seen/processed.
Note: This class currently extends
maintain compatibility with DataSource V1 APIs. This extension will be removed once we
get rid of V1 completely.
|Constructor and Description
|Modifier and Type
|Method and Description
Equality based on JSON string representation.
A JSON-serialized representation of an Offset that is used for saving offsets to the offset log.
public abstract String json()
json in class
public boolean equals(Object obj)
equals in class
public int hashCode()
hashCode in class
public String toString()
toString in class