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
 
 - 
 
 -