com.gigaspaces.internal.cluster.node.impl

Class AbstractReplicationInBatchContext

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.ReplicationInContext

com.gigaspaces.internal.cluster.node.impl.AbstractReplicationInBatchContext

All Implemented Interfaces:

IReplicationInBatchContext, IReplicationInContext

Direct Known Subclasses:

GlobalOrderReplicationInBatchContext, MultiSourceSingleFileReplicationInBatchContext

public abstract class AbstractReplicationInBatchContext
extends ReplicationInContext
implements IReplicationInBatchContext

Since:

9.1

Author:

idan

Constructor Summary

Constructors

Constructor and Description
AbstractReplicationInBatchContext(Logger contextLogger, int entireBatchSize, String sourceLookupName, String groupName, boolean supportDistTransactionConsolidation)

Method Summary

Modifier and Type	Method and Description
<T> void	addPendingContext(T operationContext)
protected abstract void	afterBatchConsumed(long lastProcessedKeyInBatch)
void	currentConsumed()
long	getCurrentKey()
int	getEntireBatchSize()
<T> List<T>	getPendingContext()
<T> T	getTagObject()
boolean	isBatchContext()
void	pendingConsumed() Should be called once all the pending operation that are kept in the context are consumed and considered successfully replicated.
void	rollback()
void	setCurrentKey(long currentKey)
<T> void	setTagObject(T tagObject)
void	snapshot()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.ReplicationInContext

getContentContext, getContextLogger, getContextMarker, getGroupName, getLastProcessedKey, getReplicationBlobstoreBulkContext, getSourceLookupName, setContextPacket, setLastProcessedKey, setReplicationBlobstoreBulkContext, supportsDistributedTransactionConsolidation

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.cluster.node.IReplicationInContext

getContentContext, getContextLogger, getContextMarker, getGroupName, getLastProcessedKey, getReplicationBlobstoreBulkContext, getSourceLookupName, setReplicationBlobstoreBulkContext, supportsDistributedTransactionConsolidation

Constructor Detail

AbstractReplicationInBatchContext

public AbstractReplicationInBatchContext(Logger contextLogger,
                                         int entireBatchSize,
                                         String sourceLookupName,
                                         String groupName,
                                         boolean supportDistTransactionConsolidation)

Method Detail

pendingConsumed

public void pendingConsumed()

Description copied from interface: IReplicationInBatchContext

Should be called once all the pending operation that are kept in the context are consumed and considered successfully replicated. once called all the pending operations that are kept in the context are cleared

Specified by:

pendingConsumed in interface IReplicationInBatchContext

addPendingContext

public <T> void addPendingContext(T operationContext)

Specified by:

addPendingContext in interface IReplicationInBatchContext

getPendingContext

public <T> List<T> getPendingContext()

Specified by:

getPendingContext in interface IReplicationInBatchContext

setCurrentKey

public void setCurrentKey(long currentKey)

currentConsumed

public void currentConsumed()

Specified by:

currentConsumed in interface IReplicationInBatchContext

afterBatchConsumed

protected abstract void afterBatchConsumed(long lastProcessedKeyInBatch)

setTagObject

public <T> void setTagObject(T tagObject)

Specified by:

setTagObject in interface IReplicationInBatchContext

getTagObject

public <T> T getTagObject()

Specified by:

getTagObject in interface IReplicationInBatchContext

getEntireBatchSize

public int getEntireBatchSize()

Specified by:

getEntireBatchSize in interface IReplicationInBatchContext

getCurrentKey

public long getCurrentKey()

snapshot

public void snapshot()

rollback

public void rollback()

isBatchContext

public boolean isBatchContext()

Specified by:

isBatchContext in interface IReplicationInContext

Overrides:

isBatchContext in class ReplicationInContext