Uses of Class
com.continuent.tungsten.replicator.event.ReplEvent

Packages that use ReplEvent

com.continuent.tungsten.replicator.event
com.continuent.tungsten.replicator.extractor
com.continuent.tungsten.replicator.pipeline
com.continuent.tungsten.replicator.storage.parallel
com.continuent.tungsten.replicator.thl

Uses of ReplEvent in com.continuent.tungsten.replicator.event

Subclasses of ReplEvent in com.continuent.tungsten.replicator.event

class	ReplControlEvent An implementation of ReplEvent used to transmit control information within pipelines.
class	ReplDBMSEvent Storage class for replication events implementing full event management metadata such as timestamp, source ID, epoch number, and event fragment protocol.
class	ReplDBMSFilteredEvent Implements a filtered event, which represents a gap in the transaction sequence.

Uses of ReplEvent in com.continuent.tungsten.replicator.extractor

Methods in com.continuent.tungsten.replicator.extractor that return ReplEvent

ReplEvent

Extractor.extract() Extract the next available event from the log.

Uses of ReplEvent in com.continuent.tungsten.replicator.pipeline

Methods in com.continuent.tungsten.replicator.pipeline with parameters of type ReplEvent

int	Schedule.advise(ReplEvent replEvent) Task must call this method after extracting event but before processing to decide disposition.
int	SimpleSchedule.advise(ReplEvent replEvent) Task must call this method after extracting event but before processing to decide disposition.

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

Methods in com.continuent.tungsten.replicator.storage.parallel that return ReplEvent

ReplEvent	ParallelQueueExtractor.extract() Extract the next available event from the log.
ReplEvent	ParallelQueueStore.get(int taskId) Removes and returns next event from the queue, blocking if empty.
ReplEvent	ParallelQueueStore.peek(int taskId) Returns but does not remove next event from the queue if it exists or returns null if queue is empty.

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

Methods in com.continuent.tungsten.replicator.thl that return ReplEvent

ReplEvent	THLParallelQueueExtractor.extract() Extract the next available event from the log.
ReplEvent	THLStoreExtractor.extract() Extract the next available event from the log.
ReplEvent	THLParallelReadTask.get() Removes and returns next event from the queue, blocking if empty.
ReplEvent	THLParallelQueue.get(int taskId) Removes and returns next event from the queue, blocking if empty.
ReplEvent	THLEvent.getReplEvent() Get associated replication.
ReplEvent	ProtocolReplEvent.getReplEvent()
ReplEvent	THLParallelReadTask.peek() Returns but does not remove next event from the queue if it exists or returns null if queue is empty.
ReplEvent	THLParallelReadQueue.peek() Returns but does not remove next event from the queue if it exists or returns null if queue is empty.
ReplEvent	THLParallelQueue.peek(int taskId) Returns next event from the queue without removing it, returning null if queue is empty.
ReplEvent	Connector.requestEvent(long seqNo) Fetch an event from server.
ReplEvent	Protocol.requestReplEvent(long seqNo) TODO: requestReplicationDBMSEvent definition.
ReplEvent	THLParallelReadQueue.take() Removes the next event from the queue, waiting indefinitely for something to arrive.
ReplEvent	THLParallelReadQueue.take(long timeout, java.util.concurrent.TimeUnit unit) Removes the next element from the event queue, returning null if it cannot be found within the timeout.

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

void	Protocol.sendReplEvent(ReplEvent event, boolean forceSend) TODO: sendReplicationDBMSEvent definition.

Constructors in com.continuent.tungsten.replicator.thl with parameters of type ReplEvent

ProtocolReplEvent(ReplEvent event)

THLEvent(long seqno, short fragno, boolean lastFrag, java.lang.String sourceId, short type, long epochNumber, java.sql.Timestamp localEnqueueTstamp, java.sql.Timestamp sourceTstamp, java.lang.String eventId, java.lang.String shardId, ReplEvent event)
Creates a new THLEvent object