| 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 | |
| org.apache.ignite.internal.visor.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)
Register running query.
|
| Constructor and Description |
|---|
GridRunningQueryInfo(long id,
UUID nodeId,
String qry,
GridCacheQueryType qryType,
String schemaName,
long startTime,
GridQueryCancel cancel,
boolean loc)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
VisorQueryUtils.scheduleQueryStart(IgniteEx ignite,
VisorQueryHolder holder,
VisorQueryTaskArg arg,
GridQueryCancel cancel)
Schedule start of SQL query execution.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.8.1 Release Date : May 21 2020