Modifier and Type | Method and Description |
---|---|
void |
LocalViewReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry) |
Modifier and Type | Method and Description |
---|---|
IEntryData |
ReplicationInContentContext.getMainEntryData() |
IEntryData |
ReplicationInContentContext.getSecondaryEntryData() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationInContentContext.setMainEntryData(IEntryData entryData) |
void |
ReplicationInContentContext.setSecondaryEntryData(IEntryData entryData) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
Modifier and Type | Method and Description |
---|---|
IEntryData |
DataTypeDropPacketData.getMainEntryData() |
IEntryData |
DataTypeAddIndexPacketData.getMainEntryData() |
IEntryData |
DataTypeIntroducePacketData.getMainEntryData() |
IEntryData |
ReplicationOutContext.getPreviousUpdatedEntryData() |
IEntryData |
DataTypeDropPacketData.getSecondaryEntryData() |
IEntryData |
DataTypeAddIndexPacketData.getSecondaryEntryData() |
IEntryData |
DataTypeIntroducePacketData.getSecondaryEntryData() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationOutContext.setPreviousUpdatedEntryData(IEntryData PreviousUpdatedEntryData) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSpaceReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry) |
void |
SpaceReplicationTransactionEventHandler.changeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
protected void |
AbstractSpaceReplicationEntryEventHandler.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 |
PrimaryBackupSpaceReplicationEntryEventHandler.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 |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.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 |
AbstractSpaceReplicationEntryEventHandler.postChangeExecution(IReplicationInContext context,
IEntryData previousEntryData,
IEntryData modifiedEntryData) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.postChangeExecution(IReplicationInContext context,
IEntryData previousEntryData,
IEntryData modifiedEntryData) |
protected void |
AbstractSpaceReplicationEntryEventHandler.postUpdateExecution(IReplicationInContext context,
IEntryData previousEntryData,
IEntryData currentEntryData) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.postUpdateExecution(IReplicationInContext context,
IEntryData previousEntryData,
IEntryData currentEntryData) |
Constructor and Description |
---|
NotificationReplicationSpaceFilterEntry(IEntryData currentEntryData,
IEntryData previousEntryData,
String uid,
boolean isTransient) |
NotificationReplicationSpaceFilterEntry(IEntryData entryData,
String uid,
boolean isTransient) |
Modifier and Type | Method and Description |
---|---|
IEntryData |
ReplicationEntryDataConversionMetadata.getEntryData() |
IEntryData |
DiscardReplicationPacketData.getMainEntryData() |
IEntryData |
IReplicationPacketEntryDataContentExtractor.getMainEntryData(IReplicationPacketEntryData data) |
IEntryData |
ReplicationPacketDataProducer.getMainEntryData(IReplicationPacketEntryData data) |
IEntryData |
DiscardReplicationPacketData.getSecondaryEntryData() |
IEntryData |
IReplicationPacketEntryDataContentExtractor.getSecondaryEntryData(IReplicationPacketEntryData data) |
IEntryData |
ReplicationPacketDataProducer.getSecondaryEntryData(IReplicationPacketEntryData data) |
Modifier and Type | Method and Description |
---|---|
void |
ITransactionalExecutionCallback.changeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
ReplicationEntryDataConversionMetadata |
ReplicationEntryDataConversionMetadata.entryData(IEntryData entryData) |
Modifier and Type | Field and Description |
---|---|
protected IEntryData |
UpdateReplicationPacketData._currentEntryData |
protected IEntryData |
SingleUidReplicationPacketData._entryData |
protected IEntryData |
UpdateReplicationPacketData._previousEntryData |
Modifier and Type | Method and Description |
---|---|
protected IEntryData |
AbstractReplicationPacketSingleEntryData.deserializeEntryData(ObjectInput in) |
abstract IEntryData |
AbstractReplicationPacketSingleEntryData.getMainEntryData() |
IEntryData |
RemoveReplicationPacketData.getMainEntryData() |
IEntryData |
UpdateReplicationPacketData.getMainEntryData() |
IEntryData |
SingleUidReplicationPacketData.getMainEntryData() |
IEntryData |
SingleReplicationPacketData.getMainEntryData() |
IEntryData |
UpdateReplicationPacketData.getPreviousEntryData() |
abstract IEntryData |
AbstractReplicationPacketSingleEntryData.getSecondaryEntryData() |
IEntryData |
UpdateReplicationPacketData.getSecondaryEntryData() |
IEntryData |
SingleUidReplicationPacketData.getSecondaryEntryData() |
IEntryData |
ChangeReplicationPacketData.getSecondaryEntryData() |
IEntryData |
SingleReplicationPacketData.getSecondaryEntryData() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractReplicationPacketSingleEntryData.serializeEntryData(IEntryData entryData,
ObjectOutput out) |
Constructor and Description |
---|
CancelLeaseReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID,
int routingHash,
boolean isFromGateway) |
ChangeReplicationPacketData(String typeName,
String uid,
Object id,
int version,
int previousVersion,
boolean isTransient,
IEntryData entryData,
OperationID operationID,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
IEntryData previousEntryData,
long timeToLive,
long expirationTime,
boolean fromGateway) |
EntryLeaseExpiredReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID) |
EvictReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID) |
ExtendEntryLeaseReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
long expirationTime,
long leaseTime,
OperationID operationID,
int routingHash,
boolean isFromGateway) |
ExtendNotifyTemplateLeaseReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
long expirationTime,
long leaseTime,
int objectType,
NotifyInfo notifyInfo,
OperationID operationID) |
NotifyTemplateLeaseExpiredReplicationPacketData(String className,
String uid,
IEntryData entryData,
OperationID operationID) |
PartialUpdateReplicationPacketData(IEntryPacket entry,
boolean fromGateway,
boolean overrideVersion,
IEntryData previousEntryData,
long expertaionTime,
IEntryData currentEntryData) |
RemoveByUIDReplicationPacketData(String typeName,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID,
boolean fromGateway) |
RemoveNotifyTemplateReplicationPacketData(String className,
NotifyInfo notifyInfo,
int objectType,
String templateUid,
boolean isTransient,
IEntryData entryData,
OperationID operationID) |
RemoveReplicationPacketData(IEntryPacket entry,
boolean fromGateway,
IEntryData entryData,
boolean fullEntryPacket) |
RemoveReplicationPacketData(IEntryPacket entry,
boolean fromGateway,
IEntryData entryData,
boolean fullEntryPacket,
boolean backupOnly) |
SingleUidReplicationPacketData(String uid,
OperationID operationID,
boolean isTransient,
boolean fromGateway,
IEntryData entryData) |
UpdateReplicationPacketData(IEntryPacket entry,
boolean fromGateway,
boolean overrideVersion,
IEntryData previousEntryData,
short flags,
long expirationTime,
IEntryData currentEntryData) |
Modifier and Type | Class and Description |
---|---|
class |
EntryPacketServerEntryAdapter |
Modifier and Type | Method and Description |
---|---|
void |
EntryHolderAggregatorContext.scan(Context context,
IEntryData entryData,
String uid,
boolean isTransient) |
Modifier and Type | Method and Description |
---|---|
boolean |
AllPredicate.evaluate(IEntryData entryData) |
boolean |
CriteriaRangePredicate.evaluate(IEntryData entryData) |
boolean |
TimePredicate.evaluate(IEntryData entryData) |
boolean |
CachePredicate.evaluate(IEntryData entryData) |
boolean |
TransientPredicate.evaluate(IEntryData entryData) |
Modifier and Type | Interface and Description |
---|---|
interface |
IBinaryEntryData |
interface |
ITransactionalEntryData
Contains all the data (mutable) fields of the entry.
|
Modifier and Type | Class and Description |
---|---|
class |
ExternalizableServerEntry |
class |
FlatEntryData |
class |
HybridEntryData |
class |
MutableViewHybridEntryData |
class |
TemplateEntryData |
class |
UserTypeEntryData |
class |
ViewPropertiesEntryData
Helper class for optimizing scanning entry data.
|
Modifier and Type | Field and Description |
---|---|
protected IEntryData |
ViewPropertiesEntryData.entry |
Modifier and Type | Method and Description |
---|---|
IEntryData |
ViewPropertiesEntryData.getEntry() |
IEntryData |
EntryHolder.getEntryData() |
IEntryData |
ISpaceItem.getEntryData() |
IEntryData |
TemplateHolder.getEntryData() |
IEntryData |
ITemplateHolder.getRejectedOperationEntry() |
IEntryData |
TemplateHolder.getRejectedOperationEntry() |
Modifier and Type | Method and Description |
---|---|
ITransactionalEntryData |
FlatEntryData.createCopy(IEntryData newEntryData,
long newExpirationTime) |
ITransactionalEntryData |
HybridEntryData.createCopy(IEntryData newEntryData,
long newExpirationTime) |
ITransactionalEntryData |
ITransactionalEntryData.createCopy(IEntryData newEntryData,
long newExpirationTime) |
ITransactionalEntryData |
UserTypeEntryData.createCopy(IEntryData newEntryData,
long newExpirationTime) |
ITransactionalEntryData |
MutableViewHybridEntryData.createCopy(IEntryData newEntryData,
long newExpirationTime) |
boolean |
ViewPropertiesEntryData.isViewOf(IEntryData entryData) |
void |
EntryHolder.restoreUpdateXtnRollback(IEntryData entryData) |
void |
IEntryHolder.restoreUpdateXtnRollback(IEntryData entryData) |
void |
TemplateHolder.restoreUpdateXtnRollback(IEntryData entryData) |
void |
ITemplateHolder.setRejectedOpOriginalExceptionAndEntry(Throwable cause,
IEntryData rejectedEntry) |
void |
TemplateHolder.setRejectedOpOriginalExceptionAndEntry(Throwable cause,
IEntryData rejectedEntry) |
void |
TemplateEntryData.updateData(IEntryData entryData) |
void |
EntryHolder.updateEntryData(IEntryData newEntryData,
long expirationTime) |
void |
IEntryHolder.updateEntryData(IEntryData newEntryData,
long expirationTime) |
void |
TemplateHolder.updateEntryData(IEntryData newEntryData,
long expirationTime) |
void |
ViewPropertiesEntryData.view(IEntryData entryData) |
void |
ViewPropertiesEntryData.view(IEntryData entryData,
HybridPropertiesHolder holder) |
Constructor and Description |
---|
ExternalizableServerEntry(IEntryData entry) |
Modifier and Type | Method and Description |
---|---|
void |
PathsProjectionHandler.applyFixedPathsProjections(IEntryData entryData,
Object[] projectedValues) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(Context context,
IEntryHolder entry,
ITemplateHolder template,
IEntryData entryData) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(Context context,
ITemplateHolder template,
IEntryData entryData,
String uid,
boolean isTransient) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryData entryData,
OperationID operationID,
String uid,
boolean isTransient,
QueryResultTypeInternal queryResultType) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryData entryData,
String uid,
OperationID operationId,
boolean isTransient) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
IEntryData entryData,
OperationID operationId) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
IEntryData entryData,
OperationID operationID) |
void |
AbstractProjectionTemplate.filterOutNonProjectionProperties(IEntryData entryData) |
Modifier and Type | Method and Description |
---|---|
IEntryData |
ExtendedAnswerHolder.getModifiedEntryData() |
IEntryData |
ExtendedAnswerHolder.getPreviousEntryData() |
IEntryData |
ExtendedAnswerHolder.getRejectedEntry() |
Modifier and Type | Method and Description |
---|---|
List<IEntryData> |
ExtendedAnswerHolder.getModifiedEntriesData() |
List<IEntryData> |
ExtendedAnswerHolder.getRejectedEntries() |
Modifier and Type | Method and Description |
---|---|
void |
ExtendedAnswerHolder.addModifiedEntriesData(IEntryData changed,
Object uid,
List<Object> changeResultsForEntry) |
void |
ExtendedAnswerHolder.addRejectedEntriesInfo(Throwable t,
IEntryData candidate,
Object uid) |
long |
LeaseManager.getExpirationByTimeRuleOnInitialLoad(IEntryData entry) |
void |
ExtendedAnswerHolder.setModifiedEntryData(IEntryData modifiedEntryData) |
void |
ExtendedAnswerHolder.setPreviousEntryData(IEntryData previousEntryData) |
void |
ExtendedAnswerHolder.setRejectedEntry(IEntryData ed) |
Modifier and Type | Method and Description |
---|---|
int[] |
TypeData.createIndexBackreferenceArray(IEntryCacheInfo pEntry,
IEntryData masterEntryData) |
void |
CacheManager.handleUpdateEntryReplication(Context context,
IEntryHolder new_eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators) |
void |
CacheManager.handleUpdateEntryReplication(Context context,
IEntryHolder new_eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators,
int blobstoreBulkId) |
void |
TypeData.prepareForUpdatingIndexValues(CacheManager cacheManager,
IEntryCacheInfo pEntry,
IEntryData newEntryData)
used only in economy-hash maps
index values are about to be replaced in entryData .
|
void |
TypeData.updateEntryReferences(CacheManager cacheManager,
IEntryHolder eh,
IEntryCacheInfo pEntry,
IEntryData oldEntryData)
update the entry refs in cache.
|
void |
TypeData.updateEntryReferencesUnderXtn(CacheManager cacheManager,
IEntryCacheInfo pEntry,
IEntryData oldEntryData)
update the entry refs in cache when there is an updating xtn, we keep the master entry and
shadow entry as one object pointing at each other so we cant remove the original index
references
|
Modifier and Type | Method and Description |
---|---|
IEntryData |
BlobStoreErrorBulkEntryInfo.getOriginalEntryData() |
Modifier and Type | Method and Description |
---|---|
IEntryData |
DelayedReplicationUpdateInfo.getOriginalData() |
Constructor and Description |
---|
DelayedReplicationUpdateInfo(IEntryHolder new_eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators) |
Modifier and Type | Method and Description |
---|---|
IEntryData |
Context.getCacheViewEntryDataIfNeeded(IEntryData entryData) |
IEntryData |
Context.getOriginalData() |
IEntryData |
Context.getViewEntryData(IEntryData entryData) |
Modifier and Type | Method and Description |
---|---|
void |
Context.cacheViewEntryDataIfNeeded(IEntryData entryData,
IEntryPacket packet) |
IEntryData |
Context.getCacheViewEntryDataIfNeeded(IEntryData entryData) |
IEntryData |
Context.getViewEntryData(IEntryData entryData) |
void |
Context.setBlobStoreOriginalEntryInfo(IEntryData originalData,
short originalBlobStoreVersion) |
void |
Context.setForBulkUpdate(IEntryHolder eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators) |
Modifier and Type | Method and Description |
---|---|
boolean |
Range.evaluatePredicate(IEntryData entryData) |
boolean |
CriteriaRange.evaluatePredicate(IEntryData entryData) |
Copyright © GigaSpaces.