THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
A requested Startpoint will be stored in a metadata store. This will be decoupled from the actual checkpoints offsets in the checkpoint stream.
Public Interfaces
Startpoint Model
| Code Block | ||||
|---|---|---|---|---|
| ||||
Startpoint
/**
* Startpoint
*/
public class StartpointEntry {
private final String taskName;
private final Startpoint startpoint;
// Full implementation not shown for brevity
}
/**
* Startpoint represents a position in a stream by {@link PositionType}
*/
public class Startpoint {
private final PositionType PositionType;
private final String position;
// Full implementation not shown for brevity
}
public enum PositionType {
SPECIFIC_OFFSET,
TIMESTAMP,
EARLIEST,
LATEST,
BOOTSTRAP
} |
...