Uses of Package
com.continuent.tungsten.replicator.util

Packages that use com.continuent.tungsten.replicator.util

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

Classes in com.continuent.tungsten.replicator.util used by com.continuent.tungsten.replicator.backup

ProcessHelper
Implements a simple helper to execute operating system processes with consistent logging and handling of errors.

Classes in com.continuent.tungsten.replicator.util used by com.continuent.tungsten.replicator.pipeline

Watch
Implements a "watch" operation that waits for a predicate to be fulfilled on a particular event in an event processing queue.

Classes in com.continuent.tungsten.replicator.util used by com.continuent.tungsten.replicator.storage

WatchPredicate
Denotes a predicate that returns true if an input event matches the predicate conditions.

Classes in com.continuent.tungsten.replicator.util used by com.continuent.tungsten.replicator.storage.parallel

WatchPredicate
Denotes a predicate that returns true if an input event matches the predicate conditions.

Classes in com.continuent.tungsten.replicator.util used by com.continuent.tungsten.replicator.thl

AtomicCounter
Defines a simple "atomic counter" that allows clients to increment the encapsulated sequence number and wait synchronously until particular values are reached.

AtomicIntervalGuard
Tracks the sequence number and time interval between a group of tasks processing transactions to ensure that the first and last tasks do not get too far apart in the log.

WatchPredicate
Denotes a predicate that returns true if an input event matches the predicate conditions.

Classes in com.continuent.tungsten.replicator.util used by com.continuent.tungsten.replicator.util

Watch
Implements a "watch" operation that waits for a predicate to be fulfilled on a particular event in an event processing queue.

WatchAction
Denotes an action associated with a WatchEvent that is executed when the watch has matched.

WatchPredicate
Denotes a predicate that returns true if an input event matches the predicate conditions.