public abstract class StartpointCustom extends Startpoint
Startpoint
that represents a custom startpoint. This is for systems that have a non-generic option
for setting offsets. Startpoints are serialized to JSON in the MetadataStore
and it is recommended to maintain the subclass of this StartpointCustom
as a simple POJO.Modifier and Type | Method and Description |
---|---|
void |
apply(SystemStreamPartition systemStreamPartition,
StartpointVisitor startpointVisitor)
Apply the visitor
StartpointVisitor 's register methods to the instance of this Startpoint
class. |
equals, getCreationTimestamp, hashCode, toString
public void apply(SystemStreamPartition systemStreamPartition, StartpointVisitor startpointVisitor)
Startpoint
StartpointVisitor
's register methods to the instance of this Startpoint
class.apply
in class Startpoint
systemStreamPartition
- The SystemStreamPartition
needed to register with the StartpointVisitor
startpointVisitor
- The visitor to register with.