| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.cache.query |
Contains APIs for creating and executing cache queries.
|
| org.apache.ignite.client |
Contains Ignite Thin Client API classes.
|
| org.apache.ignite.internal.client.thin | |
| org.apache.ignite.internal.jdbc2 | |
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.query | |
| org.apache.ignite.internal.processors.query |
| Modifier and Type | Method and Description |
|---|---|
FieldsQueryCursor<List<?>> |
IgniteCache.query(SqlFieldsQuery qry)
Queries cache.
|
| Modifier and Type | Method and Description |
|---|---|
SqlFieldsQuery |
SqlFieldsQuery.copy() |
SqlFieldsQuery |
SqlFieldsQuery.setArgs(Object... args)
Sets SQL arguments.
|
SqlFieldsQuery |
SqlFieldsQuery.setCollocated(boolean collocated)
Sets flag defining if this query is collocated.
|
SqlFieldsQuery |
SqlFieldsQuery.setDistributedJoins(boolean distributedJoins)
Specify if distributed joins are enabled for this query.
|
SqlFieldsQuery |
SqlFieldsQuery.setEnforceJoinOrder(boolean enforceJoinOrder)
Sets flag to enforce join order of tables in the query.
|
SqlFieldsQuery |
SqlFieldsQuery.setLazy(boolean lazy)
Deprecated.
Use
setPageSize(int) instead. |
SqlFieldsQuery |
SqlFieldsQuery.setLocal(boolean loc)
Sets whether this query should be executed on local node only.
|
SqlFieldsQuery |
SqlFieldsQuery.setPageSize(int pageSize)
Sets optional page size, if
0, then default is used. |
SqlFieldsQuery |
SqlFieldsQuery.setPartitions(int... parts)
Sets partitions for a query.
|
SqlFieldsQuery |
SqlFieldsQuery.setQueryInitiatorId(String qryInitiatorId) |
SqlFieldsQuery |
SqlFieldsQuery.setReplicatedOnly(boolean replicatedOnly)
Deprecated.
No longer used as of Apache Ignite 2.8.
|
SqlFieldsQuery |
SqlFieldsQuery.setSchema(@Nullable String schema)
Set schema for the query.
|
SqlFieldsQuery |
SqlFieldsQuery.setSql(String sql)
Sets SQL clause.
|
SqlFieldsQuery |
SqlFieldsQuery.setTimeout(int timeout,
TimeUnit timeUnit)
Sets the query execution timeout.
|
SqlFieldsQuery |
SqlFieldsQuery.setUpdateBatchSize(int updateBatchSize)
Sets update internal bach size.
|
| Constructor and Description |
|---|
SqlFieldsQuery(SqlFieldsQuery qry)
Copy constructs SQL fields query.
|
| Modifier and Type | Method and Description |
|---|---|
FieldsQueryCursor<List<?>> |
ClientCache.query(SqlFieldsQuery qry)
Convenience method to execute
SqlFieldsQuery. |
FieldsQueryCursor<List<?>> |
IgniteClient.query(SqlFieldsQuery qry)
Execute SQL query and get cursor to iterate over results.
|
| Modifier and Type | Method and Description |
|---|---|
FieldsQueryCursor<List<?>> |
TcpIgniteClient.query(SqlFieldsQuery qry)
Execute SQL query and get cursor to iterate over results.
|
FieldsQueryCursor<List<?>> |
TcpClientCache.query(SqlFieldsQuery qry)
Convenience method to execute
SqlFieldsQuery. |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JdbcStatement.setupQuery(SqlFieldsQuery qry)
Sets parameters to query object.
|
| Modifier and Type | Method and Description |
|---|---|
FieldsQueryCursor<List<?>> |
GatewayProtectedCacheProxy.query(SqlFieldsQuery qry)
Queries cache.
|
FieldsQueryCursor<List<?>> |
IgniteCacheProxyImpl.query(SqlFieldsQuery qry)
Queries cache.
|
List<FieldsQueryCursor<List<?>>> |
IgniteCacheProxy.queryMultipleStatements(SqlFieldsQuery qry)
Queries cache with multiple statements.
|
List<FieldsQueryCursor<List<?>>> |
GatewayProtectedCacheProxy.queryMultipleStatements(SqlFieldsQuery qry)
Queries cache with multiple statements.
|
List<FieldsQueryCursor<List<?>>> |
IgniteCacheProxyImpl.queryMultipleStatements(SqlFieldsQuery qry)
Queries cache with multiple statements.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SqlFieldsQueryEx
SqlFieldsQuery with experimental and internal features. |
| Modifier and Type | Method and Description |
|---|---|
SqlFieldsQuery |
SqlFieldsQueryEx.copy() |
SqlFieldsQuery |
SqlFieldsQueryEx.setSkipReducerOnUpdate(boolean skipReducerOnUpdate)
Sets server side update flag.
|
| Modifier and Type | Method and Description |
|---|---|
SqlFieldsQuery |
GridQueryIndexing.generateFieldsQuery(String cacheName,
SqlQuery qry)
Generate SqlFieldsQuery from SqlQuery.
|
static SqlFieldsQuery |
QueryUtils.withQueryTimeout(SqlFieldsQuery qry,
int timeout,
TimeUnit timeUnit) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridQueryIndexing.isStreamableInsertStatement(String schemaName,
SqlFieldsQuery sql)
Whether passed sql statement is single insert statement eligible for streaming.
|
List<JdbcParameterMeta> |
GridQueryProcessor.parameterMetaData(SqlFieldsQuery qry,
@Nullable SqlClientContext cliCtx) |
List<JdbcParameterMeta> |
GridQueryIndexing.parameterMetaData(String schemaName,
SqlFieldsQuery sql)
Jdbc parameters metadata of the specified query.
|
List<FieldsQueryCursor<List<?>>> |
GridQueryProcessor.querySqlFields(@Nullable GridCacheContext<?,?> cctx,
SqlFieldsQuery qry,
SqlClientContext cliCtx,
boolean keepBinary,
boolean failOnMultipleStmts)
Query SQL fields.
|
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.
|
FieldsQueryCursor<List<?>> |
GridQueryProcessor.querySqlFields(SqlFieldsQuery qry,
boolean keepBinary)
Query SQL fields.
|
List<FieldsQueryCursor<List<?>>> |
GridQueryProcessor.querySqlFields(SqlFieldsQuery qry,
boolean keepBinary,
boolean failOnMultipleStmts)
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.
|
@Nullable List<GridQueryFieldMetadata> |
GridQueryIndexing.resultMetaData(String schemaName,
SqlFieldsQuery sql)
Metadata of the result set that is returned if specified query gets executed.
|
List<GridQueryFieldMetadata> |
GridQueryProcessor.resultSetMetaData(SqlFieldsQuery qry,
@Nullable SqlClientContext cliCtx) |
static SqlFieldsQuery |
QueryUtils.withQueryTimeout(SqlFieldsQuery qry,
int timeout,
TimeUnit timeUnit) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023