Serialized Form

Package com.continuent.tungsten.common.cluster.resource

Class com.continuent.tungsten.common.cluster.resource.Capabilities extends java.lang.Object implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.cluster.resource.DataServer extends Resource implements Serializable

serialVersionUID: 8153881753668230575L

Serialized Fields

host

java.lang.String host

vendor

java.lang.String vendor

clusterName

java.lang.String clusterName

lastResponseTime

long lastResponseTime

maxResponseTime

long maxResponseTime

minResponseTime

long minResponseTime

Class com.continuent.tungsten.common.cluster.resource.DataSource extends Resource implements Serializable

serialVersionUID: 8153881753668230575L

Serialized Fields

dataServiceName

java.lang.String dataServiceName

The following six properties are the absolute minimum that are required in order to derive a datasource that will work within the rest of the framework. In particular, if 'host' is missing - it refers to the host where the datasource is resident - the framework that associates replicators with datasources will fail to work.

host

java.lang.String host

role

DataSourceRole role

vendor

java.lang.String vendor

driver

java.lang.String driver

url

java.lang.String url

isComposite

boolean isComposite

precedence

int precedence

isAvailable

boolean isAvailable

masterConnectUri

java.lang.String masterConnectUri

state

ResourceState state

alertStatus

DataSourceAlertStatus alertStatus

alertMessage

java.lang.String alertMessage

alertTime

long alertTime

lastError

java.lang.String lastError

lastShunReason

java.lang.String lastShunReason

appliedLatency

double appliedLatency

updateTimestamp

java.util.Date updateTimestamp

lastUpdate

java.util.Date lastUpdate

isStandby

boolean isStandby

isWitness

boolean isWitness

highWater

HighWaterResource highWater

activeConnectionsCount

java.util.concurrent.atomic.AtomicLong activeConnectionsCount

connectionsCreatedCount

java.util.concurrent.atomic.AtomicLong connectionsCreatedCount

statementsCreatedCount

java.util.concurrent.atomic.AtomicLong statementsCreatedCount

preparedStatementsCreatedCount

java.util.concurrent.atomic.AtomicLong preparedStatementsCreatedCount

callableStatementsCreatedCount

java.util.concurrent.atomic.AtomicLong callableStatementsCreatedCount

sequence

Sequence sequence

Represents a single life cycle transition for this datasource. A transition occurs for any update() in which

enabled

java.util.concurrent.atomic.AtomicInteger enabled

vipInterface

java.lang.String vipInterface

VIP management properties

vipAddress

java.lang.String vipAddress

vipIsBound

boolean vipIsBound

activeConnections

java.util.Set<E> activeConnections

Retains all non-closed connections to this data source

Class com.continuent.tungsten.common.cluster.resource.Monitor extends Resource implements Serializable

serialVersionUID: 8153881753668230575L

Serialized Fields

memberName

java.lang.String memberName

clusterName

java.lang.String clusterName

Class com.continuent.tungsten.common.cluster.resource.Queue extends Resource implements Serializable

serialVersionUID: 8153881753668230575L

Serialized Fields

items

java.util.concurrent.LinkedBlockingQueue<E> items

lastItem

java.lang.Object lastItem

Class com.continuent.tungsten.common.cluster.resource.RemoteDataService extends Resource implements Serializable

serialVersionUID: -4287212613595722268L

Serialized Fields

resourceState

ResourceState resourceState

Class com.continuent.tungsten.common.cluster.resource.Replicator extends Resource implements Serializable

serialVersionUID: 1L

Serialized Fields

dataServiceName

java.lang.String dataServiceName

host

java.lang.String host

sourceId

java.lang.String sourceId

vendor

java.lang.String vendor

resourceJdbcDriver

java.lang.String resourceJdbcDriver

resourceJdbcUrl

java.lang.String resourceJdbcUrl

role

java.lang.String role

state

java.lang.String state

isStandbyDataSource

boolean isStandbyDataSource

latestEpochNumber

long latestEpochNumber

appliedLastEventId

java.lang.String appliedLastEventId

appliedLastSeqno

long appliedLastSeqno

appliedLatency

double appliedLatency

vipInterface

java.lang.String vipInterface

vipAddress

java.lang.String vipAddress

masterConnectUri

java.lang.String masterConnectUri

masterListenUri

java.lang.String masterListenUri

Class com.continuent.tungsten.common.cluster.resource.ReplicatorCapabilities extends Capabilities implements Serializable

serialVersionUID: -3752349488516771325L

Serialized Fields

roles

java.util.ArrayList<E> roles

model

java.lang.String model

provisionDriver

java.lang.String provisionDriver

isConsistencyCheck

boolean isConsistencyCheck

isHeartbeat

boolean isHeartbeat

isFlush

boolean isFlush

Class com.continuent.tungsten.common.cluster.resource.Resource extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

java.lang.String name

type

ResourceType type

description

java.lang.String description

isContainer

boolean isContainer

isExecutable

boolean isExecutable

compositeMember

java.lang.Boolean compositeMember

childType

ResourceType childType

Class com.continuent.tungsten.common.cluster.resource.SQLRouter extends Resource implements Serializable

serialVersionUID: 8153881753668230575L

Serialized Fields

port

int port

host

java.lang.String host

role

java.lang.String role

source

java.lang.String source

dataServiceName

java.lang.String dataServiceName

Package com.continuent.tungsten.common.cluster.resource.notification

Class com.continuent.tungsten.common.cluster.resource.notification.ClusterConfigurationNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.cluster.resource.notification.ClusterMemberHeartbeat extends ClusterResourceNotification implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.cluster.resource.notification.ClusterResourceNotification extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

resourceType

ResourceType resourceType

streamID

NotificationStreamID streamID

timeSent

long timeSent

timeReceived

long timeReceived

clusterName

java.lang.String clusterName

memberName

java.lang.String memberName

resourceName

java.lang.String resourceName

resourceState

ResourceState resourceState

notificationSource

java.lang.String notificationSource

resourceProps

TungstenProperties resourceProps

resource

Resource resource

trackerCount

long trackerCount

Class com.continuent.tungsten.common.cluster.resource.notification.ClusterSynchronizationNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: -8510022412295723387L

Class com.continuent.tungsten.common.cluster.resource.notification.DataServerNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: 1L

Serialized Fields

lastException

java.lang.Exception lastException

Class com.continuent.tungsten.common.cluster.resource.notification.DataSourceNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: 1L

Serialized Fields

role

DataSourceRole role

Class com.continuent.tungsten.common.cluster.resource.notification.DirectoryNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: 6671252824107054673L

Class com.continuent.tungsten.common.cluster.resource.notification.HostNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.cluster.resource.notification.ManagerHeartbeat extends ClusterResourceNotification implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.cluster.resource.notification.ManagerNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.cluster.resource.notification.RemoteDataServiceHeartbeatNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: -1140652974780536320L

Class com.continuent.tungsten.common.cluster.resource.notification.ReplicationServiceNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: -2097111546144612171L

Class com.continuent.tungsten.common.cluster.resource.notification.ReplicatorNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: -2097111546144612171L

Class com.continuent.tungsten.common.cluster.resource.notification.SequoiaBackendNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: -3506410692814268800L

Class com.continuent.tungsten.common.cluster.resource.notification.SQLRouterNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: -7101382528522639737L

Class com.continuent.tungsten.common.cluster.resource.notification.UserEventNotification extends ClusterResourceNotification implements Serializable

serialVersionUID: -2097111546144612171L

Package com.continuent.tungsten.common.cluster.resource.physical

Class com.continuent.tungsten.common.cluster.resource.physical.Capabilities extends java.lang.Object implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.cluster.resource.physical.DataSource extends Resource implements Serializable

serialVersionUID: 8153881753668230575L

Serialized Fields

cluster

java.lang.String cluster

The following six properties are the absolute minimum that are required in order to derive a datasource that will work within the rest of the framework. In particular, if 'host' is missing - it refers to the host where the datasource is resident - the framework that associates replicators with datasources will fail to work.

host

java.lang.String host

replicatorHost

java.lang.String replicatorHost

role

DataShardFacetRole role

vendor

java.lang.String vendor

driver

java.lang.String driver

url

java.lang.String url

user

java.lang.String user

password

java.lang.String password

port

int port

logPattern

java.lang.String logPattern

logDir

java.lang.String logDir

diskLogDir

java.lang.String diskLogDir

precedence

int precedence

isAvailable

boolean isAvailable

state

ResourceState state

lastError

java.lang.String lastError

lastShunReason

java.lang.String lastShunReason

appliedLatency

double appliedLatency

sequence

Sequence sequence

Represents a single life cycle transition for this datasource. A transition occurs for any update() in which

enabled

java.util.concurrent.atomic.AtomicInteger enabled

Class com.continuent.tungsten.common.cluster.resource.physical.ReplicatorCapabilities extends Capabilities implements Serializable

serialVersionUID: -3752349488516771325L

Serialized Fields

roles

java.util.ArrayList<E> roles

model

java.lang.String model

provisionDriver

java.lang.String provisionDriver

isConsistencyCheck

boolean isConsistencyCheck

isHeartbeat

boolean isHeartbeat

isFlush

boolean isFlush

Package com.continuent.tungsten.common.config

Class com.continuent.tungsten.common.config.PropertyException extends java.lang.RuntimeException implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.config.TungstenProperties extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

properties

java.util.Map<K,V> properties

sorted

boolean sorted

beanSupportEnabled

boolean beanSupportEnabled

Package com.continuent.tungsten.common.config.cluster

Class com.continuent.tungsten.common.config.cluster.ConfigurationException extends java.lang.Exception implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.csv

Class com.continuent.tungsten.common.csv.CsvException extends java.lang.Exception implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.directory

Class com.continuent.tungsten.common.directory.Directory extends ResourceTree implements Serializable

serialVersionUID: 1L

Serialized Fields

clusterName

java.lang.String clusterName

memberName

java.lang.String memberName

recursive

boolean recursive

absolute

boolean absolute

detailed

boolean detailed

createParents

boolean createParents

sessionsByID

java.util.Map<K,V> sessionsByID

sessionsByDomain

java.util.Map<K,V> sessionsByDomain

systemSessionID

java.lang.String systemSessionID

servicesFolders

java.util.Map<K,V> servicesFolders

currentVersion

java.lang.Long currentVersion

lastMergedVersion

java.lang.Long lastMergedVersion

merging

boolean merging

Class com.continuent.tungsten.common.directory.DirectorySession extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

parent

Directory parent

sessionID

java.lang.String sessionID

currentNode

ResourceNode currentNode

timeCreated

long timeCreated

lastTimeAccessed

long lastTimeAccessed

Class com.continuent.tungsten.common.directory.ResourceNode extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

resource

Resource resource

children

java.util.Map<K,V> children

parent

ResourceNode parent

Class com.continuent.tungsten.common.directory.ResourceTree extends Resource implements Serializable

serialVersionUID: 1L

Serialized Fields

rootNode

ResourceNode rootNode

Package com.continuent.tungsten.common.exception

Class com.continuent.tungsten.common.exception.CLException extends java.lang.Exception implements Serializable

serialVersionUID: -6646383354491312498L

Class com.continuent.tungsten.common.exception.DirectoryException extends java.lang.Exception implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.exception.DirectoryNotFoundException extends java.lang.Exception implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.exception.ResourceException extends java.lang.Exception implements Serializable

serialVersionUID: 6387458316241931596L

Package com.continuent.tungsten.common.exec

Class com.continuent.tungsten.common.exec.ProcessRuntimeException extends java.lang.RuntimeException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.file

Class com.continuent.tungsten.common.file.FileIOException extends java.lang.RuntimeException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.help

Class com.continuent.tungsten.common.help.HelpException extends java.lang.RuntimeException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.jmx

Class com.continuent.tungsten.common.jmx.DynamicMBeanHelper extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

objName

javax.management.ObjectName objName

className

java.lang.String className

info

javax.management.MBeanInfo info

methods

java.util.Map<K,V> methods

Class com.continuent.tungsten.common.jmx.DynamicMBeanOperation extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

java.lang.String name

description

java.lang.String description

usage

java.lang.String usage

signature

java.util.Vector<E> signature

params

java.util.Map<K,V> params

Class com.continuent.tungsten.common.jmx.DynamicMBeanParam extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

java.lang.String name

displayName

java.lang.String displayName

description

java.lang.String description

order

int order

type

java.lang.Class<T> type

Class com.continuent.tungsten.common.jmx.ServerRuntimeException extends java.lang.RuntimeException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.network

Class com.continuent.tungsten.common.network.HostException extends java.lang.Exception implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.patterns.notification

Class com.continuent.tungsten.common.patterns.notification.NotificationGroupMember extends java.lang.Object implements Serializable

serialVersionUID: 2416032277684423671L

Serialized Fields

name

java.lang.String name

host

java.lang.String host

port

int port

Class com.continuent.tungsten.common.patterns.notification.ResourceNotificationException extends java.lang.Exception implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.patterns.notification.adaptor

Class com.continuent.tungsten.common.patterns.notification.adaptor.NotificationAdaptorException extends java.lang.Exception implements Serializable

serialVersionUID: 8339994478408859274L

Package com.continuent.tungsten.common.patterns.order

Class com.continuent.tungsten.common.patterns.order.HighWaterResource extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

highWaterEpoch

long highWaterEpoch

highWaterEventId

java.lang.String highWaterEventId

Class com.continuent.tungsten.common.patterns.order.RingBuffer extends java.lang.Object implements Serializable

serialVersionUID: 4591478646508939995L

Serialized Fields

capacity

int capacity

elements

java.util.ArrayList<E> elements

nextElementIndex

int nextElementIndex

Class com.continuent.tungsten.common.patterns.order.Sequence extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

wrapAround

long wrapAround

generation

long generation

isWrapped

boolean isWrapped

identity

java.util.UUID identity

currentValue

java.util.concurrent.atomic.AtomicLong currentValue

lastValue

java.util.concurrent.atomic.AtomicLong lastValue

Class com.continuent.tungsten.common.patterns.order.SequenceException extends java.lang.Exception implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.sockets

Class com.continuent.tungsten.common.sockets.SocketTerminationException extends java.io.IOException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.common.utils

Class com.continuent.tungsten.common.utils.CLUtils extends java.lang.Object implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.common.utils.HelpMap extends java.util.TreeMap<java.lang.String,HelpItem> implements Serializable

serialVersionUID: 1L

Serialized Fields

category

java.lang.String category

Class com.continuent.tungsten.common.utils.OSCommandResult extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

stdout

java.lang.String stdout

stderr

java.lang.String stderr

exitCode

int exitCode

Class com.continuent.tungsten.common.utils.StatisticsMap extends java.util.TreeMap<java.lang.String,Statistic<?>> implements Serializable

serialVersionUID: 1L

Serialized Fields

name

java.lang.String name

Package com.continuent.tungsten.manager.resource.physical

Class com.continuent.tungsten.manager.resource.physical.Cluster extends Resource implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.manager.resource.physical.ClusterManager extends Resource implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.manager.resource.physical.Operation extends Resource implements Serializable

serialVersionUID: 1L

Serialized Fields

operation

DynamicMBeanOperation operation

Class com.continuent.tungsten.manager.resource.physical.Process extends Resource implements Serializable

serialVersionUID: 1L

Serialized Fields

service

java.lang.String service

port

int port

clusterName

java.lang.String clusterName

member

java.lang.String member

connection

javax.management.remote.JMXConnector connection

server

javax.management.MBeanServerConnection server

epoch

long epoch

Class com.continuent.tungsten.manager.resource.physical.ResourceManager extends Resource implements Serializable

serialVersionUID: 1L

Serialized Fields

manager

DynamicMBeanHelper manager

Package com.continuent.tungsten.manager.resource.shared

Class com.continuent.tungsten.manager.resource.shared.Folder extends Resource implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.manager.resource.shared.ResourceConfiguration extends Resource implements Serializable

serialVersionUID: 1L

Serialized Fields

properties

TungstenProperties properties

Class com.continuent.tungsten.manager.resource.shared.RootResource extends Resource implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.replicator

Class com.continuent.tungsten.replicator.ReplicatorException extends java.lang.Exception implements Serializable

serialVersionUID: -2849591301389282829L

Serialized Fields

originalErrorMessage

java.lang.String originalErrorMessage

extraData

java.lang.String extraData

Class com.continuent.tungsten.replicator.StateChangeNotification extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

prevState

java.lang.String prevState

newState

java.lang.String newState

cause

java.lang.String cause

Package com.continuent.tungsten.replicator.applier

Class com.continuent.tungsten.replicator.applier.ApplierException extends ReplicatorException implements Serializable

serialVersionUID: 8214495751377199032L

Class com.continuent.tungsten.replicator.applier.ApplierStats extends java.lang.Object implements Serializable

serialVersionUID: 288282825L

Serialized Fields

applied

long applied

firstAppliedTime

long firstAppliedTime

lastAppliedTime

long lastAppliedTime

Package com.continuent.tungsten.replicator.backup

Class com.continuent.tungsten.replicator.backup.BackupException extends ReplicatorException implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.replicator.backup.UnsupportedCapabilityException extends ReplicatorException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.replicator.conf

Class com.continuent.tungsten.replicator.conf.MonitorThreadBucket extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

count

int count

value

long value

Class com.continuent.tungsten.replicator.conf.MonitorThreadInfo extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

threadID

long threadID

name

java.lang.String name

cpuTime

long cpuTime

cpuTimes

MonitorThreadBucket[] cpuTimes

realTimes

MonitorThreadBucket[] realTimes

counters

MonitorThreadBucket[] counters

Package com.continuent.tungsten.replicator.consistency

Class com.continuent.tungsten.replicator.consistency.ConsistencyCheckAbstract extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

id

int id

table

Table table

method

java.lang.String method

Class com.continuent.tungsten.replicator.consistency.ConsistencyCheckMD5 extends ConsistencyCheckAbstract implements Serializable

serialVersionUID: 8055678665808795613L

Serialized Fields

usePKForLimit

boolean usePKForLimit

rowFrom

int rowFrom

rowLimit

int rowLimit

checkColumnNames

boolean checkColumnNames

checkColumnTypes

boolean checkColumnTypes

Class com.continuent.tungsten.replicator.consistency.ConsistencyException extends ReplicatorException implements Serializable

serialVersionUID: 6105152751419283356L

Package com.continuent.tungsten.replicator.database

Class com.continuent.tungsten.replicator.database.Column extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

java.lang.String name

type

int type

signed

boolean signed

length

long length

notNull

boolean notNull

value

java.io.Serializable value

valueInputStreamLength

int valueInputStreamLength

position

int position

blob

boolean blob

typeDescription

java.lang.String typeDescription

Class com.continuent.tungsten.replicator.database.DatabaseException extends ReplicatorException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.replicator.dbms

Class com.continuent.tungsten.replicator.dbms.DBMSData extends java.lang.Object implements Serializable

serialVersionUID: -1L

Serialized Fields

options

java.util.List<E> options

Class com.continuent.tungsten.replicator.dbms.LoadDataFileDelete extends DBMSData implements Serializable

serialVersionUID: 1L

Serialized Fields

fileId

int fileId

Class com.continuent.tungsten.replicator.dbms.LoadDataFileFragment extends DBMSData implements Serializable

serialVersionUID: 1L

Serialized Fields

fileId

int fileId

data

byte[] data

defaultSchema

java.lang.String defaultSchema

Class com.continuent.tungsten.replicator.dbms.LoadDataFileQuery extends StatementData implements Serializable

serialVersionUID: 1L

Serialized Fields

fileId

int fileId

filenameStartPos

int filenameStartPos

filenameEndPos

int filenameEndPos

Class com.continuent.tungsten.replicator.dbms.OneRowChange extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

schemaName

java.lang.String schemaName

tableName

java.lang.String tableName

action

RowChangeData.ActionType action

keySpec

java.util.ArrayList<E> keySpec

columnSpec

java.util.ArrayList<E> columnSpec

keyValues

java.util.ArrayList<E> keyValues

columnValues

java.util.ArrayList<E> columnValues

tableId

long tableId

Class com.continuent.tungsten.replicator.dbms.OneRowChange.ColumnSpec extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

index

int index

name

java.lang.String name

type

int type

signed

boolean signed

length

int length

notNull

boolean notNull

blob

boolean blob

typeDescription

java.lang.String typeDescription

Class com.continuent.tungsten.replicator.dbms.OneRowChange.ColumnVal extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

value

java.io.Serializable value

Class com.continuent.tungsten.replicator.dbms.RowChangeData extends DBMSData implements Serializable

serialVersionUID: 1L

Serialized Fields

rowChanges

java.util.ArrayList<E> rowChanges

Class com.continuent.tungsten.replicator.dbms.RowIdData extends DBMSData implements Serializable

serialVersionUID: 1L

Serialized Fields

rowId

long rowId

type

int type

Class com.continuent.tungsten.replicator.dbms.StatementData extends DBMSData implements Serializable

serialVersionUID: 1L

Serialized Fields

defaultSchema

java.lang.String defaultSchema

timestamp

java.lang.Long timestamp

query

java.lang.String query

queryAsBytes

byte[] queryAsBytes

errorCode

int errorCode

Package com.continuent.tungsten.replicator.event

Class com.continuent.tungsten.replicator.event.DBMSEmptyEvent extends DBMSEvent implements Serializable

serialVersionUID: 1300L

Class com.continuent.tungsten.replicator.event.DBMSEvent extends java.lang.Object implements Serializable

serialVersionUID: 1300L

Serialized Fields

id

java.lang.String id

metadata

java.util.LinkedList<E> metadata

data

java.util.ArrayList<E> data

lastFrag

boolean lastFrag

sourceTstamp

java.sql.Timestamp sourceTstamp

options

java.util.LinkedList<E> options

Class com.continuent.tungsten.replicator.event.ReplControlEvent extends ReplEvent implements Serializable

Serialized Fields

eventType

int eventType

seqno

long seqno

header

ReplDBMSHeader header

Class com.continuent.tungsten.replicator.event.ReplDBMSEvent extends ReplEvent implements Serializable

serialVersionUID: 1300L

Serialized Fields

seqno

long seqno

fragno

short fragno

lastFrag

boolean lastFrag

extractedTstamp

java.sql.Timestamp extractedTstamp

sourceId

java.lang.String sourceId

shardId

java.lang.String shardId

epochNumber

long epochNumber

event

DBMSEvent event

Class com.continuent.tungsten.replicator.event.ReplDBMSFilteredEvent extends ReplDBMSEvent implements Serializable

serialVersionUID: 1L

Serialized Fields

seqnoEnd

long seqnoEnd

fragnoEnd

short fragnoEnd

Class com.continuent.tungsten.replicator.event.ReplEvent extends java.lang.Object implements Serializable

serialVersionUID: 1300L

Class com.continuent.tungsten.replicator.event.ReplOption extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

java.lang.String name

value

java.lang.String value

Package com.continuent.tungsten.replicator.extractor

Class com.continuent.tungsten.replicator.extractor.ExtractorException extends ReplicatorException implements Serializable

serialVersionUID: 1L

Serialized Fields

eventId

java.lang.String eventId

Package com.continuent.tungsten.replicator.extractor.mysql

Class com.continuent.tungsten.replicator.extractor.mysql.MySQLExtractException extends ExtractorException implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.replicator.extractor.mysql.SerialBlob extends javax.sql.rowset.serial.SerialBlob implements Serializable

Package com.continuent.tungsten.replicator.extractor.oracle

Class com.continuent.tungsten.replicator.extractor.oracle.OracleExtractException extends ExtractorException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.replicator.management

Class com.continuent.tungsten.replicator.management.ReplicatorStateException extends ReplicatorException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.replicator.plugin

Class com.continuent.tungsten.replicator.plugin.PluginException extends ReplicatorException implements Serializable

serialVersionUID: 1L

Package com.continuent.tungsten.replicator.thl

Class com.continuent.tungsten.replicator.thl.ProtocolHandshake extends ProtocolMessage implements Serializable

serialVersionUID: 234524352L

Serialized Fields

capabilities

java.util.Map<K,V> capabilities

Class com.continuent.tungsten.replicator.thl.ProtocolHandshakeResponse extends ProtocolMessage implements Serializable

serialVersionUID: 123452346L

Serialized Fields

sourceId

java.lang.String sourceId

lastEpochNumber

long lastEpochNumber

lastSeqno

long lastSeqno

heartbeatMillis

int heartbeatMillis

options

java.util.Map<K,V> options

Class com.continuent.tungsten.replicator.thl.ProtocolHeartbeat extends ProtocolMessage implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.replicator.thl.ProtocolMessage extends java.lang.Object implements Serializable

serialVersionUID: 234224352543L

Serialized Fields

payload

java.io.Serializable payload

Class com.continuent.tungsten.replicator.thl.ProtocolNOK extends ProtocolMessage implements Serializable

serialVersionUID: 345634563L

Class com.continuent.tungsten.replicator.thl.ProtocolOK extends ProtocolMessage implements Serializable

serialVersionUID: 34563456345L

Class com.continuent.tungsten.replicator.thl.ProtocolReplEvent extends ProtocolMessage implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.replicator.thl.ProtocolReplEventRequest extends ProtocolMessage implements Serializable

serialVersionUID: 1L

Serialized Fields

seqNo

long seqNo

prefetchRange

long prefetchRange

Class com.continuent.tungsten.replicator.thl.SeqNoRange extends java.lang.Object implements Serializable

serialVersionUID: 345634563456L

Serialized Fields

minSeqNo

long minSeqNo

maxSeqNo

long maxSeqNo

Class com.continuent.tungsten.replicator.thl.THLEvent extends java.lang.Object implements Serializable

serialVersionUID: -1L

Serialized Fields

seqno

long seqno

fragno

short fragno

lastFrag

boolean lastFrag

sourceId

java.lang.String sourceId

type

short type

epochNumber

long epochNumber

sourceTstamp

java.sql.Timestamp sourceTstamp

localEnqueueTstamp

java.sql.Timestamp localEnqueueTstamp

comment

java.lang.String comment

eventId

java.lang.String eventId

shardId

java.lang.String shardId

event

ReplEvent event

Class com.continuent.tungsten.replicator.thl.THLException extends ReplicatorException implements Serializable

serialVersionUID: 23452L

Package com.continuent.tungsten.replicator.thl.log

Class com.continuent.tungsten.replicator.thl.log.LogConsistencyException extends THLException implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.replicator.thl.log.LogPositionException extends THLException implements Serializable

serialVersionUID: 1L

Class com.continuent.tungsten.replicator.thl.log.LogTimeoutException extends THLException implements Serializable

serialVersionUID: 1L