Overview  Package  Class   Use  Tree  Deprecated  Index  Help 
 PREV   NEXT FRAMES    NO FRAMES    

Uses of Class
com.continuent.tungsten.replicator.ReplicatorException

Packages that use ReplicatorException
com.continuent.tungsten.replicator   
com.continuent.tungsten.replicator.applier   
com.continuent.tungsten.replicator.applier.batch   
com.continuent.tungsten.replicator.backup   
com.continuent.tungsten.replicator.channel   
com.continuent.tungsten.replicator.conf   
com.continuent.tungsten.replicator.consistency   
com.continuent.tungsten.replicator.database   
com.continuent.tungsten.replicator.ddlscan   
com.continuent.tungsten.replicator.event   
com.continuent.tungsten.replicator.extractor   
com.continuent.tungsten.replicator.extractor.mysql   
com.continuent.tungsten.replicator.extractor.oracle   
com.continuent.tungsten.replicator.extractor.postgresql   
com.continuent.tungsten.replicator.filter   
com.continuent.tungsten.replicator.heartbeat   
com.continuent.tungsten.replicator.loader   
com.continuent.tungsten.replicator.management   
com.continuent.tungsten.replicator.management.script   
com.continuent.tungsten.replicator.management.tungsten   
com.continuent.tungsten.replicator.pipeline   
com.continuent.tungsten.replicator.plugin   
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   
com.continuent.tungsten.replicator.thl.log   
com.continuent.tungsten.replicator.thl.serializer   
 

Uses of ReplicatorException in com.continuent.tungsten.replicator
 

Constructors in com.continuent.tungsten.replicator that throw ReplicatorException
VersionManager(TungstenProperties properties)
           
 

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

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.applier
 class ApplierException
          This class defines a ApplierException
 

Methods in com.continuent.tungsten.replicator.applier that throw ReplicatorException
 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 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.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.
protected  void MySQLDrizzleApplier.applyLoadDataLocal(LoadDataFileQuery data, java.io.File temporaryFile)
           
protected  void MySQLApplier.applyLoadDataLocal(LoadDataFileQuery data, java.io.File temporaryFile)
          applyLoadDataLocal executes the LoadDataFileQuery.
protected  void JdbcApplier.applyLoadDataLocal(LoadDataFileQuery data, java.io.File temporaryFile)
          applyLoadDataLocal executes the LoadDataFileQuery.
protected  void JdbcApplier.applyOneRowChangePrepared(OneRowChange oneRowChange)
           
protected  void JdbcApplier.applyRowChangeData(RowChangeData data, java.util.List<ReplOption> options)
           
protected  void MySQLApplier.applyRowIdData(RowIdData data)
           
protected  void JdbcApplier.applyRowIdData(RowIdData data)
           
protected  void JdbcPrefetcher.applyRowIdData(RowIdData data)
           
protected  void DrizzleApplier.applyRowIdData(RowIdData data)
           
protected  void MySQLDrizzleApplier.applyStatementData(StatementData data)
           
protected  void JdbcApplier.applyStatementData(StatementData data)
           
 void ApplierWrapper.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 void MongoApplier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 void Applier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 void JdbcApplier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 void JdbcPrefetcher.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 void RawApplier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 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 DrizzleApplier.configure(PluginContext context)
          Generate URL suitable for Drizzle and then delegate remaining configuration to superclass.
 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.
protected  void JdbcPrefetcher.prefetchOneRowChangePrepared(OneRowChange oneRowChange)
           
protected  void JdbcPrefetcher.prefetchRowChangeData(RowChangeData data, java.util.List<ReplOption> options)
           
protected  void JdbcPrefetcher.prefetchStatementData(StatementData data)
           
 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 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 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 ReplicatorException in com.continuent.tungsten.replicator.applier.batch
 

Methods in com.continuent.tungsten.replicator.applier.batch that throw ReplicatorException
 void SimpleBatchApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback)
          Applies row updates using a batch loading scheme.
 void SimpleBatchApplier.assertNotNull(java.lang.String property, java.lang.String name)
           
protected  void SimpleBatchApplier.clearStageTable(CsvInfo info)
           
protected  void InfiniDBBatchApplier.clearStageTable(CsvInfo info)
          Needs to be done in a transaction, otherwise cpimport will be unable to get the lock on the stage table !
 void SimpleBatchApplier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 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.
 java.lang.String JavascriptRuntime.exec(java.lang.String command)
          Execute an OS command and return the result of stdout.
 void NativeScriptExecutor.execute(CsvInfo info)
          Executes the script for a specific table.
 void JavascriptExecutor.execute(CsvInfo info)
          Executes the script for a specific table.
 void ScriptExecutor.execute(CsvInfo info)
          Executes the script for a specific table.
 ReplDBMSHeader SimpleBatchApplier.getLastEvent()
          Return header information corresponding to last committed event.
 java.lang.String CsvInfo.getPKColumn()
          Determines primary key name for the given CsvInfo object.
 java.util.Map<java.lang.String,java.lang.String> CsvInfo.getSqlParameters()
          Returns SQL substitution parameters for this CSV file.
static SqlScriptGenerator SimpleBatchApplier.initializeGenerator(java.lang.String script)
           
protected  void VerticaStreamBatchApplier.load(CsvInfo info)
           
 void SqlCsvLoader.load(Database conn, CsvInfo info, LoadMismatch onLoadMismatch)
          Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.
 void CsvLoader.load(Database conn, CsvInfo info, LoadMismatch onLoadMismatch)
          Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.
 void VerticaCsvLoader.load(Database conn, CsvInfo info, LoadMismatch onLoadMismatch)
          Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.
 void BatchScript.load(java.io.File scriptFile)
          Loads a set of raw commands from an input stream.
 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 SimpleBatchApplier.release(PluginContext context)
          Release all resources used by plug-in.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.backup
 

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.backup
 class BackupException
          This exception signals a failed backup operation.
 class UnsupportedCapabilityException
          Exception used to denote an attempt to exercise a capability that is not supported.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.channel
 

Methods in com.continuent.tungsten.replicator.channel that throw ReplicatorException
 void ChannelAssignmentService.configure(PluginContext context)
          Complete plug-in configuration.
 java.lang.Integer ChannelAssignmentService.getChannelAssignment(java.lang.String shardId)
          Looks up a channel assignment for a shard.
 void ShardChannelTable.initializeShardTable(Database database, int channels)
          Set up the channel table.
 void ChannelAssignmentService.insertChannelAssignment(java.lang.String shardId, int channel)
          Inserts a shard/channel assignment.
 java.util.List<java.util.Map<java.lang.String,java.lang.String>> ChannelAssignmentService.listChannelAssignments()
          Return a list of current channel assignments.
 void ChannelAssignmentService.prepare(PluginContext context)
          Prepare plug-in for use.
 void ChannelAssignmentService.release(PluginContext context)
          Release all resources used by plug-in.
 

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

Methods in com.continuent.tungsten.replicator.conf that throw ReplicatorException
protected  java.lang.String ReplicatorRuntime.assertPropertySet(java.lang.String key)
           
 void PropertiesManager.clearDynamicProperties()
          Clear in-memory dynamic properties and delete on-disk file, if it exists.
 void ReplicatorRuntime.configure()
          Process configuration properties and instantiate/configure all plug-ins.
static void ReplicatorRuntime.configurePlugin(ReplicatorPlugin plugin, PluginContext context)
          Call configure method on a plugin class.
 TungstenProperties PropertiesManager.getDynamicProperties()
          Return current values of all supported dynamic values.
protected  void ReplicatorRuntime.instantiateAndConfigurePipeline(java.lang.String name)
          Instantiates a pipeline consisting of one or more stages.
protected  void ReplicatorRuntime.instantiateExtensions()
          Load extension classes, if defined.
protected  ReplicatorPlugin ReplicatorRuntime.loadAndConfigurePlugin(java.lang.String prefix, java.lang.String name)
          Generic code to load and configure a plugin.
 void PropertiesManager.loadProperties()
           
static TungstenProperties PropertiesManager.loadProperties(java.io.File propsFile)
           
 void ReplicatorRuntime.prepare()
          Prepares pipeline for use.
static void ReplicatorRuntime.preparePlugin(ReplicatorPlugin plugin, PluginContext context)
          Call prepare method on a plugin class.
 void PropertiesManager.setDynamicProperties(TungstenProperties dynaProps)
          Sets one or more dynamic properties after checking we permit them to be set.
 void ReplicatorRuntime.setLastOnlineRoleName(java.lang.String roleName)
          Writes the value of the last online role to storage.
protected  PluginSpecification ReplicatorRuntime.specifyPlugin(java.lang.String prefix, java.lang.String name)
          Generic code to load and configure a plugin.
 

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

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.consistency
 class ConsistencyException
          This class defines a ConsistencyException
 

Methods in com.continuent.tungsten.replicator.consistency that throw ReplicatorException
 void ConsistencyCheckFilter.configure(PluginContext context)
          Stores the consistency check table name.
 ReplDBMSEvent ConsistencyCheckFilter.filter(ReplDBMSEvent event)
           
 void ConsistencyCheckFilter.prepare(PluginContext context)
          Prepare plug-in for use.
 void ConsistencyCheckFilter.release(PluginContext context)
          Release all resources used by plug-in.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.database
 

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.database
 class DatabaseException
          This class defines a DatabaseException
 

Methods in com.continuent.tungsten.replicator.database that throw ReplicatorException
 SqlOperationMatcher OracleDatabase.getSqlNameMatcher()
          In Oracle, to support timestamp with local time zone replication we need to set the session level time zone to be the same as the database time zone.
 SqlOperationMatcher DerbyDatabase.getSqlNameMatcher()
          Returns a SQL name matcher for this database type.
 SqlOperationMatcher PostgreSQLDatabase.getSqlNameMatcher()
          Returns a SQL name matcher for this database type.
abstract  SqlOperationMatcher AbstractDatabase.getSqlNameMatcher()
           
 SqlOperationMatcher GreenplumDatabase.getSqlNameMatcher()
          Returns a SQL name matcher for this database type.
 SqlOperationMatcher Database.getSqlNameMatcher()
          Returns a SQL name matcher for this database type.
 SqlOperationMatcher MySQLDatabase.getSqlNameMatcher()
          Returns a SQL name matcher for this database type.
 SqlOperationMatcher DrizzleDatabase.getSqlNameMatcher()
          Returns a SQL name matcher for this database type.
 void AbstractDatabase.kill(Session session)
          Kills a particular session.
 void Database.kill(Session session)
          Kills a particular session.
 void MySQLDatabase.kill(Session session)
          Issue a KILL command to remove a particular session.
static DBMS JdbcURL.string2DBMS(java.lang.String driver_spec)
           
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.ddlscan
 

Methods in com.continuent.tungsten.replicator.ddlscan that throw ReplicatorException
 void DDLScan.parseRenameDefinitions(java.lang.String definitionsFile)
          Tries to load rename definitions file.
 void DDLScan.parseTemplate(java.lang.String templateFile)
          Compiles the given Velocity template file.
 void DDLScanCtrl.prepare()
           
 void DDLScan.prepare(java.lang.String additionalPath)
          Connect to the underlying database.
 java.lang.String DDLScan.scan(java.lang.String tablesToFind, java.util.Hashtable<java.lang.String,java.lang.String> templateOptions, java.io.Writer writer)
          Scans and extracts metadata from the database of requested tables.
 boolean DDLScanCtrl.scanAndGenerate()
          Scans the database for requested objects and generates output through a template.
 

Constructors in com.continuent.tungsten.replicator.ddlscan that throw ReplicatorException
DDLScan(java.lang.String url, java.lang.String dbName, java.lang.String user, java.lang.String pass)
          Creates a new DDLScan object from provided JDBC URL connection credentials and template file.
 

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

Methods in com.continuent.tungsten.replicator.event that throw ReplicatorException
 void EventMetadataFilter.configure(PluginContext context)
          Complete plug-in configuration.
 ReplDBMSEvent EventMetadataFilter.filter(ReplDBMSEvent event)
          Filter the event.
 void EventMetadataFilter.prepare(PluginContext context)
          Prepare plug-in for use.
 void EventMetadataFilter.release(PluginContext context)
          Release all resources used by plug-in.
 

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

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.extractor
 class ExtractorException
          This class defines a ExtractorException
 

Methods in com.continuent.tungsten.replicator.extractor that throw ReplicatorException
 void ExtractorWrapper.configure(PluginContext context)
          Complete plug-in configuration.
 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.
 ReplEvent Extractor.extract()
          Extract the next available event from the log.
 DBMSEvent RawExtractor.extract()
          Extract the next available DBMSEvent from the database log.
 DBMSEvent RawExtractor.extract(java.lang.String eventId)
          Extract starting after the event ID provided as an argument.
 java.lang.String ExtractorWrapper.getCurrentResourceEventId()
          Delegates to underlying extractor.
 java.lang.String Extractor.getCurrentResourceEventId()
          Returns the last event ID committed in a database from which we are extracting.
 java.lang.String DummyExtractor.getCurrentResourceEventId()
          Returns the last event ID committed in the database from which we are extracting.
 java.lang.String RawExtractor.getCurrentResourceEventId()
          Returns the last event ID committed in the database from which we are extracting.
 void ExtractorWrapper.prepare(PluginContext context)
          Prepare plug-in for use.
 void ExtractorWrapper.release(PluginContext context)
          Release all resources used by plug-in.
 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.
 void ExtractorWrapper.setLastEventId(java.lang.String eventId)
          Provides a new native event ID that overrides the default value that the extractor would otherwise use.
 void Extractor.setLastEventId(java.lang.String eventId)
          Provides a new native event ID that overrides the default value that the extractor would otherwise use.
 void DummyExtractor.setLastEventId(java.lang.String eventId)
          Set the value of the last event ID we have processed.
 void RawExtractor.setLastEventId(java.lang.String eventId)
          Set the value of the last event ID we have processed.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.extractor.mysql
 

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.extractor.mysql
 class MySQLExtractException
          This class defines a MySQLExtractException
 

Methods in com.continuent.tungsten.replicator.extractor.mysql that throw ReplicatorException
 void BinlogReader.close()
          Closes the stream but leaves directory and base name intact
 void MySQLExtractor.configure(PluginContext context)
          Complete plug-in configuration.
 void RelayLogClient.connect()
          Connect to database and set up relay log transfer.
 DBMSEvent MySQLExtractor.extract()
          Extract the next available DBMSEvent from the database log.
 DBMSEvent MySQLExtractor.extract(java.lang.String id)
          Extract starting after the event ID provided as an argument.
protected  int QueryLogEvent.extractStatusVariables(byte[] buffer, int start, int end)
           
protected  int RowsLogEvent.extractValue(OneRowChange.ColumnSpec spec, OneRowChange.ColumnVal value, byte[] row, int rowPos, int type, int meta)
           
 java.lang.String MySQLExtractor.getCurrentResourceEventId()
          Returns the last event ID committed in the database from which we are extracting.
 void MySQLExtractor.prepare(PluginContext context)
          If strictVersionChecking is enabled we ensure this database is a supported version.
 boolean RelayLogClient.processEvent()
          Process next event packet from MySQL.
abstract  void RowsLogEvent.processExtractedEvent(RowChangeData rowChanges, TableMapLogEvent map)
           
 void DeleteRowsLogEvent.processExtractedEvent(RowChangeData rowChanges, TableMapLogEvent map)
          
 void WriteRowsLogEvent.processExtractedEvent(RowChangeData rowChanges, TableMapLogEvent map)
          
 void UpdateRowsLogEvent.processExtractedEvent(RowChangeData rowChanges, TableMapLogEvent map)
          
protected  int RowsLogEvent.processExtractedEventRow(OneRowChange oneRowChange, int rowIndex, java.util.BitSet cols, int rowPos, byte[] row, TableMapLogEvent map, boolean isKeySpec)
           
protected  java.lang.String RowsLogEvent.processString(byte[] buffer, int pos, int length)
           
 void BinlogIndex.readIndex()
          Refreshes the list of binlog files from current index contents.
static LogEvent LogEvent.readLogEvent(ReplicatorRuntime runtime, BinlogReader position, FormatDescriptionLogEvent descriptionEvent, boolean parseStatements, boolean useBytesForString, boolean prefetchSchemaNameLDI)
           
 void MySQLExtractor.release(PluginContext context)
          Release all resources used by plug-in.
 void MySQLExtractor.setLastEventId(java.lang.String eventId)
          Set the value of the last event ID we have processed.
 

Constructors in com.continuent.tungsten.replicator.extractor.mysql that throw ReplicatorException
AppendBlockLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
BeginLoadQueryLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
BinlogIndex(java.lang.String directory, java.lang.String baseName, boolean readIndex)
          Creates a new BinlogIndex instance.
DeleteFileLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
DeleteRowsLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, boolean useBytesForString, java.lang.String currentPosition)
           
ExecuteLoadQueryLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, boolean parseStatements, java.lang.String currentPosition)
           
FormatDescriptionLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
IntvarLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
LogEvent(byte[] buffer, FormatDescriptionLogEvent descriptionEvent, int eventType)
           
QueryLogEvent(byte[] buffer, FormatDescriptionLogEvent descriptionEvent, int eventType)
           
QueryLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, boolean parseStatements, boolean useBytesForString, java.lang.String currentPosition)
           
RandLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
RotateLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
          Creates a new Rotate_log_event object read normally from log.
RowsLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, int eventType, boolean useBytesForString)
           
StartLogEvent(byte[] buffer, FormatDescriptionLogEvent descriptionEvent)
           
StopLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
TableMapLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
UpdateRowsLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, boolean useBytesForString, java.lang.String currentPosition)
           
UserVarLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
WriteRowsLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, boolean useBytesForString, java.lang.String currentPosition)
           
XidLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, java.lang.String currentPosition)
           
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.extractor.oracle
 

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.extractor.oracle
 class OracleExtractException
          This class defines an OracleExtractException
 

Methods in com.continuent.tungsten.replicator.extractor.oracle that throw ReplicatorException
 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.
 DBMSEvent OracleCDCReaderExtractor.extract()
          Extract the next available DBMSEvent from the database log.
 DBMSEvent OracleCDCExtractor.extract()
          Extract the next available DBMSEvent from the database log.
 DBMSEvent OracleCDCReaderExtractor.extract(java.lang.String eventId)
          Extract starting after the event ID provided as an argument.
 DBMSEvent OracleCDCExtractor.extract(java.lang.String eventId)
          Extract starting after the event ID provided as an argument.
 java.lang.String OracleCDCReaderExtractor.getCurrentResourceEventId()
          Returns the last event ID committed in the database from which we are extracting.
 java.lang.String OracleCDCExtractor.getCurrentResourceEventId()
          Returns the last event ID committed in the database from which we are extracting.
 void OracleCDCReaderThread.prepare()
           
 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.
 void OracleCDCReaderExtractor.setLastEventId(java.lang.String eventId)
          Set the value of the last event ID we have processed.
 void OracleCDCExtractor.setLastEventId(java.lang.String eventId)
          Set the value of the last event ID we have processed.
 void OracleCDCReaderThread.setLastSCN(java.lang.String lastSCN)
           
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.extractor.postgresql
 

Methods in com.continuent.tungsten.replicator.extractor.postgresql that throw ReplicatorException
 void PostgreSQLSlonyExtractor.configure(PluginContext context)
          Complete plug-in configuration.
 DBMSEvent PostgreSQLSlonyExtractor.extract()
          Extracts the next event.

Extract the next available DBMSEvent from the database log.
 DBMSEvent PostgreSQLSlonyExtractor.extract(java.lang.String eventId)
          Extract starting after the event ID provided as an argument.
 java.lang.String PostgreSQLSlonyExtractor.getCurrentResourceEventId()
          Determines last transaction (log_txid) in the Slony log.

Returns the last event ID committed in the database from which we are extracting.
 void PostgreSQLSlonyExtractor.prepare(PluginContext context)
          Prepare plug-in for use.
 void PostgreSQLSlonyExtractor.release(PluginContext context)
          Release all resources used by plug-in.
 void PostgreSQLSlonyExtractor.setLastEventId(java.lang.String eventId)
          Set the value of the last event ID we have processed.
 

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

Methods in com.continuent.tungsten.replicator.filter that throw ReplicatorException
protected  void SetToStringFilter.checkForListType(OneRowChange orc)
          Overriding EnumToStringFilter core to check for SET columns in the event.
protected  void EnumToStringFilter.checkForListType(OneRowChange orc)
          Checks for ENUM columns in the event.
protected  void EnumToStringFilter.checkForListType(OneRowChange orc, java.lang.String type)
          Checks for ENUM/SET type columns in the event.
 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.
 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.
 void RenameDefinitions.parseFile()
          Parses rename definition file, validates format and populates lookup structures.
 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.
 void TungstenTableCDCTransformFilter.setFrom(java.lang.String name)
          Sets the regex used to match the database name.
 void TungstenTableCDCTransformFilter.setTo(java.lang.String name)
          Sets the corresponding regex to transform the name.
protected  void SetToStringFilter.transformColumns(java.util.ArrayList<OneRowChange.ColumnSpec> columns, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> columnValues, java.util.HashMap<java.lang.Integer,java.lang.String[]> setDefinitions, java.lang.String typeCaption)
          Overriding EnumToStringFilter core to transform SET column values to comma separated string representation.
protected  void EnumToStringFilter.transformColumns(java.util.ArrayList<OneRowChange.ColumnSpec> columns, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> columnValues, java.util.HashMap<java.lang.Integer,java.lang.String[]> enumDefinitions, java.lang.String typeCaption)
           
 

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

Methods in com.continuent.tungsten.replicator.heartbeat that throw ReplicatorException
 void HeartbeatFilter.configure(PluginContext context)
          Complete plug-in configuration.
 ReplDBMSEvent HeartbeatFilter.filter(ReplDBMSEvent event)
           
 void HeartbeatFilter.prepare(PluginContext context)
          Prepare plug-in for use.
 void HeartbeatFilter.release(PluginContext context)
          Release all resources used by plug-in.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.loader
 

Methods in com.continuent.tungsten.replicator.loader that throw ReplicatorException
protected  java.lang.String MySQLLoader.buildCreateSchemaStatement()
          Return a statement that will create the schema, null if no create schema can be given
protected  java.lang.String JdbcLoader.buildCreateSchemaStatement()
          Return a statement that will create the schema, null if no create schema can be given
protected  java.lang.String MySQLLoader.buildCreateTableStatement()
          Return a statement that will create the table structure, null if no create table can be given
protected  java.lang.String JdbcLoader.buildCreateTableStatement()
          Return a statement that will create the table structure, null if no create table can be given
 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.
 DBMSEvent JdbcLoader.extract()
          Extract a THL event up to getChunkSize() rows Extract the next available DBMSEvent from the database log.
 DBMSEvent CSVLoader.extract()
          Extract the next available DBMSEvent from the CSV file
 DBMSEvent JdbcLoader.extract(java.lang.String eventId)
           
 DBMSEvent CSVLoader.extract(java.lang.String eventId)
          Extract starting after the event ID provided as an argument.
 java.lang.String MySQLLoader.getCurrentResourceEventId()
          Use the output of SHOW MASTER STATUS to get the extractor Event ID Parse the value of tungstenServiceSchemaPosition for the current eventId
 java.lang.String JdbcLoader.getCurrentResourceEventId()
          Parse the value of tungstenServiceSchemaPosition for the current eventId
 java.lang.String CSVLoader.getCurrentResourceEventId()
          Returns the last event ID committed in the database from which we are extracting.
protected  java.lang.String CSVLoader.getDefaultSchema()
          Return the schema to use in the THL events
protected  DBMSEvent Loader.getFinishLoadEvent()
          Build an event that includes the heartbeat name to indicate that all data has been extracted
protected  void JdbcLoader.nextTable()
          Prepare the next table for extraction by resetting the position and parsing column definitions
protected  void CSVLoader.nextTable()
          Update variables to point to the next table to load values for
 void LoaderCtrl.prepare()
          Connect to the underlying database containing THL.
 void JdbcLoader.prepare(PluginContext context)
           
 void CSVLoader.prepare(PluginContext context)
          Prepare plug-in for use.
protected  void CSVLoader.prepareCurrentTable()
          Open the CSV file containing the values for the current table
protected  void CSVLoader.prepareTableDefinition(java.io.File f)
          Parse the table columns and data types from the table definition file
 void JdbcLoader.release(PluginContext context)
           
 void CSVLoader.release(PluginContext context)
          Release all resources used by plug-in.
 void JdbcLoader.setLastEventId(java.lang.String eventId)
          Prepare to start extraction from the first table found Set the value of the last event ID we have processed.
 void CSVLoader.setLastEventId(java.lang.String eventId)
          Set the value of the last event ID we have processed.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.management
 

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.management
 class ReplicatorStateException
          Defines a non-fatal exception that occurred during replicator state machine processing.
 

Methods in com.continuent.tungsten.replicator.management that throw ReplicatorException
protected  java.lang.String OpenReplicatorManager.assertPropertySet(java.lang.String key)
           
 void OpenReplicatorPlugin.configure(TungstenProperties properties)
          Read configuration data and configure replication behavior appropriately.
protected  void OpenReplicatorManager.doConfigure()
          Process configuration properties and instantiate/configure all plug-ins.
static TungstenProperties OpenReplicatorManager.getConfigurationProperties(java.lang.String serviceName)
           
 void ReplicationServiceManager.go(boolean forceOffline)
          Start replicator services.
protected  OpenReplicatorPlugin OpenReplicatorManager.loadAndConfigurePlugin(java.lang.String prefix, java.lang.String name)
          Generic code to load and configure a plugin.
 void OpenReplicatorPlugin.prepare(OpenReplicatorContext context)
          Prepare plug-in for use.
 void OpenReplicatorPlugin.release()
          Release all resources used by plug-in.
 void OpenReplicatorPlugin.setRole(java.lang.String role, java.lang.String uri)
          Sets the replicator role.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.management.script
 

Methods in com.continuent.tungsten.replicator.management.script that throw ReplicatorException
 void ScriptPlugin.configure(TungstenProperties properties)
          Read configuration data and configure replication behavior appropriately.
 void ScriptPlugin.prepare(OpenReplicatorContext context)
          Prepare plug-in for use.
 void ScriptPlugin.release()
          Release all resources used by plug-in.
 void ScriptPlugin.setRole(java.lang.String role, java.lang.String uri)
          Sets the replicator role.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.management.tungsten
 

Methods in com.continuent.tungsten.replicator.management.tungsten that throw ReplicatorException
 void TungstenPlugin.configure(TungstenProperties properties)
          Read configuration data and configure replication behavior appropriately.
 void TungstenPlugin.prepare(OpenReplicatorContext context)
          Set event dispatcher and instantiate the Tungsten monitor.
 void TungstenPlugin.release()
          Deallocate all resources.
 void TungstenPlugin.setRole(java.lang.String role, java.lang.String uri)
          Sets the replicator role.
 

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

Methods in com.continuent.tungsten.replicator.pipeline that throw ReplicatorException
 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.
 java.util.concurrent.Future<ReplDBMSHeader> Pipeline.flush()
          Find the current native event ID in the DBMS and wait until it reaches the log.
 long Pipeline.getMaxCommittedSeqno()
          getMaxCommittedSeqno returns the max committed sequence number from all the stores.
 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 Stage.release(PluginContext context)
          Release all resources used by plug-in.
 java.util.concurrent.Future<Pipeline> Pipeline.shutdownAfterEventId(java.lang.String eventId)
          Shuts down after a particular event ID is applied.
 java.util.concurrent.Future<Pipeline> Pipeline.shutdownAfterHeartbeat(java.lang.String name)
          Shuts down after a heartbeat event is seen.
 java.util.concurrent.Future<Pipeline> Pipeline.shutdownAfterSequenceNumber(long seqno)
          Shuts down after a particular sequence number is applied.
 java.util.concurrent.Future<Pipeline> Pipeline.shutdownAfterTimestamp(java.sql.Timestamp timestamp)
          Shuts down after the replication event timestamp meets or exceeds the argument.
 void Pipeline.start(com.continuent.tungsten.fsm.event.EventDispatcher eventDispatcher)
          Start pipeline operation.
 void StageTaskGroup.start(com.continuent.tungsten.fsm.event.EventDispatcher dispatcher)
          Start all tasks in the group.
 void Stage.start(com.continuent.tungsten.fsm.event.EventDispatcher dispatcher)
          Start task thread(s) that implement this stage.
 

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

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.plugin
 class PluginException
          This class defines a PluginException
 

Methods in com.continuent.tungsten.replicator.plugin that throw ReplicatorException
 void ReplicatorPlugin.configure(PluginContext context)
          Complete plug-in configuration.
static java.lang.Object PluginConfigurator.getParameter(ReplicatorPlugin plugin, java.lang.String name)
          Call getter method for given replicator plugin.
 ReplicatorPlugin PluginSpecification.instantiate(int id)
          Instantiate the plugin and assign properties.
static ReplicatorPlugin PluginLoader.load(java.lang.String name)
          Load plugin implementation.
static java.lang.Class<?> PluginLoader.loadClass(java.lang.String name)
          Load plugin class.
 void ReplicatorPlugin.prepare(PluginContext context)
          Prepare plug-in for use.
 void ReplicatorPlugin.release(PluginContext context)
          Release all resources used by plug-in.
static void PluginConfigurator.setParameter(ReplicatorPlugin plugin, java.lang.String name, java.lang.Object value)
          Call setter method for given ReplicatorPlugin.
 void ShutdownHook.shutdown(PluginContext context)
          Shut down component.
 

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

Methods in com.continuent.tungsten.replicator.prefetch that throw ReplicatorException
 void PrefetchApplier.apply(DBMSEvent event, ReplDBMSHeader header, boolean doCommit, boolean doRollback)
          Apply the proffered event to the replication target.
 void PrefetchApplier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 void PrefetchStore.configure(PluginContext context)
          Complete plug-in configuration.
 void PrefetchApplier.configure(PluginContext context)
          Complete plug-in configuration.
 ReplDBMSEvent PrefetchStore.filter(ReplDBMSEvent event)
          Filter the event if it has already been executed.
 ReplDBMSHeader PrefetchApplier.getLastEvent()
          Return header information corresponding to last committed event.
 java.lang.Object KeySelect.getValue(java.lang.String colName)
          Gets a column value by name.
 void PrefetchStore.prepare(PluginContext context)
          Prepare prefetch store.
 void PrefetchApplier.prepare(PluginContext context)
          Prepare plug-in for use.
 void PrefetchStore.put(ReplDBMSEvent event)
          Puts an event in the queue, blocking if it is full.
 void PrefetchStore.release(PluginContext context)
          Release queue.
 void PrefetchApplier.release(PluginContext context)
          Release all resources used by plug-in.
 void KeySelect.setValue(int index, java.lang.Object value)
          Sets a column value for the select.
 void KeySelect.setValue(java.lang.String colName, java.lang.Object value)
          Sets a column value for the select.
 

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

Methods in com.continuent.tungsten.replicator.shard that throw ReplicatorException
 void ShardFilter.configure(PluginContext context)
          Complete plug-in configuration.
 ReplDBMSEvent ShardFilter.filter(ReplDBMSEvent event)
          Filter the event.
 void ShardFilter.prepare(PluginContext context)
          Prepare plug-in for use.
 void ShardFilter.release(PluginContext context)
          Release all resources used by plug-in.
 

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

Methods in com.continuent.tungsten.replicator.storage that throw ReplicatorException
 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 InMemoryMultiQueueApplier.commit()
          This method is meaningless for an in-memory queue, which is non-transactional.
 void InMemoryQueueAdapter.commit()
          This method is meaningless for an in-memory queue, which is non-transactional.
 void InMemoryTransactionalQueueApplier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 void InMemoryTransactionalQueue.commit(int taskId)
          Commits all pending events for a particular task.
 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 CommitAction.execute(int taskId)
          Execute commit action for a particular task ID in a parallel queue.
 ReplDBMSEvent InMemoryQueueAdapter.extract()
          Extract the next available event from the log.
 java.lang.String InMemoryQueueAdapter.getCurrentResourceEventId()
          Returns the last event ID committed in a database from which we are extracting.
 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.
 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 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.
 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.
 void InMemoryQueueAdapter.setLastEvent(ReplDBMSHeader header)
          Store the header so that it can be propagated back through the pipeline for restart.
 void InMemoryQueueAdapter.setLastEventId(java.lang.String eventId)
          Ignored for now as in-memory queues do not extract.
 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.
 

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

Methods in com.continuent.tungsten.replicator.storage.parallel that throw ReplicatorException
 void ParallelQueueApplier.apply(ReplDBMSEvent event, boolean doCommit, boolean doRollback, boolean syncTHL)
          Apply the proffered event to the replication target.
 void ParallelQueueApplier.commit()
          This method is meaningless for an in-memory queue, which is non-transactional.
 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.
 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.
 java.lang.String ParallelQueueExtractor.getCurrentResourceEventId()
          Returns the last event ID committed in a database from which we are extracting.
 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.
static TungstenProperties PartitionerUtility.loadShardProperties(java.io.File shardMap)
          Find and load shard properties.
 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 Partitioner.partition(ReplDBMSHeader event, int taskId)
          Assign an event to a particular partition.
 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.
 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.put(int taskId, ReplDBMSEvent event)
          Puts an event in the queue, blocking if it is full.
 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 ParallelQueueExtractor.setLastEvent(ReplDBMSHeader header)
          Store the header so that it can be propagated back through the pipeline for restart.
 void ParallelQueueExtractor.setLastEventId(java.lang.String eventId)
          Ignored for now as in-memory queues do not extract.
 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.
 

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

Methods in com.continuent.tungsten.replicator.storage.prefetch that throw ReplicatorException
 ReplDBMSEvent PrefetchStore.filter(ReplDBMSEvent event)
          Filter the event if it has already been executed.
 void PrefetchStore.prepare(PluginContext context)
          Prepare prefetch store.
 void PrefetchStore.put(ReplDBMSEvent event)
          Puts an event in the queue, blocking if it is full.
 void PrefetchStore.release(PluginContext context)
          Release queue.
 

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

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.thl
 class THLException
          This class defines a THLException
 

Methods in com.continuent.tungsten.replicator.thl that throw ReplicatorException
 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.
 SeqNoRange Protocol.clientHandshake(long lastEpochNumber, long lastSeqno, int heartbeatMillis, java.lang.String lastEventId)
          Define a client handshake event including attendant information.
 void THLParallelQueueApplier.commit()
          This method is meaningless for an in-memory queue, which is non-transactional.
 void THLStoreApplier.commit()
          Commits current open transaction to ensure data applied up to current point are durable.
 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.connect()
          TODO: connect definition.
 LogConnection THL.connect(boolean readonly)
          Connect to the log.
 void CatalogManager.connect(java.lang.String url, java.lang.String user, java.lang.String password, java.lang.String metadataSchema, java.lang.String vendor)
          Set DBMS connection information.
 void THL.disconnect(LogConnection client)
          Disconnect from the log.
 void CommitSeqnoTable.expandTasks(int channels)
          Copies the single task 0 row left by a clean offline operation to add rows for each task in multi-channel operation.
 ReplEvent THLParallelQueueExtractor.extract()
          Extract the next available event from the log.
 ReplEvent THLStoreExtractor.extract()
          Extract the next available event from the log.
 ReplDBMSEvent RemoteTHLExtractor.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.
 java.util.LinkedList<ConnectorHandler> THL.getClients()
          Returns list of currently connected clients.
 java.lang.String THLParallelQueueExtractor.getCurrentResourceEventId()
          Returns the last event ID committed in a database from which we are extracting.
 java.lang.String THLStoreExtractor.getCurrentResourceEventId()
          Return the event ID for a flush; does not make sense for a store.
 java.lang.String RemoteTHLExtractor.getCurrentResourceEventId()
          Does not make sense for this extractor type.
 THLManagerCtrl.InfoHolder THLManagerCtrl.getInfo()
          Queries THL for summary information.
 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.
 void CommitSeqnoTable.initializeTable(int channels)
          Create the trep_commit_seqno table, if necessary, and ensure the number of channels matches the number of channels.
 void THLManagerCtrl.listEvents(java.lang.Long low, java.lang.Long high, java.lang.Long by, boolean pureSQL, boolean headersOnly, boolean json, java.lang.String charset, boolean hex)
          List THL events within the given range.
 ReplEvent THLParallelQueue.peek(int taskId)
          Returns next event from the queue without removing it, returning null if queue is empty.
 void THLManagerCtrl.prepare(boolean readOnly)
          Connect to the underlying database containing THL.
 void CommitSeqnoTable.prepare(int taskId)
          Prepares the instance for use.
 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 THLManagerCtrl.purgeEvents(java.lang.Long low, java.lang.Long high)
          Purge THL events in the given seqno interval.
 void THLParallelQueue.put(int taskId, ReplDBMSEvent event)
          Puts an event in the queue, blocking if it is full.
protected  ProtocolMessage Protocol.readMessage()
          TODO: readMessage definition.
 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.
 ReplEvent Connector.requestEvent(long seqNo)
          Fetch an event from server.
 ReplEvent Protocol.requestReplEvent(long seqNo)
          TODO: requestReplicationDBMSEvent definition.
 void Protocol.serverHandshake(ProtocolHandshakeResponseValidator validator, long minSeqNo, long maxSeqNo)
          TODO: serverHandshake definition.
 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 THLParallelQueueExtractor.setLastEventId(java.lang.String eventId)
          Ignored for now as in-memory queues do not extract.
 void THLStoreExtractor.setLastEventId(java.lang.String eventId)
          Ignored for now as stores do not extract.
 void RemoteTHLExtractor.setLastEventId(java.lang.String eventId)
          Sets the last event ID for extraction.
 void THLParallelQueue.setLastHeader(int taskId, ReplDBMSHeader header)
          Sets the last header processed.
 void RemoteTHLExtractor.shutdown(PluginContext context)
          Shut down component.
 void THL.updateCommitSeqno(THLEvent thlEvent)
          Updates the sequence number stored in the catalog trep_commit_seqno.
 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.
 void CommitSeqnoTable.validate(int channels)
           
 void ProtocolHandshakeResponseValidator.validateResponse(ProtocolHandshakeResponse handshakeResponse)
          Executes implementation-defined logic to validate the client response.
 ProtocolReplEventRequest Protocol.waitReplEventRequest()
          TODO: waitReplicationDBMSEventRequest definition.
 

Constructors in com.continuent.tungsten.replicator.thl that throw ReplicatorException
CatalogManager(ReplicatorRuntime runtime)
          Creates a new Catalog manager.
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
Server(PluginContext context, AtomicCounter sequencer, THL thl)
          Creates a new Server object
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.thl.log
 

Subclasses of ReplicatorException in com.continuent.tungsten.replicator.thl.log
 class LogConsistencyException
          Denotes an exception due to a consistency problem in the log.
 class LogPositionException
          Denotes an error that occurs due to an invalid position in a log file.
 class LogTimeoutException
          Denotes a timeout while waiting for data to appear in a log file.
 

Methods in com.continuent.tungsten.replicator.thl.log that throw ReplicatorException
 boolean LogEventReadFilter.accept(LogEventReplReader reader)
          Returns true if the reader contains an event that should be deserialized.
 boolean WriteLock.acquire()
          Attempt to acquire write lock.
protected  void LogFile.assertAnyMode()
          Returns only if log file is in read or write mode.
protected  void LogFile.assertReadMode()
          Returns only if log file is in read mode.
protected  void LogFile.assertWriteMode()
          Returns only if log file is in write mode.
 void LogConnection.commit()
          Commit transactions stored in the log.
 LogConnection DiskLog.connect(boolean readonly)
          Creates a new log connection.
 void LogFile.create(long seqno)
          Create a new log file.
 LogCursor LogCursorManager.createAndGetLogCursor(LogConnection client, LogFile logFile, long lastSeqno)
          Sets the log file and last accessed sequence number for this thread.
 void DiskLog.delete(LogConnection client, java.lang.Long low, java.lang.Long high)
          Deletes a portion of the log.
 void LogConnection.delete(java.lang.Long low, java.lang.Long high)
          Delete a range of events from the log.
 THLEvent LogEventReplReader.deserializeEvent()
          Deserialize and return the event.
 void LogFile.flush()
          Synchronizes file writes using flush with optional fsync.
 long LogFile.getLength()
          Returns the length of the file, including any unbuffered writes.
 LogCursor LogCursorManager.getLogCursor(LogConnection client, long nextSeqno)
          Return a cursor to the log file belonging to this client.
 long LogFile.getOffset()
          Returns the current position in the log file.
 THLEvent LogConnection.next()
          Convenience method to return the next event with blocking enabled.
 THLEvent LogConnection.next(boolean block)
          Returns the next event in the log.
 void LogFile.openRead()
          Open the log file for reading.
 void LogFile.openWrite()
          Prepare the log file for writing.
 void DiskLog.prepare()
          Prepare the log for use, which includes ensuring that the log is created automatically on first use and building an index of log file contents.
protected  int LogFile.readInt()
          Read a single integer.
protected  long LogFile.readLong()
          Reads a single long.
 LogRecord LogFile.readRecord(int waitMillis)
          Reads a record from the file into a byte array.
protected  short LogFile.readShort()
          Reads a single short.
 void DiskLog.release()
          Releases the log resources.
 void LogConnection.rollback()
          Rollback transactions stored in the log.
 boolean LogConnection.seek(long seqno)
          Positions cursor on first fragment of a specific event.
 boolean LogConnection.seek(long seqno, short fragno)
          Finds a specific THLEvent and position client cursor on the event.
 boolean LogConnection.seek(java.lang.String name)
          Opens a log file and positions client cursor on the event.
 void LogFile.seekOffset(long offset)
          Seeks to a particular offset in the file.
 void LogFile.setLength(long length)
          Truncate the file to the provided length.
 void LogConnectionManager.store(LogConnection connection)
          Stores a new connection.
 void LogConnection.store(THLEvent event, boolean commit)
          Store a THL event at the end of the log.
 LogRecord LogEventReplWriter.write()
          Write and return the log record.
 LogRecord LogEventRotateWriter.write()
          Write and return the log record.
protected  void LogFile.write(int myInt)
           
protected  void LogFile.write(long seqno)
           
protected  void LogFile.write(short myShort)
           
 boolean LogFile.writeRecord(LogRecord record, int logFileSize)
          Writes a buffer to the log file and returns true if we have exceeded the log file size.
 

Constructors in com.continuent.tungsten.replicator.thl.log that throw ReplicatorException
LogCursorManager()
          Create a new log cursor manager.
LogEventReplReader(LogRecord logRecord, Serializer serializer, boolean checkCRC)
          Instantiate the reader and load header information.
LogEventReplWriter(THLEvent event, Serializer serializer, boolean checkCRC, java.io.File file)
          Instantiate the writer.
LogEventRotateReader(LogRecord logRecord, boolean checkCRC)
          Instantiate the reader and load header information.
LogEventRotateWriter(java.io.File file, long index, boolean checkCRC)
          Instantiate the writer.
LogIndex(java.io.File logDir, java.lang.String filePrefix, long retentionMillis, int bufferSize, boolean isWritable)
          Creates a new in-memory instance on all log files in a particular directory.
WriteLock(java.io.File lockFile)
          Instantiates the write lock instance.
 

Uses of ReplicatorException in com.continuent.tungsten.replicator.thl.serializer
 

Methods in com.continuent.tungsten.replicator.thl.serializer that throw ReplicatorException
 THLEvent JavaSerializer.deserializeEvent(java.io.InputStream inStream)
          Deserializes THLEvent off the stream.
 THLEvent Serializer.deserializeEvent(java.io.InputStream inStream)
           
 

Overview  Package  Class   Use  Tree  Deprecated  Index  Help 
 PREV   NEXT FRAMES    NO FRAMES