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 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 enum	StreamOperation.Type	The type of the operation.

Method Summary

Modifier and Type	Method	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.

Method Details

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 a StreamOperation.PutEvent.

Returns:

this operation as a Put

Throws:

IllegalArgumentException - if this operation is not a Put

asDelete

StreamOperation.DeleteEvent asDelete()

Converts this operation to a StreamOperation.DeleteEvent.

Returns:

this operation as a Delete

Throws:

IllegalArgumentException - if this operation is not a Delete