public interface StreamOperation
Modifier and Type | Interface and Description |
---|---|
static interface |
StreamOperation.DeleteEvent
Used to signal a Delete operation
|
static interface |
StreamOperation.PutEvent
Used to signal a Put operation
|
static interface |
StreamOperation.SequenceId
A SequenceId uniquely identifies a stream operation associated with a
Publisher.
|
static class |
StreamOperation.Type
The type of the operation.
|
Modifier and Type | Method and Description |
---|---|
StreamOperation.DeleteEvent |
asDelete()
Converts this operation to a
StreamOperation.DeleteEvent . |
StreamOperation.PutEvent |
asPut()
Converts this operation to a
StreamOperation.PutEvent . |
int |
getRepGroupId()
Returns the shard id associated with this operation.
|
StreamOperation.SequenceId |
getSequenceId()
Returns the unique sequence id associated with this operation.
|
StreamOperation.Type |
getType()
Returns the type of this operation.
|
StreamOperation.SequenceId getSequenceId()
int getRepGroupId()
StreamOperation.Type getType()
StreamOperation.PutEvent asPut()
StreamOperation.PutEvent
.IllegalArgumentException
- if this operation is not a PutStreamOperation.DeleteEvent asDelete()
StreamOperation.DeleteEvent
.IllegalArgumentException
- if this operation is not a DeleteCopyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.