org.apache.samza.startpoint

Class Startpoint

java.lang.Object

org.apache.samza.startpoint.Startpoint

Direct Known Subclasses:

StartpointOldest, StartpointSpecific, StartpointTimestamp, StartpointUpcoming

@InterfaceStability.Evolving
public abstract class Startpoint
extends java.lang.Object

Startpoint represents a position in a stream partition.

Method Summary

Modifier and Type	Method and Description
abstract <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)
long	getCreationTimestamp() The timestamp when this Startpoint was written to the storage layer.
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getCreationTimestamp

public long getCreationTimestamp()

The timestamp when this Startpoint was written to the storage layer.

Returns:

a timestamp in epoch milliseconds.

apply

public abstract <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.

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 java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object