public class BlobstorePrimaryBackupSpaceReplicationEntryEventHandler extends PrimaryBackupSpaceReplicationEntryEventHandler
_engine, _exceptionHandler
Constructor and Description |
---|
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine,
boolean isCentralAndExternalDB) |
Modifier and Type | Method and Description |
---|---|
void |
afterConsumption(IReplicationInContext context,
boolean successful,
long lastProcessedKey)
Flushes the bulk to disk after consuming the replication.
|
void |
beforeConsume(IReplicationInContext context) |
protected void |
changeEntryInSpace(IReplicationInContext context,
Transaction txn,
String uid,
int version,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry,
long timeToLive,
boolean twoPhaseCommit,
String typeName) |
protected void |
removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected void |
writeEntryIntoSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
long lease,
boolean twoPhaseCommit) |
postChangeExecution, postRemoveExecution, postUpdateExecution, shouldChangeEntryInSpace, shouldEvictEntryFromSpace, shouldRemoveEntryFromSpace, shouldUpdateEntryInSpace, updateOrWrite
changeEntry, executeUpdateOperation, getConflictingOperationPolicy, ignoreOperation, inEvictEntry, removeEntry, removeEntryByUid, updateEntry, writeEntry
inChangeEntry, inRemoveEntry, inRemoveEntryByUID, inUpdateEntry, inWriteEntry
public BlobstorePrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine, boolean isCentralAndExternalDB)
protected void writeEntryIntoSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, boolean twoPhaseCommit) throws Exception
writeEntryIntoSpace
in class PrimaryBackupSpaceReplicationEntryEventHandler
Exception
public void afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
afterConsumption
in interface IReplicationInEntryHandler
afterConsumption
in class AbstractReplicationEntryEventHandler
public void beforeConsume(IReplicationInContext context)
beforeConsume
in interface IReplicationInEntryHandler
beforeConsume
in class AbstractReplicationEntryEventHandler
protected void updateEntryInSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit) throws UnusableEntryException, UnknownTypeException, TransactionException, RemoteException
protected void changeEntryInSpace(IReplicationInContext context, Transaction txn, String uid, int version, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry, long timeToLive, boolean twoPhaseCommit, String typeName) throws Exception
changeEntryInSpace
in class PrimaryBackupSpaceReplicationEntryEventHandler
Exception
protected void removeEntryFromSpace(IReplicationInContext context, Transaction txn, ITemplatePacket template, boolean twoPhaseCommit) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException
Copyright © GigaSpaces.