public class LogChangeReader extends java.lang.Object implements ChangeReader
Modifier and Type | Class and Description |
---|---|
class |
LogChangeReader.DbInfo |
class |
LogChangeReader.JEChange |
class |
LogChangeReader.JEChangeTxn |
(package private) class |
LogChangeReader.LogChangeIterator |
ChangeReader.Change, ChangeReader.ChangeTxn, ChangeReader.ChangeType
Modifier and Type | Field and Description |
---|---|
static LogEntryType[] |
targetTypes |
Constructor and Description |
---|
LogChangeReader(Environment env,
java.lang.String dataSetName,
SyncProcessor processor,
boolean consolidateTransactions,
long consolidateMaxMemory) |
Modifier and Type | Method and Description |
---|---|
void |
discardChanges(Transaction txn)
Called when the changes in all transactions returned by the
getChangeTxns iterator have been transferred to the external system, and
they can be discarded locally.
|
LogChangeSet |
getChangeSet() |
java.util.Iterator<ChangeReader.ChangeTxn> |
getChangeTxns()
Returns an iterator over all transactions containing changes for one of
the data sets of interest (specified by SyncProcessor.getChangeSet and
indirectly by SyncProcessor.sync or syncAll).
|
java.util.Map<DatabaseId,LogChangeReader.DbInfo> |
getSyncDbs() |
void |
setWaitHook(TestHook waitHook) |
public static final LogEntryType[] targetTypes
public LogChangeReader(Environment env, java.lang.String dataSetName, SyncProcessor processor, boolean consolidateTransactions, long consolidateMaxMemory)
public java.util.Map<DatabaseId,LogChangeReader.DbInfo> getSyncDbs()
public LogChangeSet getChangeSet()
public java.util.Iterator<ChangeReader.ChangeTxn> getChangeTxns()
ChangeReader
If a single transaction applies to more than one change set, a separate transaction will be returned by the iterator.
If this method is called more than once for a given change set, the information returned may be different each time, because changes may be discarded by ChangeTxn.discardChanges and additional changes may appear as they are being written.
getChangeTxns
in interface ChangeReader
public void setWaitHook(TestHook waitHook)
public void discardChanges(Transaction txn)
ChangeReader
The changes will not be discarded until the given txn has been committed. By using an XA transaction, the changes can be discarded locally only if they are also committed in the external system.
discardChanges
in interface ChangeReader
Copyright (c) 2004-2012 Oracle. All rights reserved.