org.apache.samza.startpoint

Class StartpointSpecific

java.lang.Object

org.apache.samza.startpoint.Startpoint

org.apache.samza.startpoint.StartpointSpecific

public final class StartpointSpecific
extends Startpoint

A Startpoint that represents a specific offset in a stream partition.

Constructor Summary

Constructors

Constructor and Description
StartpointSpecific(java.lang.String specificOffset) Constructs a Startpoint that represents a specific offset in a stream partition.

Method Summary

Modifier and Type	Method and Description
<IN,OUT> OUT	apply(IN input, StartpointVisitor<IN,OUT> startpointVisitor) Applies the StartpointVisitor's visit methods to the Startpoint and returns the result of that operation.
boolean	equals(java.lang.Object o)
java.lang.String	getSpecificOffset() Getter for the specific offset.
int	hashCode()
java.lang.String	toString()

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

getCreationTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

StartpointSpecific

public StartpointSpecific(java.lang.String specificOffset)

Constructs a Startpoint that represents a specific offset in a stream partition.

Parameters:

specificOffset - Specific offset in a stream partition.

Method Detail

getSpecificOffset

public java.lang.String getSpecificOffset()

Getter for the specific offset.

Returns:

the specific offset.

apply

public <IN,OUT> OUT apply(IN input,
                          StartpointVisitor<IN,OUT> startpointVisitor)

Description copied from class: Startpoint

Applies the StartpointVisitor's visit methods to the Startpoint and returns the result of that operation.

Specified by:

apply in class Startpoint

Parameters:

input - the metadata associated with the startpoint.

startpointVisitor - the visitor of the startpoint.

Returns:

the result of applying the visitor on startpoint.

toString

public java.lang.String toString()

Overrides:

toString in class Startpoint

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class Startpoint

hashCode

public int hashCode()

Overrides:

hashCode in class Startpoint