@InterfaceStability.Experimental @InterfaceAudience.Private public class SnapshotMarkerMessage extends AbstractDCPRequest
Snapshot marker.
Sent by the producer to tell the consumer that a new snapshot is being sent. A snapshot is simply a series of commands that is guaranteed to contain a unique set of keys.
Modifier and Type | Field and Description |
---|---|
static int |
ACK |
static int |
CHECKPOINT |
static int |
DISK |
static int |
MEMORY |
DEFAULT_PARTITION
Constructor and Description |
---|
SnapshotMarkerMessage(short partition,
long startSequenceNumber,
long endSequenceNumber,
int flags,
String bucket) |
SnapshotMarkerMessage(short partition,
long startSequenceNumber,
long endSequenceNumber,
int flags,
String bucket,
String password) |
Modifier and Type | Method and Description |
---|---|
boolean |
ack() |
boolean |
checkpoint() |
boolean |
disk() |
long |
endSequenceNumber() |
boolean |
memory() |
long |
startSequenceNumber() |
partition, partition
bucket, creationTime, incrementRetryCount, observable, password, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bucket, incrementRetryCount, observable, password
creationTime
public static final int MEMORY
public static final int DISK
public static final int CHECKPOINT
public static final int ACK
public SnapshotMarkerMessage(short partition, long startSequenceNumber, long endSequenceNumber, int flags, String bucket)
Copyright © 2014 Couchbase, Inc.