Package com.gigaspaces.internal.cluster.node.impl.handlers

Class BlobstorePrimaryBackupSpaceReplicationEntryEventHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

com.gigaspaces.internal.cluster.node.impl.handlers.PrimaryBackupSpaceReplicationEntryEventHandler

com.gigaspaces.internal.cluster.node.impl.handlers.BlobstorePrimaryBackupSpaceReplicationEntryEventHandler

All Implemented Interfaces:

IReplicationInEntryHandler, IReplicationInEvictEntryHandler

public class BlobstorePrimaryBackupSpaceReplicationEntryEventHandler
extends PrimaryBackupSpaceReplicationEntryEventHandler

Since:

11.0.0 Handles incoming blobstore bulks, flushes the previous bulk if a new bulk entry arrived or non bulk entry arrived.

Author:

Boris

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

_engine, _exceptionHandler

Constructor Summary

Constructors

Constructor	Description
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine, boolean isCentralAndExternalDB)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.handlers.PrimaryBackupSpaceReplicationEntryEventHandler

postChangeExecution, postRemoveExecution, postUpdateExecution, shouldChangeEntryInSpace, shouldEvictEntryFromSpace, shouldRemoveEntryFromSpace, shouldUpdateEntryInSpace, updateOrWrite

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

changeEntry, executeUpdateOperation, getConflictingOperationPolicy, ignoreOperation, inEvictEntry, removeEntry, removeEntryByUid, updateEntry, writeEntry

Methods inherited from class com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

inChangeEntry, inRemoveEntry, inRemoveEntryByUID, inUpdateEntry, inWriteEntry

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BlobstorePrimaryBackupSpaceReplicationEntryEventHandler

public BlobstorePrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine,
 boolean isCentralAndExternalDB)

Method Details

writeEntryIntoSpace

protected void writeEntryIntoSpace(IReplicationInContext context,
 Transaction txn,
 IEntryPacket entry,
 long lease,
 boolean twoPhaseCommit)
                            throws Exception

Overrides:

writeEntryIntoSpace in class PrimaryBackupSpaceReplicationEntryEventHandler

Throws:

Exception

afterConsumption

public void afterConsumption(IReplicationInContext context,
 boolean successful,
 long lastProcessedKey)

Flushes the bulk to disk after consuming the replication.

Specified by:

afterConsumption in interface IReplicationInEntryHandler

Overrides:

afterConsumption in class AbstractReplicationEntryEventHandler

beforeConsume

public void beforeConsume(IReplicationInContext context)

Specified by:

beforeConsume in interface IReplicationInEntryHandler

Overrides:

beforeConsume in class AbstractReplicationEntryEventHandler

updateEntryInSpace

protected void updateEntryInSpace(IReplicationInContext context,
 Transaction txn,
 IEntryPacket entry,
 IEntryPacket previousEntry,
 boolean partialUpdate,
 boolean overrideVersion,
 long lease,
 boolean twoPhaseCommit)
                           throws UnusableEntryException,
UnknownTypeException,
TransactionException,
RemoteException

Overrides:

updateEntryInSpace in class PrimaryBackupSpaceReplicationEntryEventHandler

Throws:

UnusableEntryException

UnknownTypeException

TransactionException

RemoteException

changeEntryInSpace

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

Overrides:

changeEntryInSpace in class PrimaryBackupSpaceReplicationEntryEventHandler

Throws:

Exception

removeEntryFromSpace

protected void removeEntryFromSpace(IReplicationInContext context,
 Transaction txn,
 ITemplatePacket template,
 boolean twoPhaseCommit)
                             throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException

Overrides:

removeEntryFromSpace in class PrimaryBackupSpaceReplicationEntryEventHandler

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException