org.apache.samza.startpoint

Class StartpointCustom

java.lang.Object

org.apache.samza.startpoint.Startpoint

org.apache.samza.startpoint.StartpointCustom

public abstract class StartpointCustom
extends Startpoint

A 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.

Method Summary

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.

Methods inherited from class org.apache.samza.startpoint.Startpoint

equals, getCreationTimestamp, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

apply

public void apply(SystemStreamPartition systemStreamPartition,
                  StartpointVisitor startpointVisitor)

Description copied from class: Startpoint

Apply the visitor StartpointVisitor's register methods to the instance of this Startpoint class.

Specified by:

apply in class Startpoint

Parameters:

systemStreamPartition - The SystemStreamPartition needed to register with the StartpointVisitor

startpointVisitor - The visitor to register with.