@Evolving
public abstract class Offset
extends Object
MicroBatchStream
or
ContinuousStream
.
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.Constructor and Description |
---|
Offset() |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj)
Equality based on JSON string representation.
|
int |
hashCode() |
abstract String |
json()
A JSON-serialized representation of an Offset that is
used for saving offsets to the offset log.
|
String |
toString() |
public abstract String json()
public boolean equals(Object obj)
equals
in class Object
public int hashCode()
hashCode
in class Object
public String toString()
toString
in class Object