Uses of Class
oracle.kv.pubsub.StreamPosition
Packages that use StreamPosition
Package
Description
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 StreamPositionModifier and TypeMethodDescriptionNoSQLSubscription.getCurrentPosition()
Returns a current position in the stream.NoSQLSubscriptionConfig.getInitialPosition()
Returns the initial stream position to be used when creating a Subscription.NoSQLSubscription.getLastCheckpoint()
Gets the last checkpoint stored in kv store for the given subscription.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 StreamPositionModifier and TypeMethodDescriptionvoid
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.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, 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, Throwable failureCause) Signals when a previously requested checkpoint is completed.NoSQLSubscriptionConfig.Builder.setStartStreamPosition
(StreamPosition position) Sets the start stream position.