|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use AtomicCounter | |
|---|---|
| com.continuent.tungsten.replicator.thl | |
| Uses of AtomicCounter in com.continuent.tungsten.replicator.thl |
|---|
| Constructors in com.continuent.tungsten.replicator.thl with parameters of type AtomicCounter | |
|---|---|
Server(PluginContext context,
AtomicCounter sequencer,
THL thl)
Creates a new Server object |
|
THLParallelReadTask(int taskId,
THL thl,
Partitioner partitioner,
AtomicCounter headSeqnoCounter,
AtomicIntervalGuard<?> intervalGuard,
int maxSize,
int maxControlEvents,
int syncInterval,
com.continuent.tungsten.fsm.event.EventDispatcher dispatcher)
Instantiate a read task. |
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||