org.apache.samza.startpoint

Class StartpointUpcoming

java.lang.Object

org.apache.samza.startpoint.Startpoint

org.apache.samza.startpoint.StartpointUpcoming

public final class StartpointUpcoming
extends Startpoint

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

Constructor Summary

Constructors

Constructor and Description
StartpointUpcoming() Constructs a Startpoint that represents the latest 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

StartpointUpcoming

public StartpointUpcoming()

Constructs a Startpoint that represents the latest 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