Package io.hstream
Class StreamShardOffset
- java.lang.Object
-
- io.hstream.StreamShardOffset
-
public class StreamShardOffset extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
StreamShardOffset.OffsetType
static class
StreamShardOffset.SpecialOffset
-
Constructor Summary
Constructors Constructor Description StreamShardOffset(long timestamp)
StreamShardOffset(StreamShardOffset.SpecialOffset specialOffset)
StreamShardOffset(String recordId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getNormalOffset()
StreamShardOffset.OffsetType
getOffsetType()
StreamShardOffset.SpecialOffset
getSpecialOffset()
long
getTimestampOffset()
boolean
isNormalOffset()
boolean
isSpecialOffset()
boolean
isTimestampOffset()
-
-
-
Constructor Detail
-
StreamShardOffset
public StreamShardOffset(StreamShardOffset.SpecialOffset specialOffset)
-
StreamShardOffset
public StreamShardOffset(String recordId)
-
StreamShardOffset
public StreamShardOffset(long timestamp)
-
-
Method Detail
-
isSpecialOffset
public boolean isSpecialOffset()
-
isNormalOffset
public boolean isNormalOffset()
-
isTimestampOffset
public boolean isTimestampOffset()
-
getOffsetType
public StreamShardOffset.OffsetType getOffsetType()
-
getSpecialOffset
public StreamShardOffset.SpecialOffset getSpecialOffset()
-
getNormalOffset
public String getNormalOffset()
-
getTimestampOffset
public long getTimestampOffset()
-
-