org.apache.samza.startpoint

Interface StartpointVisitor<IN,OUT>

@InterfaceStability.Evolving
public interface StartpointVisitor<IN,OUT>

A SystemAdmin implementation should implement this abstraction to support Startpoint.

Method Summary

Modifier and Type	Method and Description
default OUT	visit(IN input, StartpointOldest startpointOldest) Performs a sequence of operations using IN and StartpointOldest and returns the result of the execution.
default OUT	visit(IN input, StartpointSpecific startpointSpecific) Performs a sequence of operations using IN and StartpointSpecific and returns the result of the execution.
default OUT	visit(IN input, StartpointTimestamp startpointTimestamp) Performs a sequence of operations using IN and StartpointTimestamp and returns the result of the execution.
default OUT	visit(IN input, StartpointUpcoming startpointUpcoming) Performs a sequence of operations using IN and StartpointUpcoming and returns the result of the execution.

Method Detail

visit

default OUT visit(IN input,
                  StartpointSpecific startpointSpecific)

Performs a sequence of operations using IN and StartpointSpecific and returns the result of the execution.

Parameters:

input - the input metadata about the startpoint.

startpointSpecific - the Startpoint that represents the specific offset.

Returns:

the result of executing the operations defined by the visit method.

visit

default OUT visit(IN input,
                  StartpointTimestamp startpointTimestamp)

Performs a sequence of operations using IN and StartpointTimestamp and returns the result of the execution.

Parameters:

input - the input metadata about the startpoint.

startpointTimestamp - the Startpoint that represents the timestamp.

Returns:

the result of executing the operations defined by the visit method.

visit

default OUT visit(IN input,
                  StartpointOldest startpointOldest)

Performs a sequence of operations using IN and StartpointOldest and returns the result of the execution.

Parameters:

input - the input metadata about the startpoint.

startpointOldest - the Startpoint that represents the earliest offset.

Returns:

the result of executing the operations defined by the visit method.

visit

default OUT visit(IN input,
                  StartpointUpcoming startpointUpcoming)

Performs a sequence of operations using IN and StartpointUpcoming and returns the result of the execution.

Parameters:

input - the input metadata about the startpoint.

startpointUpcoming - the Startpoint that represents the latest offset.

Returns:

the result of executing the operations defined by the visit method.