Modifier and Type | Method and Description |
---|---|
protected void |
AbstractLocalClusterReplicationInHandler.handleChangeEntry(String typeName,
String uid,
Object id,
int version,
int previousVersion,
int routingHash,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
IReplicationInBatchContext batchContext) |
protected void |
AbstractLocalClusterReplicationInHandler.handleRemoveEntry(IEntryPacket entryPacket,
IReplicationInBatchContext batchContext) |
protected void |
AbstractLocalClusterReplicationInHandler.handleRemoveEntryByUid(String typeName,
String uid,
IReplicationInBatchContext batchContext) |
protected void |
AbstractLocalClusterReplicationInHandler.handleUpdateEntry(IEntryPacket entryPacket,
IEntryPacket oldEntryPacket,
IReplicationInBatchContext batchContext,
boolean partialUpdate) |
protected void |
AbstractLocalClusterReplicationInHandler.handleWriteEntry(IEntryPacket entryPacket,
IReplicationInBatchContext batchContext) |
Modifier and Type | Method and Description |
---|---|
protected ExtendedAnswerHolder |
AbstractSpaceReplicationEntryEventHandler.executeUpdateOperation(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit,
int updateModifiers) |
protected ExtendedAnswerHolder |
PrimaryBackupSpaceReplicationEvictionProtectionEntryEventHandler.executeUpdateOperation(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit,
int updateModifiers) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected abstract ExtendedAnswerHolder |
AbstractSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
long lease,
int modifiers) |
protected ExtendedAnswerHolder |
ActiveActiveSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction transaction,
IEntryPacket entryPacket,
long lease,
int updateModifiers) |
protected ExtendedAnswerHolder |
PrimaryBackupSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction transaction,
IEntryPacket entryPacket,
long lease,
int updateModifiers) |
Constructor and Description |
---|
UnknownTypeConsumeResult(String unknownTypeClassName,
UnknownTypeException exception) |
Modifier and Type | Method and Description |
---|---|
Object |
SpaceImpl.asyncRead(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers,
IFuture result) |
ExtendedAnswerHolder |
SpaceEngine.change(ITemplatePacket template,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
Collection<SpaceEntryMutator> mutators,
int operationModifiers,
boolean returnOnlyUid)
perform an update in place using mutators
|
Pair<Integer,SingleExplainPlan> |
SpaceImpl.clear(ITemplatePacket template,
Transaction txn,
int modifiers,
SpaceContext sc) |
Pair<Integer,SingleExplainPlan> |
SpaceEngine.clear(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int operationModifiers) |
Pair<Integer,SingleExplainPlan> |
SpaceEngine.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int operationModifiers) |
Pair<Integer,SingleExplainPlan> |
SpaceImpl.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int modifiers) |
AnswerHolder |
SpaceEngine.newUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long[] leases,
SpaceContext sc,
long timeout,
int operationModifiers)
perform update of multiple entries.
|
GSEventRegistration |
SpaceEngine.notify(ITemplatePacket template,
long lease,
boolean fromReplication,
String templateUid,
SpaceContext sc,
NotifyInfo info) |
GSEventRegistration |
SpaceImpl.notify(ITemplatePacket template,
Transaction txn,
long lease,
SpaceContext sc,
NotifyInfo info) |
AnswerPacket |
SpaceImpl.read(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
AnswerHolder |
SpaceEngine.read(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
SpaceContext sc,
boolean returnOnlyUid,
boolean fromReplication,
boolean origin,
int operationModifiers) |
IEntryPacket[] |
SpaceImpl.readByIds(ITemplatePacket template,
Transaction txn,
boolean take,
SpaceContext spaceContext,
int modifiers) |
IEntryPacket[] |
SpaceImpl.readMultiple(ITemplatePacket template,
Transaction txn,
boolean take,
int maxEntries,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
AnswerHolder |
SpaceImpl.readMultiple(ITemplatePacket template,
Transaction txn,
boolean take,
int maxEntries,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers,
int minEntries,
long timeout,
boolean isIfExist) |
AnswerHolder |
SpaceEngine.readMultiple(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
SpaceContext sc,
boolean returnOnlyUid,
int operationModifiers,
BatchQueryOperationContext batchOperationContext,
List<SpaceEntriesAggregator> aggregators) |
AnswerHolder |
SpaceImpl.readNew(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
void |
SpaceEngine.registerLocalView(ITemplatePacket[] queryPackets,
Collection<SpaceQueryDetails> queryDescriptions,
RouterStubHolder viewStub,
int batchSize,
long batchTimeout,
SpaceContext spaceContext) |
ExtendedAnswerHolder |
SpaceEngine.update(IEntryPacket updated_entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
boolean newRouter,
int modifiers)
perform an update operation- make it atomic NOTE- returnonlyUID is ignored
|
ExtendedAnswerHolder |
SpaceEngine.update(IEntryPacket updated_entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
boolean newRouter,
int modifiers,
MultipleIdsContext multipleIdsContext) |
AnswerPacket |
SpaceImpl.update(IEntryPacket entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
int modifiers,
boolean newRouter) |
Object[] |
SpaceEngine.updateMultiple(IEntryPacket[] entries,
Transaction txn,
long[] leases,
SpaceContext sc,
int operationModifiers,
boolean newRouter)
perform update of multiple entries.
|
ExtendedAnswerHolder |
SpaceEngine.updateOrWrite(UpdateOrWriteContext ctx,
boolean newRouter) |
ExtendedAnswerHolder |
SpaceEngine.updateOrWrite(UpdateOrWriteContext ctx,
boolean fromReplication,
boolean origin,
boolean newRouter) |
WriteEntryResult |
SpaceEngine.write(IEntryPacket entryPacket,
Transaction txn,
long lease,
int modifiers,
boolean fromReplication,
boolean origin,
SpaceContext sc)
Creates an IEntryHolder object from the specified entry packet and inserts it into all
relevant engine tables.
|
WriteEntryResult |
SpaceImpl.write(IEntryPacket entry,
Transaction txn,
long lease,
int modifiers,
boolean fromReplication,
SpaceContext sc) |
Modifier and Type | Method and Description |
---|---|
IServerTypeDesc |
SpaceTypeManager.getTypeDescriptorByObject(Object obj,
ObjectType objectType) |
IServerTypeDesc |
SpaceTypeManager.loadServerTypeDesc(ITransportPacket packet) |
Modifier and Type | Method and Description |
---|---|
void |
MirrorReplicationInHandler.addChangeEntry(IReplicationInBatchContext context,
String typeName,
String uid,
Object id,
int version,
long timeToLive,
Collection<SpaceEntryMutator> mutators) |
void |
MirrorReplicationInHandler.changeEntry(IReplicationInBatchContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
IEntryPacket |
EntryAdapter.toEntry(Object object)
Converts given object to IGSEntry
|
IEntryPacket |
EntryAdapter.toEntry(Object key,
Object value)
Convert key value to entry
|
I |
IDataConverter.toInternal(Object obj)
Converts to internal representation
|
IEntryPacket |
EntryPacketDataConverter.toInternal(Object obj) |
Copyright © GigaSpaces.