Modifier and Type | Method and Description |
---|---|
ISpaceProxy |
SpaceProxyFactory.createSpaceProxy(String url) |
ISpaceProxy |
SpaceProxyFactory.createSpaceProxy(String name,
boolean isRemote) |
Constructor and Description |
---|
CursorEntryPacketIterator(ISpaceProxy spaceProxy,
Object query,
SpaceIteratorConfiguration spaceIteratorConfiguration) |
SpaceEntryPacketIterator(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int batchSize,
int modifiers) |
SpaceIterator(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
SpaceIteratorConfiguration spaceIteratorConfiguration) |
Modifier and Type | Method and Description |
---|---|
ISpaceProxy |
SpaceIteratorBatchResultProvider.getSpaceProxy() |
Constructor and Description |
---|
SpaceIteratorBatchResultProvider(ISpaceProxy spaceProxy,
int batchSize,
int readModifiers,
ITemplatePacket queryPacket,
UUID uuid,
long maxInactiveDuration) |
SpaceIteratorBatchResultsManager(ISpaceProxy spaceProxy,
int batchSize,
int readModifiers,
ITemplatePacket queryPacket,
long maxInactiveDuration) |
Modifier and Type | Method and Description |
---|---|
UidQueryPacket |
TieredSpaceIteratorResult.buildQueryPacket(ISpaceProxy spaceProxy,
int batchSize,
QueryResultTypeInternal resultType) |
Constructor and Description |
---|
DefaultMessageCleanser(ISpaceProxy gigaSpace) |
GSMessageExecutorImpl(ISpaceProxy gigaSpace) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSpaceCacheContainer |
Modifier and Type | Method and Description |
---|---|
static ISpaceProxy |
SpaceCacheFactory.createSpaceCache(IDirectSpaceProxy remoteSpace,
Properties customProperties,
SpaceURL remoteSpaceUrl) |
ISpaceProxy |
NearCacheSpaceFinderListener.onFindSpace(ISpaceProxy spaceProxy,
SpaceURL spaceURL,
Properties customProperties) |
Modifier and Type | Method and Description |
---|---|
ISpaceProxy |
NearCacheSpaceFinderListener.onFindSpace(ISpaceProxy spaceProxy,
SpaceURL spaceURL,
Properties customProperties) |
Modifier and Type | Class and Description |
---|---|
class |
LocalCacheContainer |
Modifier and Type | Class and Description |
---|---|
class |
LocalViewContainer |
Modifier and Type | Interface and Description |
---|---|
interface |
IDirectSpaceProxy
A direct space proxy working on an actual space.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDirectSpaceProxy
Title: Description:
|
class |
AbstractSpaceProxy
A common base class for most space proxies.
|
class |
SpaceProxyImpl
Provides the functionality of clustered proxy.
|
Modifier and Type | Method and Description |
---|---|
QueryMultiplePartialFailureException |
ReadTakeMultipleProxyActionInfo.convertExceptionResults(ISpaceProxy spaceProxy,
QueryMultiplePartialFailureException e,
AbstractProjectionTemplate projectionTemplate) |
Object |
ReadTakeProxyActionInfo.convertQueryResult(ISpaceProxy spaceProxy,
IEntryPacket result,
AbstractProjectionTemplate projectionTemplate) |
Object[] |
ReadTakeMultipleProxyActionInfo.convertQueryResults(ISpaceProxy spaceProxy,
IEntryPacket[] results,
AbstractProjectionTemplate projectionTemplate) |
Object[] |
ReadTakeByIdsProxyActionInfo.convertResults(ISpaceProxy spaceProxy,
IEntryPacket[] results,
boolean returnPackets,
AbstractProjectionTemplate projectionTemplate) |
ReadTakeByIdsException |
ReadTakeByIdsProxyActionInfo.convertResults(ISpaceProxy spaceProxy,
ReadTakeByIdsException e,
boolean returnPackets,
AbstractProjectionTemplate projectionTemplate) |
protected void |
CommonProxyActionInfo.initOperationId(ISpaceProxy spaceProxy,
ITransportPacket packet) |
protected void |
QueryProxyActionInfo.setFifoIfNeeded(ISpaceProxy spaceProxy) |
protected IEntryPacket |
CommonProxyActionInfo.toEntryPacket(ISpaceProxy spaceProxy,
Object entry,
ObjectType objectType) |
protected void |
CommonProxyActionInfo.validateReadModifiers(ISpaceProxy spaceProxy) |
Constructor and Description |
---|
AggregateProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
AggregationSet aggregationSet,
Transaction txn,
int modifiers) |
ChangeProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers) |
CountClearProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean isTake) |
CountClearProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean isTake,
boolean isClear) |
NotifyProxyActionInfo(ISpaceProxy spaceProxy,
Object query) |
QueryProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean requiresOperationId) |
QueryProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean requiresOperationId,
boolean supportIdsQuery) |
QueryProxyActionInfo(ISpaceProxy spaceProxy,
Transaction txn,
int modifiers) |
ReadTakeAsyncProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
Transaction txn,
long timeout,
int modifiers,
boolean isTake,
AsyncFutureListener<?> listener) |
ReadTakeByIdsProxyActionInfo(ISpaceProxy spaceProxy,
String className,
Object[] ids,
Object routing,
Object[] routings,
Transaction txn,
boolean isTake,
int modifiers,
QueryResultTypeInternal queryResultType,
String[] projections,
AbstractProjectionTemplate projectionTemplate) |
ReadTakeMultipleProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean isTake,
boolean ifExist) |
ReadTakeProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
boolean isTake) |
ReadTakeProxyActionInfo(ISpaceProxy spaceProxy,
String className,
Object id,
Object routing,
int version,
Transaction txn,
long timeout,
int modifiers,
QueryResultTypeInternal resultType,
boolean ifExists,
boolean isTake,
String[] projections,
AbstractProjectionTemplate projectionTemplate) |
ReadTakeProxyActionInfo(ISpaceProxy spaceProxy,
String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket,
boolean ifExists,
boolean isTake) |
SnapshotProxyActionInfo(ISpaceProxy spaceProxy,
Object entry) |
WriteMultipleProxyActionInfo(ISpaceProxy spaceProxy,
Object[] entries,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
WriteProxyActionInfo(ISpaceProxy spaceProxy,
Object entry,
Transaction txn,
long lease,
long timeout,
int modifiers) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSpaceProxyActionManager<TSpaceProxy extends ISpaceProxy>
An action manager, holding all the action listeners used by different space proxies.
|
class |
AdminProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
AggregateProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
ChangeProxyAction<TSpaceProxy extends ISpaceProxy>
Change operation
|
class |
CountClearProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
ReadTakeByIdsProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
ReadTakeEntriesUidsProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
ReadTakeMultipleProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
ReadTakeProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
SnapshotProxyAction<TSpaceProxy extends ISpaceProxy> |
class |
WriteProxyAction<TSpaceProxy extends ISpaceProxy> |
Modifier and Type | Class and Description |
---|---|
class |
TypeDescriptorActionsProxyExecutor<TSpaceProxy extends ISpaceProxy> |
Modifier and Type | Field and Description |
---|---|
protected ISpaceProxy |
AbstractLocalClusterOperationData._spaceProxy |
protected ISpaceProxy |
AbstractLocalClusterReplicationInHandler._spaceProxy |
Modifier and Type | Method and Description |
---|---|
ISpaceProxy |
AbstractLocalClusterReplicationInHandler.getSpaceProxy() |
Constructor and Description |
---|
NotificationReplicationDataConsumeFixFacade(ISpaceProxy spaceProxy) |
Constructor and Description |
---|
ContinousQuery(ISpaceProxy spaceProxy,
ITemplatePacket query,
ContinousQueryListener listener,
ContinousQueryConfig config,
DataEventSession eventSession) |
Modifier and Type | Method and Description |
---|---|
static ITemplatePacket |
PbsEntryFormatter.getCppTemplatePacketFromSqlQuery(SQLQuery<?> sqlQuery,
ISpaceProxy spaceProxy) |
static ITemplatePacket |
PbsEntryFormatter.getTemplatePacketFromSqlQuery(SQLQuery<?> sqlQuery,
ISpaceProxy spaceProxy,
PbsProjectionTemplate projectionTemplate,
QueryResultTypeInternal resultType) |
static Object |
PbsEntryFormatter.readFieldValue(PbsInputStream input,
ISpaceProxy contextSpaceProxy) |
static ITemplatePacket |
PbsEntryFormatter.readPbsTemplate(PbsInputStream input,
ISpaceProxy spaceProxy) |
static ITemplatePacket |
PbsEntryFormatter.readPbsTemplate(PbsInputStream input,
ISpaceProxy spaceProxy,
ITypeDesc typeDescriptor) |
static Object[] |
PbsEntryFormatter.readPrimitiveArray(PbsInputStream input,
ISpaceProxy contextSpaceProxy) |
static ITemplatePacket |
PbsEntryFormatter.readSqlQuery(PbsInputStream input,
ISpaceProxy spaceProxy,
ITypeDesc typeDescriptor) |
Modifier and Type | Field and Description |
---|---|
protected ISpaceProxy |
XAResourceImpl._proxy |
Modifier and Type | Method and Description |
---|---|
ISpaceProxy |
SpaceFinderListener.onFindSpace(ISpaceProxy spaceProxy,
SpaceURL spaceURL,
Properties customProperties) |
Modifier and Type | Method and Description |
---|---|
static Transaction.Created |
XATransactionFactory.create(ExtendedTransactionManager mgr,
Xid xid,
long leaseTime,
boolean setAsDefault,
ISpaceProxy proxy,
XAResourceImpl resource,
boolean delegatedXa)
Creates new transaction for XA transactions.
|
ISpaceProxy |
SpaceFinderListener.onFindSpace(ISpaceProxy spaceProxy,
SpaceURL spaceURL,
Properties customProperties) |
Modifier and Type | Method and Description |
---|---|
AbstractDMLQuery |
SqlQueryParser.parseSqlQuery(SQLQuery sqlQuery,
ISpaceProxy space)
The main method to handle the query.
|
Modifier and Type | Method and Description |
---|---|
ResponsePacket |
AlterTableQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
DeleteQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
InsertQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
UpdateQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
Join.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
CommitQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
CreateTableQuery.executeOnSpace(ISpaceProxy space,
Transaction txn)
The main logic method, execute the query on the space by calling snapshot
|
ResponsePacket |
DropTableQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
Query.executeOnSpace(ISpaceProxy space,
Transaction txn)
Will execute this query on the space and return a ResponsePacket
|
ResponsePacket |
SelectQuery.executeOnSpace(ISpaceProxy space,
Transaction txn)
Execute the query
|
ResponsePacket |
ProcedureQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
BatchResponsePacket |
InsertQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection) |
BatchResponsePacket |
UpdateQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection) |
BatchResponsePacket |
AbstractDMLQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection)
Executes a query with batched prepared values.
|
BatchResponsePacket |
SelectQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection) |
protected void |
AbstractDMLQuery.executeSubQueries(ISpaceProxy space,
Transaction txn) |
Query |
QueryHandler.handleStatement(RequestPacket request,
ISpaceProxy space)
The main method to handle the query.
|
void |
AbstractDMLQuery.prepare(ISpaceProxy space,
Transaction txn)
Set the prepared values on the expression tree
|
void |
AlterTableQuery.validateQuery(ISpaceProxy space) |
void |
InsertQuery.validateQuery(ISpaceProxy space) |
void |
Join.validateQuery(ISpaceProxy space) |
void |
AbstractDMLQuery.validateQuery(ISpaceProxy space) |
void |
CommitQuery.validateQuery(ISpaceProxy space) |
void |
CreateTableQuery.validateQuery(ISpaceProxy space) |
void |
DropTableQuery.validateQuery(ISpaceProxy space) |
void |
Query.validateQuery(ISpaceProxy space)
Each query should have its own specific validations.
|
void |
SelectQuery.validateQuery(ISpaceProxy space)
This method pre-validates the query, in terms of selected tables and columns.
|
Modifier and Type | Method and Description |
---|---|
IQueryResultSet<IEntryPacket> |
QueryTemplatePacket.read(ISpaceProxy space,
AbstractDMLQuery query,
Transaction txn,
int modifiers,
int maxResults) |
IQueryResultSet<IEntryPacket> |
QueryTemplatePacket.read(ISpaceProxy space,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
int maxResults,
int minEntriesToWaitFor) |
IQueryResultSet<IEntryPacket> |
QueryTemplatePacket.readMultiple(ISpaceProxy space,
Transaction txn,
int maxResults,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
int |
AbstractQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifiers) |
int |
IQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifier)
Execute clear
|
int |
AbstractQueryExecutor.count(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int readModifier) |
int |
IQueryExecutor.count(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int readModifier) |
void |
QueryExecutor.execute(AndNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
CollocatedJoinedQueryExecutor.execute(AndNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(AndNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute And expression - execute both children and union the results
|
void |
JoinedQueryExecutor.execute(AndNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
QueryExecutor.execute(ExpNode expNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
CollocatedJoinedQueryExecutor.execute(ExpNode equalNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(ExpNode equalNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
JoinedQueryExecutor.execute(ExpNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
AbstractQueryExecutor.execute(InnerQueryNode innerQueryNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Executes an inner query
|
void |
IQueryExecutor.execute(InnerQueryNode innerQueryNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute inner query
|
void |
QueryExecutor.execute(InNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
CollocatedJoinedQueryExecutor.execute(InNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(InNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute IN expression - can be a list of simple values or an inner select query
|
void |
JoinedQueryExecutor.execute(InNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
IQueryResultSet<IEntryPacket> |
QueryExecutor.execute(ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
IQueryResultSet<IEntryPacket> |
CollocatedJoinedQueryExecutor.execute(ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
IQueryResultSet<IEntryPacket> |
IQueryExecutor.execute(ISpaceProxy space,
Transaction txn,
int modifiers,
int max) |
IQueryResultSet<IEntryPacket> |
JoinedQueryExecutor.execute(ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
QueryExecutor.execute(NotInNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
CollocatedJoinedQueryExecutor.execute(NotInNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(NotInNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
execute NOT IN query
|
void |
JoinedQueryExecutor.execute(NotInNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
QueryExecutor.execute(OrNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
CollocatedJoinedQueryExecutor.execute(OrNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(OrNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute Or expression - execute both children and union the results
|
void |
JoinedQueryExecutor.execute(OrNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
IQueryResultSet<IEntryPacket> |
AbstractQueryExecutor.executeTemplate(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
protected boolean |
JoinedQueryExecutor.matchesExpressionTree(ExpNode root,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Traverse the binary expression tree non-recursively using a custom stack The tree has to be
traversed in postorder - the parent is traversed after its children.
|
IQueryResultSet |
AbstractQueryExecutor.readAll(ISpaceProxy space,
Transaction txn) |
IQueryResultSet<IEntryPacket> |
IQueryExecutor.readAll(ISpaceProxy space,
Transaction txn) |
protected IQueryResultSet<IEntryPacket> |
AbstractQueryExecutor.traverseExpressionTree(ExpNode root,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Traverse the binary expression tree non-recursively using a custom stack The tree has to be
traversed in postorder - the parent is traversed after its children.
|
Constructor and Description |
---|
ExecutionTask(QueryTemplatePacket packet,
ISpaceProxy space,
Transaction transaction,
int maxObjects,
int readModifier) |
Modifier and Type | Method and Description |
---|---|
void |
ExpNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Accept the query executor
|
void |
InnerQueryNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
AndNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
InNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
NotInNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
OrNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
ValueNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
Modifier and Type | Method and Description |
---|---|
IQueryResultSet<IEntryPacket> |
QueryTableData.executeSubQuery(ISpaceProxy space,
Transaction txn) |
void |
QueryTableData.init(ISpaceProxy space,
Transaction txn,
AbstractDMLQuery query)
Fetch the entries from space that match this table condition
|
Modifier and Type | Method and Description |
---|---|
static SpaceConfigReader |
JProperties.loadDCacheConfig(ISpaceProxy remoteSpace,
Properties customProperties,
String dcacheSuffix) |
Modifier and Type | Field and Description |
---|---|
protected ISpaceProxy |
AbstractMap._spaceProxy |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultSpaceInstance.setIJSpace(ISpaceProxy spaceProxy) |
Constructor and Description |
---|
DefaultGigaSpaceTypeManager(ISpaceProxy space,
ExceptionTranslator exTranslator) |
Copyright © GigaSpaces.