org.apache.samza.startpoint

Class StartpointTimestamp

java.lang.Object

org.apache.samza.startpoint.Startpoint

org.apache.samza.startpoint.StartpointTimestamp

public final class StartpointTimestamp
extends Startpoint

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

Constructor Summary

Constructors

Constructor and Description
StartpointTimestamp(java.lang.Long timestampOffset) Constructs a Startpoint that represents a timestamp 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.Long	getTimestampOffset() Getter for the timestamp 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

StartpointTimestamp

public StartpointTimestamp(java.lang.Long timestampOffset)

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

Parameters:

timestampOffset - in a stream partition in milliseconds.

Method Detail

getTimestampOffset

public java.lang.Long getTimestampOffset()

Getter for the timestamp offset.

Returns:

the timestamp offset in milliseconds.

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