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

Packages that use ReplDBMSEvent

com.continuent.tungsten.replicator.applier
com.continuent.tungsten.replicator.consistency
com.continuent.tungsten.replicator.event
com.continuent.tungsten.replicator.extractor
com.continuent.tungsten.replicator.filter
com.continuent.tungsten.replicator.heartbeat
com.continuent.tungsten.replicator.pipeline
com.continuent.tungsten.replicator.prefetch
com.continuent.tungsten.replicator.shard
com.continuent.tungsten.replicator.storage
com.continuent.tungsten.replicator.storage.parallel
com.continuent.tungsten.replicator.storage.prefetch
com.continuent.tungsten.replicator.thl

Uses of ReplDBMSEvent in com.continuent.tungsten.replicator.applier

Methods in com.continuent.tungsten.replicator.applier with parameters of type ReplDBMSEvent

void	ApplierWrapper.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the DBMSEvent in the ReplDBMSEvent.
void	Applier.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the proffered event to the replication target.

Uses of ReplDBMSEvent in com.continuent.tungsten.replicator.consistency

Methods in com.continuent.tungsten.replicator.consistency that return ReplDBMSEvent

ReplDBMSEvent

ConsistencyCheckFilter.filter(ReplDBMSEvent event)

Methods in com.continuent.tungsten.replicator.consistency with parameters of type ReplDBMSEvent

ReplDBMSEvent

ConsistencyCheckFilter.filter(ReplDBMSEvent event)

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

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

class

ReplDBMSFilteredEvent Implements a filtered event, which represents a gap in the transaction sequence.

Methods in com.continuent.tungsten.replicator.event that return ReplDBMSEvent

ReplDBMSEvent

EventMetadataFilter.filter(ReplDBMSEvent event) Filter the event.

Methods in com.continuent.tungsten.replicator.event with parameters of type ReplDBMSEvent

ReplDBMSEvent

EventMetadataFilter.filter(ReplDBMSEvent event) Filter the event.

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

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

ReplDBMSEvent

ExtractorWrapper.extract() Extracts a raw event and wraps it in a ReplDBMS complete with sequence number, which increments each time we process the last fragment.

Uses of ReplDBMSEvent in com.continuent.tungsten.replicator.filter

Methods in com.continuent.tungsten.replicator.filter that return ReplDBMSEvent

ReplDBMSEvent	BuildAuditTable.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	CaseMappingFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	LoggingFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	OptimizeUpdatesFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	TungstenTableCDCTransformFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	Filter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	BidiRemoteSlaveFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	TimeDelayFilter.filter(ReplDBMSEvent event) Implements a delay in processing the event.
ReplDBMSEvent	ReplicateColumnsFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	ReplicateFilter.filter(ReplDBMSEvent event) Filters transactions using do and ignore rules.
ReplDBMSEvent	RenameFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	MySQLSessionSupportFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	JavaScriptFilter.filter(ReplDBMSEvent event) Calls filter(event) function in user's script.
ReplDBMSEvent	ShardFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	DatabaseTransformFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	EnumToStringFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	PrintEventFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	ColumnNameFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	PrimaryKeyFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	DummyFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	CDCMetadataFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	BuildIndexTable.filter(ReplDBMSEvent event) Filter the event.

Methods in com.continuent.tungsten.replicator.filter with parameters of type ReplDBMSEvent

ReplDBMSEvent	BuildAuditTable.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	CaseMappingFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	LoggingFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	OptimizeUpdatesFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	TungstenTableCDCTransformFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	Filter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	BidiRemoteSlaveFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	TimeDelayFilter.filter(ReplDBMSEvent event) Implements a delay in processing the event.
ReplDBMSEvent	ReplicateColumnsFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	ReplicateFilter.filter(ReplDBMSEvent event) Filters transactions using do and ignore rules.
ReplDBMSEvent	RenameFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	MySQLSessionSupportFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	JavaScriptFilter.filter(ReplDBMSEvent event) Calls filter(event) function in user's script.
ReplDBMSEvent	ShardFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	DatabaseTransformFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	EnumToStringFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	PrintEventFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	ColumnNameFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	PrimaryKeyFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	DummyFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	CDCMetadataFilter.filter(ReplDBMSEvent event) Filter the event.
ReplDBMSEvent	BuildIndexTable.filter(ReplDBMSEvent event) Filter the event.

Uses of ReplDBMSEvent in com.continuent.tungsten.replicator.heartbeat

Methods in com.continuent.tungsten.replicator.heartbeat that return ReplDBMSEvent

ReplDBMSEvent

HeartbeatFilter.filter(ReplDBMSEvent event)

Methods in com.continuent.tungsten.replicator.heartbeat with parameters of type ReplDBMSEvent

ReplDBMSEvent

HeartbeatFilter.filter(ReplDBMSEvent event)

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

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

boolean	SimpleSchedule.skip(ReplDBMSEvent event) Skips the given event
boolean	StageProgressTracker.skip(ReplDBMSEvent event) Returns false if the current event should be skipped.

Uses of ReplDBMSEvent in com.continuent.tungsten.replicator.prefetch

Methods in com.continuent.tungsten.replicator.prefetch that return ReplDBMSEvent

ReplDBMSEvent

PrefetchStore.filter(ReplDBMSEvent event) Filter the event if it has already been executed.

Methods in com.continuent.tungsten.replicator.prefetch with parameters of type ReplDBMSEvent

ReplDBMSEvent	PrefetchStore.filter(ReplDBMSEvent event) Filter the event if it has already been executed.
void	PrefetchStore.put(ReplDBMSEvent event) Puts an event in the queue, blocking if it is full.

Uses of ReplDBMSEvent in com.continuent.tungsten.replicator.shard

Methods in com.continuent.tungsten.replicator.shard that return ReplDBMSEvent

ReplDBMSEvent

ShardFilter.filter(ReplDBMSEvent event) Filter the event.

Methods in com.continuent.tungsten.replicator.shard with parameters of type ReplDBMSEvent

ReplDBMSEvent

ShardFilter.filter(ReplDBMSEvent event) Filter the event.

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

Fields in com.continuent.tungsten.replicator.storage with type parameters of type ReplDBMSEvent

protected java.util.concurrent.LinkedBlockingQueue<ReplDBMSEvent>

InMemoryQueueStore.queue

Methods in com.continuent.tungsten.replicator.storage that return ReplDBMSEvent

ReplDBMSEvent	InMemoryQueueAdapter.extract() Extract the next available event from the log.
ReplDBMSEvent	InMemoryTransactionalQueue.get() Removes and returns next event from the queue, blocking if empty.
ReplDBMSEvent	InMemoryQueueStore.get() Removes and returns next event from the queue, blocking if empty.
ReplDBMSEvent	InMemoryMultiQueue.get(int taskId) Removes and returns next event from the queue, blocking if empty.
ReplDBMSEvent	InMemoryMultiQueue.get(int taskId, long waitMillis) Removes and returns next event from the queue, waiting up to specified number of milliseconds.
ReplDBMSEvent	InMemoryTransactionalQueue.peek() Returns but does not remove next event from the queue if it exists or returns null if queue is empty.
ReplDBMSEvent	InMemoryQueueStore.peek() Returns but does not remove next event from the queue if it exists or returns null if queue is empty.
ReplDBMSEvent	InMemoryMultiQueue.peek(int taskId) Returns but does not remove next event from the queue if it exists or returns null if queue is empty.
ReplDBMSEvent	InMemoryQueueStore.poll() Removes and returns next event from the queue, returning null if empty.

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

void	InMemoryMultiQueueApplier.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the proffered event to the replication target.
void	InMemoryQueueAdapter.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the proffered event to the replication target.
void	InMemoryTransactionalQueueApplier.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the proffered event to the replication target.
void	InMemoryTransactionalQueue.put(int taskId, ReplDBMSEvent event) Puts an event in the local task queue, where it is buffered in order until commit or rollback.
void	InMemoryMultiQueue.put(int taskId, ReplDBMSEvent event) Puts an event in the queue, blocking if it is full.
void	InMemoryQueueStore.put(ReplDBMSEvent event) Puts an event in the queue, blocking if it is full.

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

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

void	ParallelQueueApplier.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the proffered event to the replication target.
void	ParallelQueueStore.put(int taskId, ReplDBMSEvent event) Puts an event in the queue, blocking if it is full.

Uses of ReplDBMSEvent in com.continuent.tungsten.replicator.storage.prefetch

Methods in com.continuent.tungsten.replicator.storage.prefetch that return ReplDBMSEvent

ReplDBMSEvent

PrefetchStore.filter(ReplDBMSEvent event) Filter the event if it has already been executed.

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

ReplDBMSEvent	PrefetchStore.filter(ReplDBMSEvent event) Filter the event if it has already been executed.
void	PrefetchStore.put(ReplDBMSEvent event) Puts an event in the queue, blocking if it is full.

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

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

ReplDBMSEvent

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

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

void	THLParallelQueueApplier.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the proffered event to the replication target.
void	THLStoreApplier.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL) Apply the proffered event to the replication target.
static void	THLManagerCtrl.printHeader(java.lang.StringBuilder stringBuilder, ReplDBMSEvent event) Prints a formatted header into StringBuilder for the given ReplDBMSEvent.
static void	THLManagerCtrl.printReplDBMSEvent(java.lang.StringBuilder stringBuilder, ReplDBMSEvent event, boolean pureSQL, java.lang.String charset, boolean hex) Formats and prints ReplDBMSEvent into a given stringBuilder.
void	THLParallelQueue.put(int taskId, ReplDBMSEvent event) Puts an event in the queue, blocking if it is full.

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

THLEvent(java.lang.String eventId, ReplDBMSEvent event)
Creates a new THLEvent object with status set to COMPLETED.