public class DataTypeAddIndexPacketData extends AbstractReplicationPacketSingleEntryData
AbstractReplicationPacketSingleEntryData.SingleEntryIterator, AbstractReplicationPacketSingleEntryData.SingleFilterIterable
Constructor and Description |
---|
DataTypeAddIndexPacketData() |
DataTypeAddIndexPacketData(AddTypeIndexesRequestInfo addIndexRequestInfo,
boolean fromGateway) |
Modifier and Type | Method and Description |
---|---|
boolean |
beforeDelayedReplication()
If the replication of this packet is delayed due to being asynchronous by nature or the
target was disconnected when the replication packet was generated, this method is called
before the actual replication and the implementor can modify the packet accordingly, mostly
relevant for time to live update.
|
boolean |
containsFullEntryData() |
void |
execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
boolean |
filterIfNotPresentInReplicaState() |
IEntryData |
getMainEntryData() |
String |
getMainTypeName() |
ReplicationSingleOperationType |
getOperationType() |
int |
getOrderCode() |
IEntryData |
getSecondaryEntryData() |
String |
getUid() |
boolean |
isTransient() |
void |
readExternal(ObjectInput in) |
void |
readFromSwap(ObjectInput in) |
boolean |
requiresRecoveryDuplicationProtection() |
boolean |
supportsReplicationFilter() |
protected IReplicationFilterEntry |
toFilterEntry(SpaceTypeManager spaceTypeManager) |
String |
toString() |
void |
writeExternal(ObjectOutput out) |
void |
writeToSwap(ObjectOutput out) |
add, addAll, clear, clone, contains, containsAll, createEmptyMultipleEntryData, deserializeEntryData, getBlobstoreBulkId, getCustomContent, getMultipleOperationType, getOperationId, getRecoveryFilteringId, getSingleEntryData, getWeight, isEmpty, isFromGateway, isMultiParticipantData, isPartOfBlobstoreBulk, isSingleEntryData, iterator, remove, removeAll, requiresRecoveryFiltering, retainAll, serializeEntryData, setBlobstoreBulkId, setWeight, size, toArray, toArray, toFilterEntries, updateTimeToLiveIfNeeded
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
equals, hashCode, parallelStream, removeIf, spliterator, stream
public DataTypeAddIndexPacketData()
public DataTypeAddIndexPacketData(AddTypeIndexesRequestInfo addIndexRequestInfo, boolean fromGateway)
public ReplicationSingleOperationType getOperationType()
public void execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator) throws Exception
Exception
public boolean beforeDelayedReplication()
IReplicationPacketData
public boolean supportsReplicationFilter()
supportsReplicationFilter
in interface IReplicationPacketData<IReplicationPacketEntryData>
supportsReplicationFilter
in class AbstractReplicationPacketSingleEntryData
public boolean requiresRecoveryDuplicationProtection()
requiresRecoveryDuplicationProtection
in interface IReplicationPacketEntryData
requiresRecoveryDuplicationProtection
in class AbstractReplicationPacketSingleEntryData
public IEntryData getMainEntryData()
getMainEntryData
in class AbstractReplicationPacketSingleEntryData
public IEntryData getSecondaryEntryData()
getSecondaryEntryData
in class AbstractReplicationPacketSingleEntryData
public String getMainTypeName()
getMainTypeName
in class AbstractReplicationPacketSingleEntryData
protected IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)
toFilterEntry
in class AbstractReplicationPacketSingleEntryData
public String getUid()
public int getOrderCode()
public boolean isTransient()
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class AbstractReplicationPacketSingleEntryData
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class AbstractReplicationPacketSingleEntryData
IOException
ClassNotFoundException
public void writeToSwap(ObjectOutput out) throws IOException
writeToSwap
in interface ISwapExternalizable
writeToSwap
in class AbstractReplicationPacketSingleEntryData
IOException
public void readFromSwap(ObjectInput in) throws IOException, ClassNotFoundException
readFromSwap
in interface ISwapExternalizable
readFromSwap
in class AbstractReplicationPacketSingleEntryData
IOException
ClassNotFoundException
public boolean filterIfNotPresentInReplicaState()
public boolean containsFullEntryData()
Copyright © GigaSpaces.