| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.odbc.jdbc | |
| org.apache.ignite.internal.processors.query |
| Constructor and Description |
|---|
QueryCursorImpl(Iterable<T> iterExec,
GridQueryCancel cancel,
boolean isQry,
boolean lazy) |
| Modifier and Type | Method and Description |
|---|---|
GridQueryCancel |
JdbcQueryDescriptor.cancelHook() |
| Modifier and Type | Method and Description |
|---|---|
UpdateSourceIterator<?> |
GridQueryIndexing.executeUpdateOnDataNodeTransactional(GridCacheContext<?,?> cctx,
int[] ids,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel) |
UpdateSourceIterator<?> |
GridQueryProcessor.executeUpdateOnDataNodeTransactional(GridCacheContext<?,?> cctx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel)
Execute update on DHT node (i.e. when it is possible to execute and update on all nodes independently).
|
List<FieldsQueryCursor<List<?>>> |
GridQueryProcessor.querySqlFields(@Nullable GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts,
GridCacheQueryType qryType,
@Nullable GridQueryCancel cancel)
Query SQL fields.
|
List<FieldsQueryCursor<List<?>>> |
GridQueryProcessor.querySqlFields(@Nullable GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts,
@Nullable GridQueryCancel cancel)
Query SQL fields.
|
List<FieldsQueryCursor<List<?>>> |
GridQueryIndexing.querySqlFields(String schemaName,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts,
GridQueryCancel cancel)
Detect whether SQL query should be executed in distributed or local manner and execute it.
|
long |
RunningQueryManager.register(String qry,
GridCacheQueryType qryType,
String schemaName,
boolean loc,
@Nullable GridQueryCancel cancel,
String qryInitiatorId,
boolean enforceJoinOrder,
boolean lazy,
boolean distributedJoins)
Registers running query and returns an id associated with the query.
|
| Constructor and Description |
|---|
GridRunningQueryInfo(long id,
UUID nodeId,
String qry,
GridCacheQueryType qryType,
String schemaName,
long startTime,
long startTimeNanos,
GridQueryCancel cancel,
boolean loc,
String qryInitiatorId,
boolean enforceJoinOrder,
boolean lazy,
boolean distributedJoins,
UUID subjId)
Constructor.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023