public final class StreamOffset<K> extends Object
2.2
Modifier and Type | Method and Description |
---|---|
static <K> StreamOffset<K> |
create(K stream,
ReadOffset readOffset)
|
boolean |
equals(Object o) |
static <K> StreamOffset<K> |
from(Record<K,?> reference)
|
static <K> StreamOffset<K> |
fromStart(K stream)
|
K |
getKey() |
ReadOffset |
getOffset() |
int |
hashCode() |
static <K> StreamOffset<K> |
latest(K stream)
|
String |
toString() |
public static <K> StreamOffset<K> create(K stream, ReadOffset readOffset)
stream
- the stream key.readOffset
- the ReadOffset
to use.StreamOffset
.public static <K> StreamOffset<K> latest(K stream)
K
- stream
- the stream key.StreamOffset
.public static <K> StreamOffset<K> fromStart(K stream)
K
- stream
- the stream key.StreamOffset
.public static <K> StreamOffset<K> from(Record<K,?> reference)
K
- reference
- the record to be used as reference point.StreamOffset
.public K getKey()
public ReadOffset getOffset()
Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.