Package org.apache.kafka.streams.query
Class PositionBound
java.lang.Object
org.apache.kafka.streams.query.PositionBound
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 TypeMethodDescriptionstatic PositionBound
Creates a new PositionBound representing a specific position.boolean
int
hashCode()
boolean
Returns true iff this object specifies that there is no position bound.position()
Returns the specific position of this bound.toString()
static PositionBound
Creates a new PositionBound representing "no bound"
-
Method Details
-
unbounded
Creates a new PositionBound representing "no bound" -
at
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
Returns the specific position of this bound. -
toString
-
equals
-
hashCode
public int hashCode()
-