Package oracle.kv.pubsub
Interface StreamOperation
-
- All Known Subinterfaces:
StreamOperation.DeleteEvent,StreamOperation.PutEvent
public interface StreamOperationThe operation (Put, Delete) that was delivered over the NoSQL stream.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceStreamOperation.DeleteEventUsed to signal a Delete operationstatic interfaceStreamOperation.PutEventUsed to signal a Put operationstatic interfaceStreamOperation.SequenceIdA SequenceId uniquely identifies a stream operation associated with a Publisher.static classStreamOperation.TypeThe type of the operation.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamOperation.DeleteEventasDelete()Converts this operation to aStreamOperation.DeleteEvent.StreamOperation.PutEventasPut()Converts this operation to aStreamOperation.PutEvent.intgetRepGroupId()Returns the shard id associated with this operation.StreamOperation.SequenceIdgetSequenceId()Returns the unique sequence id associated with this operation.StreamOperation.TypegetType()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
-
-