org.apache.samza.startpoint

Class StartpointOldest

java.lang.Object

org.apache.samza.startpoint.Startpoint

org.apache.samza.startpoint.StartpointOldest

public final class StartpointOldest
extends Startpoint

A Startpoint that represents the earliest offset in a stream partition.

Constructor Summary

Constructors

Constructor and Description
StartpointOldest() Constructs a Startpoint that represents the earliest 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.
java.lang.String	toString()

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

equals, getCreationTimestamp, hashCode

Methods inherited from class java.lang.Object

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

Constructor Detail

StartpointOldest

public StartpointOldest()

Constructs a Startpoint that represents the earliest offset in a stream partition.

Method Detail

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