Uses of Class
oracle.kv.pubsub.StreamPosition
-
Packages that use StreamPosition Package Description oracle.kv.pubsub Provides the classes used to define a Subscription to all logical changes (table row puts and deletes) made to a NoSQL store. -
-
Uses of StreamPosition in oracle.kv.pubsub
Methods in oracle.kv.pubsub that return StreamPosition Modifier and Type Method Description StreamPosition
NoSQLSubscription. getCurrentPosition()
Returns a current position in the stream.StreamPosition
NoSQLSubscriptionConfig. getInitialPosition()
Returns the initial stream position to be used when creating a Subscription.StreamPosition
NoSQLSubscription. getLastCheckpoint()
Gets the last checkpoint stored in kv store for the given subscription.StreamPosition
NoSQLSubscription. getOptimizedPosition(StreamPosition streamPosition)
Returns a stream position that represents the same operations supplied toNoSQLSubscriber.onNext(oracle.kv.pubsub.StreamOperation)
, but one that is optimized for checkpoints.Methods in oracle.kv.pubsub with parameters of type StreamPosition Modifier and Type Method Description void
NoSQLSubscription. doCheckpoint(StreamPosition streamPosition)
Do subscription checkpoint.void
NoSQLSubscription. doCheckpoint(StreamPosition streamPosition, boolean exact)
Do subscription checkpoint at the given stream position or a stream position later than the given position selected by the Streams API.StreamPosition
NoSQLSubscription. getOptimizedPosition(StreamPosition streamPosition)
Returns a stream position that represents the same operations supplied toNoSQLSubscriber.onNext(oracle.kv.pubsub.StreamOperation)
, but one that is optimized for checkpoints.default void
NoSQLSubscriber. onChangeResult(StreamPosition streamPosition, java.lang.Throwable failureCause)
Signals when a request to add or remove a table from the set of subscribed tables is completed.void
NoSQLSubscriber. onCheckpointComplete(StreamPosition streamPosition, java.lang.Throwable failureCause)
Signals when a previously requested checkpoint is completed.NoSQLSubscriptionConfig.Builder
NoSQLSubscriptionConfig.Builder. setStartStreamPosition(StreamPosition position)
Sets the start stream position.
-