Uses of Interface
com.continuent.tungsten.replicator.event.ReplDBMSHeader

Packages that use ReplDBMSHeader

com.continuent.tungsten.replicator.applier
com.continuent.tungsten.replicator.applier.batch
com.continuent.tungsten.replicator.conf
com.continuent.tungsten.replicator.event
com.continuent.tungsten.replicator.extractor
com.continuent.tungsten.replicator.pipeline
com.continuent.tungsten.replicator.plugin
com.continuent.tungsten.replicator.prefetch
com.continuent.tungsten.replicator.storage
com.continuent.tungsten.replicator.storage.parallel
com.continuent.tungsten.replicator.storage.prefetch
com.continuent.tungsten.replicator.thl
com.continuent.tungsten.replicator.util

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

Methods in com.continuent.tungsten.replicator.applier that return ReplDBMSHeader

ReplDBMSHeader	ApplierWrapper.getLastEvent() Return header information corresponding to last committed transaction.
ReplDBMSHeader	MongoApplier.getLastEvent() Return header information corresponding to last committed event.
ReplDBMSHeader	Applier.getLastEvent() Return header information corresponding to last committed transaction.
ReplDBMSHeader	JdbcApplier.getLastEvent() Return header information corresponding to last committed event.
ReplDBMSHeader	JdbcPrefetcher.getLastEvent() Return header information corresponding to last committed event.
ReplDBMSHeader	DummyApplier.getLastEvent()
ReplDBMSHeader	RawApplier.getLastEvent() Return header information corresponding to last committed event.

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

void	MongoApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback) Applies row updates to MongoDB.
void	JdbcApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback) Apply the proffered event to the replication target.
void	JdbcPrefetcher.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback) Apply the proffered event to the replication target.
void	DummyApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback) Apply the proffered event to the replication target.
void	RawApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback) Apply the proffered event to the replication target.
void	ApplierWrapper.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.
void	Applier.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.

Uses of ReplDBMSHeader in com.continuent.tungsten.replicator.applier.batch

Methods in com.continuent.tungsten.replicator.applier.batch that return ReplDBMSHeader

ReplDBMSHeader

SimpleBatchApplier.getLastEvent() Return header information corresponding to last committed event.

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

void	SimpleBatchApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback) Applies row updates using a batch loading scheme.

Uses of ReplDBMSHeader in com.continuent.tungsten.replicator.conf

Methods in com.continuent.tungsten.replicator.conf that return types with arguments of type ReplDBMSHeader

java.util.concurrent.Future<ReplDBMSHeader>

ReplicatorRuntime.waitForCommitted(long seqno) Returns a future to allow clients to wait until the pipeline has safely committed the requested seqno.

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

Classes in com.continuent.tungsten.replicator.event that implement ReplDBMSHeader

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.
class	ReplDBMSHeaderData An implementation of replicator header information used to track position.

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

ReplDBMSHeader

ReplControlEvent.getHeader() Returns the event to which control information applies or null if inapplicable.

Constructors in com.continuent.tungsten.replicator.event with parameters of type ReplDBMSHeader

ReplControlEvent(int eventType, long seqno, ReplDBMSHeader header)
Creates a new control event instance.

ReplDBMSFilteredEvent(ReplDBMSHeader firstFilteredEvent, ReplDBMSHeader lastFilteredEvent)
Standard way to instantiate a filtered event using the headers from the first and last event.

ReplDBMSHeaderData(ReplDBMSHeader event)

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

Methods in com.continuent.tungsten.replicator.extractor with parameters of type ReplDBMSHeader

void	ExtractorWrapper.setLastEvent(ReplDBMSHeader header) Set the value of the last event called.
void	Extractor.setLastEvent(ReplDBMSHeader header) Set the value of the last event called.

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

Methods in com.continuent.tungsten.replicator.pipeline that return ReplDBMSHeader

ReplDBMSHeader	StageProgressTracker.getCommittedMinEvent() Return the last committed event.
ReplDBMSHeader	StageProgressTracker.getDirtyLastProcessedEvent(int taskId) Return last event that we have seen.
ReplDBMSHeader	StageProgressTracker.getDirtyMinLastEvent() Return the last processed event or null if none such exists.
ReplDBMSHeader	Pipeline.getLastAppliedEvent() Returns the last event applied in the last stage.
ReplDBMSHeader	TaskProgress.getLastCommittedEvent()
ReplDBMSHeader	TaskProgress.getLastProcessedEvent()

Methods in com.continuent.tungsten.replicator.pipeline that return types with arguments of type ReplDBMSHeader

java.util.concurrent.Future<ReplDBMSHeader>	Pipeline.flush() Find the current native event ID in the DBMS and wait until it reaches the log.
java.util.concurrent.Future<ReplDBMSHeader>	Pipeline.watchForCommittedSequenceNumber(long seqno, boolean terminate) Sets a watch for a particular sequence number to be safely committed on all channels at the end of the pipeline.
java.util.concurrent.Future<ReplDBMSHeader>	StageProgressTracker.watchForCommittedSequenceNumber(long seqno, boolean cancel) Sets a watch for a particular sequence number to be safely committed on all channels.
java.util.concurrent.Future<ReplDBMSHeader>	Stage.watchForCommittedSequenceNumber(long seqno, boolean terminate) Sets a watch for a particular sequence number to be safely committed on all channels.
java.util.concurrent.Future<ReplDBMSHeader>	Pipeline.watchForExtractedEventId(java.lang.String eventId) Sets a watch for a particular event ID to be extracted.
java.util.concurrent.Future<ReplDBMSHeader>	Pipeline.watchForExtractedSequenceNumber(long seqno) Sets a watch for a particular sequence number to be extracted.
java.util.concurrent.Future<ReplDBMSHeader>	Pipeline.watchForProcessedEventId(java.lang.String eventId) Sets a watch for a particular event ID to be processed.
java.util.concurrent.Future<ReplDBMSHeader>	StageProgressTracker.watchForProcessedEventId(java.lang.String eventId, boolean cancel) Sets a watch for a particular event ID to be processed.
java.util.concurrent.Future<ReplDBMSHeader>	Stage.watchForProcessedEventId(java.lang.String eventId, boolean terminate) Sets a watch for a particular event ID to be extracted.
java.util.concurrent.Future<ReplDBMSHeader>	StageProgressTracker.watchForProcessedHeartbeat(java.lang.String name, boolean cancel) Sets a watch for a heartbeat event to be extracted.
java.util.concurrent.Future<ReplDBMSHeader>	Stage.watchForProcessedHeartbeat(java.lang.String name, boolean terminate) Sets a watch for a heartbeat event to be extracted.
java.util.concurrent.Future<ReplDBMSHeader>	Pipeline.watchForProcessedSequenceNumber(long seqno) Sets a watch for a particular sequence number to be processed.
java.util.concurrent.Future<ReplDBMSHeader>	StageProgressTracker.watchForProcessedSequenceNumber(long seqno, boolean cancel) Sets a watch for a particular sequence number to be processed.
java.util.concurrent.Future<ReplDBMSHeader>	Stage.watchForProcessedSequenceNumber(long seqno, boolean terminate) Sets a watch for a particular sequence number to be processed.
java.util.concurrent.Future<ReplDBMSHeader>	StageProgressTracker.watchForProcessedTimestamp(java.sql.Timestamp timestamp, boolean cancel) Sets a watch for a particular source timestamp to be extracted.
java.util.concurrent.Future<ReplDBMSHeader>	Stage.watchForProcessedTimestamp(java.sql.Timestamp timestamp, boolean terminate) Sets a watch for a source timestamp to be extracted.

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

boolean	TaskScheduler.proceed(ReplDBMSHeader lastEvent) Controls whether stage task should continue processing events.
void	SingleThreadStageTask.reportInitialPosition(ReplDBMSHeader lastHeader)
void	StageProgressTracker.setInitialLastProcessedEvent(int taskId, ReplDBMSHeader replEvent)
void	TaskProgress.setLastCommittedEvent(ReplDBMSHeader lastCommittedEvent)
void	StageProgressTracker.setLastProcessedEvent(int taskId, ReplDBMSHeader replEvent) Set the last processed event, which triggers checks for watches.
void	Schedule.setLastProcessedEvent(ReplDBMSHeader event) Set the last processed event, which triggers checks for watches.
void	TaskProgress.setLastProcessedEvent(ReplDBMSHeader lastEvent)
void	SimpleSchedule.setLastProcessedEvent(ReplDBMSHeader event) Set the last processed event, which triggers checks for watches.

Uses of ReplDBMSHeader in com.continuent.tungsten.replicator.plugin

Methods in com.continuent.tungsten.replicator.plugin that return types with arguments of type ReplDBMSHeader

java.util.concurrent.Future<ReplDBMSHeader>

PluginContext.waitForCommitted(long seqno) Returns a future to allow clients to wait until the pipeline has safely committed the requested seqno.

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

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

ReplDBMSHeader	PrefetchApplier.getLastEvent() Return header information corresponding to last committed event.
ReplDBMSHeader	PrefetchStore.getLastHeader() Returns the position of the slave on which we are handling prefetch.

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

void	PrefetchApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback) Apply the proffered event to the replication target.
void	PrefetchStore.setLastHeader(ReplDBMSHeader header) Sets the last header processed.

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

Fields in com.continuent.tungsten.replicator.storage declared as ReplDBMSHeader

protected ReplDBMSHeader

InMemoryQueueStore.lastHeader

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

ReplDBMSHeader	InMemoryMultiQueueApplier.getLastEvent() Return header information corresponding to last committed transaction.
ReplDBMSHeader	InMemoryQueueAdapter.getLastEvent() Return the header, which should have been place here by an extractor during restart.
ReplDBMSHeader	InMemoryTransactionalQueueApplier.getLastEvent() Return header information corresponding to last committed transaction.
ReplDBMSHeader	InMemoryQueueStore.getLastHeader() Returns the last header processed.
ReplDBMSHeader	InMemoryTransactionalQueue.getLastHeader(int taskId) Returns the last header processed.
ReplDBMSHeader	InMemoryMultiQueue.getLastHeader(int taskId) Returns the last header processed.

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

void	InMemoryQueueAdapter.setLastEvent(ReplDBMSHeader header) Store the header so that it can be propagated back through the pipeline for restart.
void	InMemoryTransactionalQueue.setLastHeader(int taskId, ReplDBMSHeader header) Sets the last header processed.
void	InMemoryMultiQueue.setLastHeader(int taskId, ReplDBMSHeader header) Sets the last header processed.
void	InMemoryQueueStore.setLastHeader(ReplDBMSHeader header) Sets the last header processed.
void	InMemoryMultiQueueApplier.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.
void	InMemoryQueueAdapter.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.
void	InMemoryTransactionalQueueApplier.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.

Method parameters in com.continuent.tungsten.replicator.storage with type arguments of type ReplDBMSHeader

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

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

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

ReplDBMSHeader	ParallelQueueApplier.getLastEvent() Return the minimum header across all queues to ensure we do not miss events on restart.
ReplDBMSHeader	ParallelQueueExtractor.getLastEvent() Return the header, which should have been place here by an extractor during restart.
ReplDBMSHeader	ParallelQueueStore.getLastHeader(int taskId) Returns the last header processed.

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

PartitionerResponse	ShardListPartitioner.partition(ReplDBMSHeader event, int taskId) Assign an event to a particular partition.
PartitionerResponse	SimplePartitioner.partition(ReplDBMSHeader event, int taskId) Assign an event to a particular partition.
PartitionerResponse	HashPartitioner.partition(ReplDBMSHeader event, int taskId) Assign an event to a particular partition.
PartitionerResponse	RoundRobinPartitioner.partition(ReplDBMSHeader event, int taskId) Assign an event to a particular partition.
PartitionerResponse	Partitioner.partition(ReplDBMSHeader event, int taskId) Assign an event to a particular partition.
PartitionerResponse	LoadBalancingPartitioner.partition(ReplDBMSHeader event, int taskId) Returns the partition with the smallest current size or the first partition that has a current size of zero.
void	ParallelQueueExtractor.setLastEvent(ReplDBMSHeader header) Store the header so that it can be propagated back through the pipeline for restart.
void	ParallelQueueStore.setLastHeader(int taskId, ReplDBMSHeader header) Sets the last header processed.
void	ParallelQueueApplier.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.

Method parameters in com.continuent.tungsten.replicator.storage.parallel with type arguments of type ReplDBMSHeader

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

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

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

ReplDBMSHeader

PrefetchStore.getLastHeader() Returns the position of the slave on which we are handling prefetch.

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

void	PrefetchStore.setLastHeader(ReplDBMSHeader header) Sets the last header processed.

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

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

ReplDBMSHeader	THL.getLastAppliedEvent() Get the last applied event.
ReplDBMSHeader	THLParallelQueueApplier.getLastEvent() Return the minimum header across all queues to ensure we do not miss events on restart.
ReplDBMSHeader	THLStoreApplier.getLastEvent() Return header information corresponding to last committed transaction.
ReplDBMSHeader	THL.getLastLoggedEvent() Get the last event applied to the replicator log or return null if there is no such event.
ReplDBMSHeader	CatalogManager.getMinLastEvent() Return the minimum last applied event as stored in the CommitSeqnoTable.
ReplDBMSHeader	THLParallelQueue.getMinLastHeader() Returns the minimum last header processed in order to handle restart correctly.
ReplDBMSHeader	CommitSeqnoTable.lastCommitSeqno(int taskId) Fetches header data for last committed transaction or null if none such can be found.
ReplDBMSHeader	CommitSeqnoTable.minCommitSeqno() Returns the header for the lowest committed sequence number or null if none such can be found.

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

void	THLParallelQueueExtractor.setLastEvent(ReplDBMSHeader header) Store the header so that it can be propagated back through the pipeline for restart.
void	THLStoreExtractor.setLastEvent(ReplDBMSHeader event) Stores the last event we have processed.
void	RemoteTHLExtractor.setLastEvent(ReplDBMSHeader event)
void	THLParallelQueue.setLastHeader(int taskId, ReplDBMSHeader header) Sets the last header processed.
void	THLParallelReadTask.setRestartHeader(ReplDBMSHeader header) Set the starting header.
void	CommitSeqnoTable.updateLastCommitSeqno(int taskId, ReplDBMSHeader header, long appliedLatency) Updates the last commit seqno value.
void	THLParallelQueueApplier.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.
void	THLStoreApplier.updatePosition(ReplDBMSHeader header, boolean doCommit, boolean syncTHL) Update current recovery position but do not apply an event.

Method parameters in com.continuent.tungsten.replicator.thl with type arguments of type ReplDBMSHeader

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.

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

THLParallelReadQueue(int taskId, int maxSize, int maxControlEvents, long startingSeqno, int syncInterval, ReplDBMSHeader lastHeader, AtomicIntervalGuard<?> intervalGuard)
Instantiates a new read queue.

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

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

boolean	SeqnoWatchPredicate.match(ReplDBMSHeader event) Return true if the sequence number is greater than or equal to what we are seeking.
boolean	SourceTimestampWatchPredicate.match(ReplDBMSHeader event) Return true if the sequence number is greater than or equal to what we are seeking.
boolean	HeartbeatWatchPredicate.match(ReplDBMSHeader event) Return true if we have a ReplDBMSEvent instance *and* it has a matching heartbeat name.
boolean	EventIdWatchPredicate.match(ReplDBMSHeader event)