| Modifier and Type | Method and Description | 
|---|---|
ISpaceProxy | 
SpaceProxyFactory.createSpaceProxy(String url)  | 
ISpaceProxy | 
SpaceProxyFactory.createSpaceProxy(String name,
                boolean isRemote)  | 
| Constructor and Description | 
|---|
SpaceEntryPacketIterator(ISpaceProxy spaceProxy,
                        Object query,
                        Transaction txn,
                        int batchSize,
                        int modifiers)  | 
SpaceIterator(ISpaceProxy spaceProxy,
             Object query,
             Transaction txn,
             int batchSize,
             ReadModifiers modifiers)  | 
| 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 | 
SelectQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)
Execute the query 
 | 
ResponsePacket | 
UpdateQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)  | 
ResponsePacket | 
ProcedureQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)  | 
ResponsePacket | 
DeleteQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)  | 
ResponsePacket | 
AlterTableQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)  | 
ResponsePacket | 
InsertQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)  | 
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 | 
CreateTableQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)
The main logic method, execute the query on the space by calling snapshot 
 | 
ResponsePacket | 
CommitQuery.executeOnSpace(ISpaceProxy space,
              Transaction txn)  | 
BatchResponsePacket | 
SelectQuery.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 | 
InsertQuery.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 | 
SelectQuery.validateQuery(ISpaceProxy space)
This method pre-validates the query, in terms of selected tables and columns. 
 | 
void | 
AlterTableQuery.validateQuery(ISpaceProxy space)  | 
void | 
AbstractDMLQuery.validateQuery(ISpaceProxy space)  | 
void | 
InsertQuery.validateQuery(ISpaceProxy space)  | 
void | 
DropTableQuery.validateQuery(ISpaceProxy space)  | 
void | 
Query.validateQuery(ISpaceProxy space)
Each query should have its own specific validations. 
 | 
void | 
CreateTableQuery.validateQuery(ISpaceProxy space)  | 
void | 
CommitQuery.validateQuery(ISpaceProxy space)  | 
| 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 | 
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 | 
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 | 
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> | 
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 | 
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 | 
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 | 
AndNode.accept(IQueryExecutor executor,
      ISpaceProxy space,
      Transaction txn,
      int readModifier,
      int max)
Accept the query executor 
 | 
void | 
ValueNode.accept(IQueryExecutor executor,
      ISpaceProxy space,
      Transaction txn,
      int readModifier,
      int max)  | 
void | 
InNode.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 | 
NotInNode.accept(IQueryExecutor executor,
      ISpaceProxy space,
      Transaction txn,
      int readModifier,
      int max)
Accept the query executor 
 | 
void | 
OrNode.accept(IQueryExecutor executor,
      ISpaceProxy space,
      Transaction txn,
      int readModifier,
      int max)
Accept the query executor 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
QueryTableData.init(ISpaceProxy space,
    Transaction txn,
    AbstractDMLQuery query)
Fetch the entries from space that match this table condition 
 | 
| Constructor and Description | 
|---|
XAResourceJMSImpl(TransactionManager tm,
                 GSXASessionImpl session,
                 ISpaceProxy proxy)  | 
| 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.