public class ConnectorState extends Object implements Iterable<StreamState>
CouchbaseKafkaConnector
instance.Constructor and Description |
---|
ConnectorState() |
Modifier and Type | Method and Description |
---|---|
ConnectorState |
clone() |
StreamState |
get(short partition)
Returns the stream state.
|
Iterator<StreamState> |
iterator() |
short[] |
partitions() |
void |
put(StreamState streamState)
Set/update the stream state
|
void |
update(short partition,
long sequenceNumber) |
Observable<StreamStateUpdatedEvent> |
updates() |
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public Iterator<StreamState> iterator()
iterator
in interface Iterable<StreamState>
public void put(StreamState streamState)
streamState
- new state for streampublic StreamState get(short partition)
partition
- partition of the stream.public short[] partitions()
public ConnectorState clone()
public void update(short partition, long sequenceNumber)
public Observable<StreamStateUpdatedEvent> updates()
Copyright © 2015 Couchbase, Inc.