Uses of Interface
com.continuent.tungsten.replicator.util.WatchPredicate

Packages that use WatchPredicate

com.continuent.tungsten.replicator.storage
com.continuent.tungsten.replicator.storage.parallel
com.continuent.tungsten.replicator.thl
com.continuent.tungsten.replicator.util

Uses of WatchPredicate in com.continuent.tungsten.replicator.storage

Methods in com.continuent.tungsten.replicator.storage with parameters of type WatchPredicate

void	ParallelStore.insertWatchSyncEvent(WatchPredicate<ReplDBMSHeader> predicate) Inserts watch synchronization event after next complete transaction that matches the provided predicate.

Uses of WatchPredicate in com.continuent.tungsten.replicator.storage.parallel

Methods in com.continuent.tungsten.replicator.storage.parallel with parameters of type WatchPredicate

void	ParallelQueueStore.insertWatchSyncEvent(WatchPredicate<ReplDBMSHeader> predicate) Inserts watch synchronization event after next complete transaction that matches the provided predicate.

Uses of WatchPredicate in com.continuent.tungsten.replicator.thl

Methods in com.continuent.tungsten.replicator.thl with parameters of type WatchPredicate

void	THLParallelReadTask.addWatchSyncPredicate(WatchPredicate<ReplDBMSHeader> predicate) Adds a watch predicate.
void	THLParallelReadQueue.addWatchSyncPredicate(WatchPredicate<ReplDBMSHeader> predicate) Add a new predicate to the list of predicates that should generate sync events.
void	THLParallelQueue.insertWatchSyncEvent(WatchPredicate<ReplDBMSHeader> predicate) Inserts watch synchronization event after next complete transaction that matches the provided predicate.

Uses of WatchPredicate in com.continuent.tungsten.replicator.util

Classes in com.continuent.tungsten.replicator.util that implement WatchPredicate

class	EventIdWatchPredicate Implements a WatchPredicate to identify that a particular native event ID has been reached.
class	HeartbeatWatchPredicate Implements a WatchPredicate that returns true when we see an event that is marked as a heartbeat.
class	SeqnoWatchPredicate Implements a WatchPredicate to identify that a particular sequence number has been reached.
class	SourceTimestampWatchPredicate Implements a WatchPredicate to identify that a particular sequence number has been reached.

Methods in com.continuent.tungsten.replicator.util that return WatchPredicate

WatchPredicate<E>

Watch.getPredicate() Returns the watch predicate.

Methods in com.continuent.tungsten.replicator.util with parameters of type WatchPredicate

Watch<E>	WatchManager.watch(WatchPredicate<E> predicate, int taskCount) Adds a new watch predicate to the queue.
Watch<E>	WatchManager.watch(WatchPredicate<E> predicate, int taskCount, WatchAction<E> action) Adds a new watch predicate to the queue including an accompanying action.

Constructors in com.continuent.tungsten.replicator.util with parameters of type WatchPredicate

Watch(WatchPredicate<E> predicate, int taskCount)
Create watch with predicate and task count.

Watch(WatchPredicate<E> predicate, int taskCount, WatchAction<E> action)
Create watch with all components.