|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of PluginContext in com.continuent.tungsten.replicator.applier |
|---|
| Methods in com.continuent.tungsten.replicator.applier with parameters of type PluginContext | |
|---|---|
void |
ApplierWrapper.configure(PluginContext context)
Complete plug-in configuration. |
void |
MongoApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
MySQLDrizzleApplier.configure(PluginContext context)
|
void |
MySQLApplier.configure(PluginContext context)
Generate URL suitable for MySQL and then delegate remaining configuration to superclass. |
void |
OracleApplier.configure(PluginContext context)
Generate URL suitable for MySQL and then delegate remaining configuration to superclass. |
void |
PostgreSQLApplier.configure(PluginContext context)
Generate URL suitable for PostgreSQL and then delegate remaining configuration to superclass. |
void |
JdbcApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
JdbcPrefetcher.configure(PluginContext context)
Complete plug-in configuration. |
void |
DummyApplier.configure(PluginContext context)
|
void |
DrizzleApplier.configure(PluginContext context)
Generate URL suitable for Drizzle and then delegate remaining configuration to superclass. |
void |
ApplierWrapper.prepare(PluginContext context)
Prepare plug-in for use. |
void |
MongoApplier.prepare(PluginContext context)
Prepare plug-in for use. |
void |
JdbcApplier.prepare(PluginContext context)
Prepare plug-in for use. |
void |
JdbcPrefetcher.prepare(PluginContext context)
Prepare plug-in for use. |
void |
DummyApplier.prepare(PluginContext context)
|
void |
ApplierWrapper.release(PluginContext context)
Release all resources used by plug-in. |
void |
MongoApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
JdbcApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
JdbcPrefetcher.release(PluginContext context)
Release all resources used by plug-in. |
void |
DummyApplier.release(PluginContext context)
|
| Uses of PluginContext in com.continuent.tungsten.replicator.applier.batch |
|---|
| Methods in com.continuent.tungsten.replicator.applier.batch with parameters of type PluginContext | |
|---|---|
void |
NativeScriptExecutor.configure(PluginContext context)
Complete plug-in configuration. |
void |
SimpleBatchApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
JavascriptExecutor.configure(PluginContext context)
Complete plug-in configuration. |
void |
NativeScriptExecutor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
SimpleBatchApplier.prepare(PluginContext context)
Prepare plug-in for use. |
void |
JavascriptExecutor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
NativeScriptExecutor.release(PluginContext context)
Release all resources used by plug-in. |
void |
SimpleBatchApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
JavascriptExecutor.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.channel |
|---|
| Methods in com.continuent.tungsten.replicator.channel with parameters of type PluginContext | |
|---|---|
void |
ChannelAssignmentService.configure(PluginContext context)
Complete plug-in configuration. |
void |
ChannelAssignmentService.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ChannelAssignmentService.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.conf |
|---|
| Classes in com.continuent.tungsten.replicator.conf that implement PluginContext | |
|---|---|
class |
ReplicatorRuntime
Contains run-time data for the replicator, including properties and all active plugins. |
| Methods in com.continuent.tungsten.replicator.conf with parameters of type PluginContext | |
|---|---|
static void |
ReplicatorRuntime.configurePlugin(ReplicatorPlugin plugin,
PluginContext context)
Call configure method on a plugin class. |
static void |
ReplicatorRuntime.preparePlugin(ReplicatorPlugin plugin,
PluginContext context)
Call prepare method on a plugin class. |
static void |
ReplicatorRuntime.releasePlugin(ReplicatorPlugin plugin,
PluginContext context)
Call release method on a plugin class, warning on errors. |
| Uses of PluginContext in com.continuent.tungsten.replicator.consistency |
|---|
| Methods in com.continuent.tungsten.replicator.consistency with parameters of type PluginContext | |
|---|---|
void |
ConsistencyCheckFilter.configure(PluginContext context)
Stores the consistency check table name. |
void |
ConsistencyCheckFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ConsistencyCheckFilter.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.event |
|---|
| Methods in com.continuent.tungsten.replicator.event with parameters of type PluginContext | |
|---|---|
void |
EventMetadataFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
EventMetadataFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
EventMetadataFilter.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.extractor |
|---|
| Methods in com.continuent.tungsten.replicator.extractor with parameters of type PluginContext | |
|---|---|
void |
ExtractorWrapper.configure(PluginContext context)
Complete plug-in configuration. |
void |
DummyExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
ExtractorWrapper.prepare(PluginContext context)
Prepare plug-in for use. |
void |
DummyExtractor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ExtractorWrapper.release(PluginContext context)
Release all resources used by plug-in. |
void |
DummyExtractor.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.extractor.mysql |
|---|
| Methods in com.continuent.tungsten.replicator.extractor.mysql with parameters of type PluginContext | |
|---|---|
void |
MySQLExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
MySQLExtractor.prepare(PluginContext context)
If strictVersionChecking is enabled we ensure this database is a supported version. |
void |
MySQLExtractor.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.extractor.oracle |
|---|
| Methods in com.continuent.tungsten.replicator.extractor.oracle with parameters of type PluginContext | |
|---|---|
void |
OracleCDCReaderExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
OracleCDCExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
OracleExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
OracleCDCReaderExtractor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
OracleCDCExtractor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
OracleExtractor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
OracleCDCReaderExtractor.release(PluginContext context)
Release all resources used by plug-in. |
void |
OracleCDCExtractor.release(PluginContext context)
Release all resources used by plug-in. |
void |
OracleExtractor.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.extractor.postgresql |
|---|
| Methods in com.continuent.tungsten.replicator.extractor.postgresql with parameters of type PluginContext | |
|---|---|
void |
PostgreSQLSlonyExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
PostgreSQLSlonyExtractor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
PostgreSQLSlonyExtractor.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.filter |
|---|
| Methods in com.continuent.tungsten.replicator.filter with parameters of type PluginContext | |
|---|---|
void |
BuildAuditTable.configure(PluginContext context)
Complete plug-in configuration. |
void |
CaseMappingFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
LoggingFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
OptimizeUpdatesFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
TungstenTableCDCTransformFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
BidiRemoteSlaveFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
TimeDelayFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
ReplicateColumnsFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
ReplicateFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
RenameFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
MySQLSessionSupportFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
JavaScriptFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
ShardFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
DatabaseTransformFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
EnumToStringFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
PrintEventFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
ColumnNameFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
PrimaryKeyFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
DummyFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
CDCMetadataFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
BuildIndexTable.configure(PluginContext context)
Complete plug-in configuration. |
void |
BuildAuditTable.prepare(PluginContext context)
Prepare plug-in for use. |
void |
CaseMappingFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
LoggingFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
OptimizeUpdatesFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
TungstenTableCDCTransformFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
BidiRemoteSlaveFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
TimeDelayFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ReplicateColumnsFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ReplicateFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
RenameFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
MySQLSessionSupportFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
JavaScriptFilter.prepare(PluginContext context)
Reads and compiles user's script. |
void |
ShardFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
DatabaseTransformFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
EnumToStringFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
PrintEventFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ColumnNameFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
PrimaryKeyFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
DummyFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
CDCMetadataFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
BuildIndexTable.prepare(PluginContext context)
Prepare plug-in for use. |
void |
BuildAuditTable.release(PluginContext context)
Release all resources used by plug-in. |
void |
CaseMappingFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
LoggingFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
OptimizeUpdatesFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
TungstenTableCDCTransformFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
BidiRemoteSlaveFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
TimeDelayFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
ReplicateColumnsFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
ReplicateFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
RenameFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
MySQLSessionSupportFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
JavaScriptFilter.release(PluginContext context)
Calls script's release() function if it exists. |
void |
ShardFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
DatabaseTransformFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
EnumToStringFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
PrintEventFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
ColumnNameFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
PrimaryKeyFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
DummyFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
CDCMetadataFilter.release(PluginContext context)
Release all resources used by plug-in. |
void |
BuildIndexTable.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.heartbeat |
|---|
| Methods in com.continuent.tungsten.replicator.heartbeat with parameters of type PluginContext | |
|---|---|
void |
HeartbeatFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
HeartbeatFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
HeartbeatFilter.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.loader |
|---|
| Methods in com.continuent.tungsten.replicator.loader with parameters of type PluginContext | |
|---|---|
void |
MySQLLoader.configure(PluginContext context)
Build a MySQL JDBC connection string Complete plug-in configuration. |
void |
JdbcLoader.configure(PluginContext context)
|
void |
CSVLoader.configure(PluginContext context)
Complete plug-in configuration. |
void |
JdbcLoader.prepare(PluginContext context)
|
void |
CSVLoader.prepare(PluginContext context)
Prepare plug-in for use. |
void |
JdbcLoader.release(PluginContext context)
|
void |
CSVLoader.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.pipeline |
|---|
| Methods in com.continuent.tungsten.replicator.pipeline that return PluginContext | |
|---|---|
PluginContext |
Pipeline.getContext()
|
PluginContext |
Stage.getPluginContext()
|
| Methods in com.continuent.tungsten.replicator.pipeline with parameters of type PluginContext | |
|---|---|
void |
Pipeline.configure(PluginContext context)
Configures pipeline data structures including stages and stores. |
void |
StageTaskGroup.configure(PluginContext context)
Complete plug-in configuration. |
void |
Stage.configure(PluginContext context)
Complete plug-in configuration. |
protected void |
Stage.configurePlugin(ReplicatorPlugin plugin,
PluginContext context)
Call configure method on a plugin class. |
void |
SingleThreadStageTask.execShutdownHooks(PluginContext context)
Invoke shutdown hooks (if any) defined on components of this task. |
void |
Pipeline.prepare(PluginContext context)
Prepare plug-in for use. |
void |
StageTaskGroup.prepare(PluginContext context)
Prepare plug-in for use. |
void |
Stage.prepare(PluginContext context)
Prepare plug-in for use. |
protected void |
Stage.preparePlugin(ReplicatorPlugin plugin,
PluginContext context)
Call prepare method on a plugin class. |
void |
Pipeline.release(PluginContext context)
Release all resources used by plug-in. |
void |
StageTaskGroup.release(PluginContext context)
Release all resources used by plug-in. |
void |
Stage.release(PluginContext context)
Release all resources used by plug-in. |
protected void |
Stage.releasePlugin(ReplicatorPlugin plugin,
PluginContext context)
Call release method on a plugin class, warning on errors. |
| Uses of PluginContext in com.continuent.tungsten.replicator.plugin |
|---|
| Methods in com.continuent.tungsten.replicator.plugin with parameters of type PluginContext | |
|---|---|
void |
ReplicatorPlugin.configure(PluginContext context)
Complete plug-in configuration. |
void |
ReplicatorPlugin.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ReplicatorPlugin.release(PluginContext context)
Release all resources used by plug-in. |
void |
ShutdownHook.shutdown(PluginContext context)
Shut down component. |
| Uses of PluginContext in com.continuent.tungsten.replicator.prefetch |
|---|
| Fields in com.continuent.tungsten.replicator.prefetch declared as PluginContext | |
|---|---|
protected PluginContext |
PrefetchApplier.runtime
|
| Methods in com.continuent.tungsten.replicator.prefetch with parameters of type PluginContext | |
|---|---|
void |
PrefetchStore.configure(PluginContext context)
Complete plug-in configuration. |
void |
PrefetchApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
PrefetchStore.prepare(PluginContext context)
Prepare prefetch store. |
void |
PrefetchApplier.prepare(PluginContext context)
Prepare plug-in for use. |
void |
PrefetchStore.release(PluginContext context)
Release queue. |
void |
PrefetchApplier.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.shard |
|---|
| Methods in com.continuent.tungsten.replicator.shard with parameters of type PluginContext | |
|---|---|
void |
ShardFilter.configure(PluginContext context)
Complete plug-in configuration. |
void |
ShardFilter.prepare(PluginContext context)
Prepare plug-in for use. |
void |
ShardFilter.release(PluginContext context)
Release all resources used by plug-in. |
| Uses of PluginContext in com.continuent.tungsten.replicator.storage |
|---|
| Methods in com.continuent.tungsten.replicator.storage with parameters of type PluginContext | |
|---|---|
void |
InMemoryMultiQueueApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
InMemoryTransactionalQueue.configure(PluginContext context)
Complete plug-in configuration. |
void |
InMemoryQueueAdapter.configure(PluginContext context)
Complete plug-in configuration. |
void |
InMemoryTransactionalQueueApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
InMemoryQueueStore.configure(PluginContext context)
Complete plug-in configuration. |
void |
InMemoryMultiQueue.configure(PluginContext context)
Complete plug-in configuration. |
void |
InMemoryMultiQueueApplier.prepare(PluginContext context)
Connect to underlying queue. |
void |
InMemoryTransactionalQueue.prepare(PluginContext context)
Allocate an in-memory queue. |
void |
InMemoryQueueAdapter.prepare(PluginContext context)
Connect to underlying queue. |
void |
InMemoryTransactionalQueueApplier.prepare(PluginContext context)
Connect to underlying queue. |
void |
InMemoryQueueStore.prepare(PluginContext context)
Allocate an in-memory queue. |
void |
InMemoryMultiQueue.prepare(PluginContext context)
Allocate an in-memory queue. |
void |
InMemoryMultiQueueApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
InMemoryTransactionalQueue.release(PluginContext context)
Release queue. |
void |
InMemoryQueueAdapter.release(PluginContext context)
Release all resources used by plug-in. |
void |
InMemoryTransactionalQueueApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
InMemoryQueueStore.release(PluginContext context)
Release queue. |
void |
InMemoryMultiQueue.release(PluginContext context)
Release queue. |
| Uses of PluginContext in com.continuent.tungsten.replicator.storage.parallel |
|---|
| Methods in com.continuent.tungsten.replicator.storage.parallel with parameters of type PluginContext | |
|---|---|
void |
ParallelQueueStore.configure(PluginContext context)
Complete plug-in configuration. |
void |
ParallelQueueApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
ParallelQueueExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
ParallelQueueStore.prepare(PluginContext context)
Allocate an in-memory queue. |
void |
ParallelQueueApplier.prepare(PluginContext context)
Connect to underlying queue. |
void |
ParallelQueueExtractor.prepare(PluginContext context)
Connect to underlying queue. |
void |
ParallelQueueStore.release(PluginContext context)
Release queue. |
void |
ParallelQueueApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
ParallelQueueExtractor.release(PluginContext context)
Release all resources used by plug-in. |
void |
ShardListPartitioner.setContext(PluginContext context)
Assigns the current runtime context in case the partitioner needs to refer to replicator state. |
void |
SimplePartitioner.setContext(PluginContext context)
Assigns the current runtime context in case the partitioner needs to refer to replicator state. |
void |
HashPartitioner.setContext(PluginContext context)
Assigns the current runtime context in case the partitioner needs to refer to replicator state. |
void |
RoundRobinPartitioner.setContext(PluginContext context)
Assigns the current runtime context in case the partitioner needs to refer to replicator state. |
void |
Partitioner.setContext(PluginContext context)
Assigns the current runtime context in case the partitioner needs to refer to replicator state. |
void |
LoadBalancingPartitioner.setContext(PluginContext context)
Assigns the current runtime context in case the partitioner needs to refer to replicator state. |
| Uses of PluginContext in com.continuent.tungsten.replicator.storage.prefetch |
|---|
| Methods in com.continuent.tungsten.replicator.storage.prefetch with parameters of type PluginContext | |
|---|---|
void |
PrefetchStore.prepare(PluginContext context)
Prepare prefetch store. |
void |
PrefetchStore.release(PluginContext context)
Release queue. |
| Uses of PluginContext in com.continuent.tungsten.replicator.thl |
|---|
| Fields in com.continuent.tungsten.replicator.thl declared as PluginContext | |
|---|---|
protected PluginContext |
THL.context
|
protected PluginContext |
Connector.pluginContext
|
protected PluginContext |
Protocol.pluginContext
|
| Methods in com.continuent.tungsten.replicator.thl with parameters of type PluginContext | |
|---|---|
void |
CatalogManager.close(PluginContext context)
Close database connection. |
void |
Connector.configure(PluginContext context)
|
void |
THL.configure(PluginContext context)
Complete plug-in configuration. |
void |
THLParallelQueueApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
THLParallelQueue.configure(PluginContext context)
Complete plug-in configuration. |
void |
THLParallelQueueExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
ConnectorHandler.configure(PluginContext context)
Complete plug-in configuration. |
void |
THLStoreApplier.configure(PluginContext context)
Complete plug-in configuration. |
void |
THLStoreExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
RemoteTHLExtractor.configure(PluginContext context)
Complete plug-in configuration. |
void |
Connector.prepare(PluginContext context)
|
void |
THL.prepare(PluginContext context)
Prepare plug-in for use. |
void |
THLParallelQueueApplier.prepare(PluginContext context)
Connect to underlying queue. |
void |
THLParallelQueue.prepare(PluginContext context)
Prepare plug-in for use. |
void |
THLParallelQueueExtractor.prepare(PluginContext context)
Connect to underlying queue. |
void |
ConnectorHandler.prepare(PluginContext context)
Prepare plug-in for use. |
void |
THLParallelReadTask.prepare(PluginContext context)
Connect to THL and seek start sequence number. |
void |
THLStoreApplier.prepare(PluginContext context)
Connect to underlying queue. |
void |
THLStoreExtractor.prepare(PluginContext context)
Connect to store. |
void |
RemoteTHLExtractor.prepare(PluginContext context)
Prepare plug-in for use. |
void |
CatalogManager.prepareSchema(PluginContext context)
Prepare catalog schema schema. |
void |
Connector.release(PluginContext context)
|
void |
THL.release(PluginContext context)
Release all resources used by plug-in. |
void |
THLParallelQueueApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
THLParallelQueue.release(PluginContext context)
Release queue. |
void |
THLParallelQueueExtractor.release(PluginContext context)
Release all resources used by plug-in. |
void |
ConnectorHandler.release(PluginContext context)
Release all resources used by plug-in. |
void |
THLStoreApplier.release(PluginContext context)
Release all resources used by plug-in. |
void |
THLStoreExtractor.release(PluginContext context)
Release all resources used by plug-in. |
void |
RemoteTHLExtractor.release(PluginContext context)
Release all resources used by plug-in. |
void |
RemoteTHLExtractor.shutdown(PluginContext context)
Shut down component. |
| Constructors in com.continuent.tungsten.replicator.thl with parameters of type PluginContext | |
|---|---|
Connector(PluginContext context,
java.lang.String remoteURI,
int resetPeriod,
long lastSeqno,
long lastEpochNumber,
int heartbeatMillis)
Creates a new Connector object Creates a new
Connector object |
|
Protocol(PluginContext context,
SocketWrapper socket)
Creates a new Protocol object |
|
Protocol(PluginContext context,
SocketWrapper socket,
int resetPeriod)
|
|
Server(PluginContext context,
AtomicCounter sequencer,
THL thl)
Creates a new Server object |
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||