Package oracle.kv.pubsub
Interface StreamOperation
-
- All Known Subinterfaces:
StreamOperation.DeleteEvent
,StreamOperation.PutEvent
public interface StreamOperation
The operation (Put, Delete) that was delivered over the NoSQL stream.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
StreamOperation.DeleteEvent
Used to signal a Delete operationstatic interface
StreamOperation.PutEvent
Used to signal a Put operationstatic interface
StreamOperation.SequenceId
A SequenceId uniquely identifies a stream operation associated with a Publisher.static class
StreamOperation.Type
The type of the operation.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamOperation.DeleteEvent
asDelete()
Converts this operation to aStreamOperation.DeleteEvent
.StreamOperation.PutEvent
asPut()
Converts this operation to aStreamOperation.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.
-
-
-
Method Detail
-
getSequenceId
StreamOperation.SequenceId getSequenceId()
Returns the unique sequence id associated with this operation.
-
getRepGroupId
int getRepGroupId()
Returns the shard id associated with this operation.
-
getType
StreamOperation.Type getType()
Returns the type of this operation.- Returns:
- the type of this operation
-
asPut
StreamOperation.PutEvent asPut()
Converts this operation to aStreamOperation.PutEvent
.- Returns:
- this operation as a Put
- Throws:
IllegalArgumentException
- if this operation is not a Put
-
asDelete
StreamOperation.DeleteEvent asDelete()
Converts this operation to aStreamOperation.DeleteEvent
.- Returns:
- this operation as a Delete
- Throws:
IllegalArgumentException
- if this operation is not a Delete
-
-