Package org.apache.kafka.streams.query

Class PositionBound

java.lang.Object

org.apache.kafka.streams.query.PositionBound

@Evolving
public class PositionBound
extends Object

A class bounding the processing state Position during queries. This can be used to specify that a query should fail if the locally available partition isn't caught up to the specified bound. "Unbounded" places no restrictions on the current location of the partition.

Method Summary

Modifier and Type	Method	Description
static PositionBound	at(Position position)	Creates a new PositionBound representing a specific position.
boolean	equals(Object o)
int	hashCode()
boolean	isUnbounded()	Returns true iff this object specifies that there is no position bound.
Position	position()	Returns the specific position of this bound.
String	toString()
static PositionBound	unbounded()	Creates a new PositionBound representing "no bound"

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Method Details

unbounded

public static PositionBound unbounded()

Creates a new PositionBound representing "no bound"

at

public static PositionBound at(Position position)

Creates a new PositionBound representing a specific position.

isUnbounded

public boolean isUnbounded()

Returns true iff this object specifies that there is no position bound.

position

public Position position()

Returns the specific position of this bound.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object