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 TypeMethodDescriptionvoidNoSQLSubscription.doCheckpoint(StreamPosition streamPosition) Do subscription checkpoint.voidNoSQLSubscription.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 voidNoSQLSubscriber.onChangeResult(StreamPosition streamPosition, Throwable failureCause) Signals when a request to add or remove a table from the set of subscribed tables is completed.voidNoSQLSubscriber.onCheckpointComplete(StreamPosition streamPosition, Throwable failureCause) Signals when a previously requested checkpoint is completed.NoSQLSubscriptionConfig.Builder.setStartStreamPosition(StreamPosition position) Sets the start stream position.