org.apache.ignite.internal.processors.query

Class GridQueryProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.query.GridQueryProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridQueryProcessor
extends GridProcessorAdapter

Indexing processor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields

Modifier and Type	Field and Description
static Class<? extends GridQueryIndexing>	idxCls For tests.
static String	INLINE_SIZES_DIFFER_WARN_MSG_FORMAT Warn message if some indexes have different inline sizes on the nodes.

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
GridQueryProcessor(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
void	beforeExchange(GridDhtPartitionsExchangeFuture fut) Prepare index rebuild futures if needed before exchange.
boolean	belongsToTable(GridCacheContext cctx, String expCacheName, String expTblName, KeyCacheObject key, CacheObject val) Check whether provided key and value belongs to expected cache and table.
void	cancelQueries(Collection<Long> queries) Cancel specified queries.
void	collectGridNodeData(DiscoveryDataBag dataBag) Collects discovery data on nodes already in grid on receiving TcpDiscoveryNodeAddedMessage.
void	collectJoiningNodeData(DiscoveryDataBag dataBag) Collects discovery data on joining node before sending TcpDiscoveryJoinRequestMessage request.
@Nullable GridComponent.DiscoveryDataExchangeType	discoveryDataType() Gets unique component type to distinguish components providing discovery data.
IgniteInternalFuture<?>	dynamicAddQueryEntity(String cacheName, String schemaName, QueryEntity entity, Integer qryParallelism, boolean sqlEscape) Enable dynamically indexing of existing cache.
IgniteInternalFuture<?>	dynamicColumnAdd(String cacheName, String schemaName, String tblName, List<QueryField> cols, boolean ifTblExists, boolean ifNotExists) Entry point for add column procedure.
IgniteInternalFuture<?>	dynamicColumnRemove(String cacheName, String schemaName, String tblName, List<String> cols, boolean ifTblExists, boolean ifExists) Entry point for drop column procedure.
IgniteInternalFuture<?>	dynamicIndexCreate(String cacheName, String schemaName, String tblName, QueryIndex idx, boolean ifNotExists, int parallel) Entry point for index procedure.
IgniteInternalFuture<?>	dynamicIndexDrop(String cacheName, String schemaName, String idxName, boolean ifExists) Entry point for index drop procedure
void	dynamicTableCreate(String schemaName, QueryEntity entity, String templateName, String cacheName, String cacheGroup, @Nullable String dataRegion, String affinityKey, @Nullable CacheAtomicityMode atomicityMode, @Nullable CacheWriteSynchronizationMode writeSyncMode, @Nullable Integer backups, boolean ifNotExists, boolean encrypted, @Nullable Integer qryParallelism) Create cache and table from given query entity.
void	dynamicTableDrop(String cacheName, String tblName, boolean ifExists) Drop table by destroying its cache if it's an 1:1 per cache table.
<R> R	executeQuery(GridCacheQueryType qryType, String qry, @Nullable GridCacheContext<?,?> cctx, IgniteOutClosureX<R> clo, boolean complete)
UpdateSourceIterator<?>	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).
GridQueryIndexing	getIndexing()
static AffinityTopologyVersion	getRequestAffinityTopologyVersion()
@Nullable IgniteInternalFuture<?>	indexRebuildFuture(int cacheId)
void	initQueryStructuresForNotStartedCache(DynamicCacheDescriptor cacheDesc) Initialize query infrastructure for not started cache.
void	markAsRebuildNeeded(GridCacheContext cctx) Mark that for given cache index should/would be rebuilt.
boolean	moduleEnabled()
CacheQueryObjectValueContext	objectContext()
void	onCacheChangeRequested(DynamicCacheChangeBatch batch) Handle of cache change request.
void	onCacheKernalStart() Handle cache kernal start.
void	onCacheReconnect() Handle cache reconnect.
void	onCacheStart(GridCacheContextInfo cacheInfo, QuerySchema schema, boolean isSql) Handle cache start.
void	onCacheStart0(GridCacheContextInfo<?,?> cacheInfo, QuerySchema schema, boolean isSql) Create type descriptors from schema and initialize indexing for given cache.
void	onCacheStop(GridCacheContextInfo cacheInfo, boolean removeIdx)
void	onCacheStop(String cacheName) Destroy H2 structures for not started caches.
void	onCacheStop0(GridCacheContextInfo cacheInfo, boolean destroy) Unregister cache.
void	onCoordinatorFinished(SchemaAbstractOperation op, @Nullable SchemaOperationException err) Invoked when coordinator finished ensuring that all participants are ready.
void	onDisconnected(IgniteFuture<?> reconnectFut) Client disconnected callback.
void	onDiscovery(SchemaAbstractDiscoveryMessage msg) Handle custom discovery message.
void	onGridDataReceived(DiscoveryDataBag.GridDiscoveryData data) Receives discovery data object from remote nodes (called on new node during discovery process).
void	onJoiningNodeDataReceived(DiscoveryDataBag.JoiningNodeDiscoveryData data) Method is called on nodes that are already in grid (not on joining node).
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	onLocalOperationFinished(SchemaAbstractOperation op, @Nullable QueryTypeDescriptorImpl type) Apply positive index operation result.
void	onNodeLeave(ClusterNode node) Handle node leave.
void	onSchemaPropose(SchemaProposeDiscoveryMessage msg) Handle schema propose from exchange thread.
void	processSchemaOperationLocal(SchemaAbstractOperation op, QueryTypeDescriptorImpl type, IgniteUuid depId, SchemaIndexOperationCancellationToken cancelTok) Process schema operation.
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>>	querySql(GridCacheContext<?,?> cctx, SqlQuery qry, boolean keepBinary) Execute distributed SQL query.
List<FieldsQueryCursor<List<?>>>	querySqlFields(@Nullable GridCacheContext<?,?> cctx, SqlFieldsQuery qry, SqlClientContext cliCtx, boolean keepBinary, boolean failOnMultipleStmts) Query SQL fields.
List<FieldsQueryCursor<List<?>>>	querySqlFields(@Nullable GridCacheContext<?,?> cctx, SqlFieldsQuery qry, SqlClientContext cliCtx, boolean keepBinary, boolean failOnMultipleStmts, GridCacheQueryType qryType, @Nullable GridQueryCancel cancel) Query SQL fields.
List<FieldsQueryCursor<List<?>>>	querySqlFields(@Nullable GridCacheContext<?,?> cctx, SqlFieldsQuery qry, SqlClientContext cliCtx, boolean keepBinary, boolean failOnMultipleStmts, @Nullable GridQueryCancel cancel) Query SQL fields.
FieldsQueryCursor<List<?>>	querySqlFields(SqlFieldsQuery qry, boolean keepBinary) Query SQL fields.
List<FieldsQueryCursor<List<?>>>	querySqlFields(SqlFieldsQuery qry, boolean keepBinary, boolean failOnMultipleStmts) Query SQL fields.
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>>	queryText(String cacheName, String clause, String resType, IndexingQueryFilter filters, int limit)
IgniteInternalFuture<?>	rebuildIndexesFromHash(GridCacheContext cctx) Rebuilds indexes for provided caches from corresponding hash indexes.
void	remove(GridCacheContext cctx, CacheDataRow row)
Collection<GridRunningQueryInfo>	runningQueries(long duration) Collect queries that already running more than specified duration.
Map<String,Integer>	secondaryIndexesInlineSize()
void	sendStatusMessage(UUID destNodeId, UUID opId, SchemaOperationException err) Send status message to coordinator node.
static void	setRequestAffinityTopologyVersion(AffinityTopologyVersion ver)
boolean	skipFieldLookup()
void	skipFieldLookup(boolean skipFieldLookup)
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
void	store(GridCacheContext cctx, CacheDataRow newRow, @Nullable CacheDataRow prevRow, boolean prevRowAvailable)
List<Long>	streamBatchedUpdateQuery(String schemaName, SqlClientContext cliCtx, String qry, List<Object[]> args)
long	streamUpdateQuery(@Nullable String cacheName, String schemaName, IgniteDataStreamer<?,?> streamer, String qry, Object[] args)
@Nullable QueryTypeDescriptorImpl	typeByValue(String cacheName, CacheObjectContext coctx, KeyCacheObject key, CacheObject val, boolean checkType)
@Nullable GridQueryTypeDescriptor	typeDescriptor(@Nullable String cacheName, String typeName) Gets type descriptor for provided cache name and type name if type is still valid.
Collection<GridQueryTypeDescriptor>	types(@Nullable String cacheName) Gets types for cache.
void	validateKeyAndValue(CacheObjectContext coctx, KeyCacheObject key, CacheObject val) Performs validation of provided key and value against configured constraints.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, onKernalStart, onReconnected, printMemoryStats, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

INLINE_SIZES_DIFFER_WARN_MSG_FORMAT

public static final String INLINE_SIZES_DIFFER_WARN_MSG_FORMAT

Warn message if some indexes have different inline sizes on the nodes.

See Also:

Constant Field Values

idxCls

public static Class<? extends GridQueryIndexing> idxCls

For tests.

Constructor Detail

GridQueryProcessor

public GridQueryProcessor(GridKernalContext ctx)
                   throws IgniteCheckedException

Parameters:

ctx - Kernal context.

Throws:

IgniteCheckedException

Method Detail

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

stop

public void stop(boolean cancel)
          throws IgniteCheckedException

Stops grid component.

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

IgniteCheckedException - Thrown in case of any errors.

onCacheKernalStart

public void onCacheKernalStart()
                        throws IgniteCheckedException

Handle cache kernal start. At this point discovery and IO managers are operational, caches are not started yet.

Throws:

IgniteCheckedException - If failed.

onCacheReconnect

public void onCacheReconnect()
                      throws IgniteCheckedException

Handle cache reconnect.

Throws:

IgniteCheckedException - If failed.

discoveryDataType

@Nullable
public @Nullable GridComponent.DiscoveryDataExchangeType discoveryDataType()

Gets unique component type to distinguish components providing discovery data. Must return non-null value if component implements any of methods GridComponent.collectJoiningNodeData(DiscoveryDataBag) or GridComponent.collectGridNodeData(DiscoveryDataBag).

Specified by:

discoveryDataType in interface GridComponent

Overrides:

discoveryDataType in class GridProcessorAdapter

Returns:

Unique component type for discovery data exchange.

collectGridNodeData

public void collectGridNodeData(DiscoveryDataBag dataBag)

Collects discovery data on nodes already in grid on receiving TcpDiscoveryNodeAddedMessage.

Specified by:

collectGridNodeData in interface GridComponent

Overrides:

collectGridNodeData in class GridProcessorAdapter

Parameters:

dataBag - container object to store discovery data in.

onJoiningNodeDataReceived

public void onJoiningNodeDataReceived(DiscoveryDataBag.JoiningNodeDiscoveryData data)

Method is called on nodes that are already in grid (not on joining node). It receives discovery data from joining node.

Specified by:

onJoiningNodeDataReceived in interface GridComponent

Overrides:

onJoiningNodeDataReceived in class GridProcessorAdapter

Parameters:

data - DiscoveryDataBag.JoiningNodeDiscoveryData interface to retrieve discovery data of joining node.

collectJoiningNodeData

public void collectJoiningNodeData(DiscoveryDataBag dataBag)

Collects discovery data on joining node before sending TcpDiscoveryJoinRequestMessage request.

Specified by:

collectJoiningNodeData in interface GridComponent

Overrides:

collectJoiningNodeData in class GridProcessorAdapter

Parameters:

dataBag - container object to store discovery data in.

onGridDataReceived

public void onGridDataReceived(DiscoveryDataBag.GridDiscoveryData data)

Receives discovery data object from remote nodes (called on new node during discovery process).

Specified by:

onGridDataReceived in interface GridComponent

Overrides:

onGridDataReceived in class GridProcessorAdapter

Parameters:

data - DiscoveryDataBag.GridDiscoveryData interface to retrieve discovery data collected on remote nodes (data common for all nodes in grid and specific for each node).

beforeExchange

public void beforeExchange(GridDhtPartitionsExchangeFuture fut)

Prepare index rebuild futures if needed before exchange.

Parameters:

fut - Exchange future.

secondaryIndexesInlineSize

public Map<String,Integer> secondaryIndexesInlineSize()

Returns:

Information about secondary indexes inline size. Key is a full index name, value is a effective inline size.

See Also:

GridQueryIndexing.secondaryIndexesInlineSize()

onSchemaPropose

public void onSchemaPropose(SchemaProposeDiscoveryMessage msg)

Handle schema propose from exchange thread.

Parameters:

msg - Discovery message.

moduleEnabled

public boolean moduleEnabled()

Returns:

true If indexing module is in classpath and successfully initialized.

getIndexing

public GridQueryIndexing getIndexing()
                              throws IgniteException

Returns:

Indexing.

Throws:

IgniteException - If module is not enabled.

onCacheStart0

public void onCacheStart0(GridCacheContextInfo<?,?> cacheInfo,
                          QuerySchema schema,
                          boolean isSql)
                   throws IgniteCheckedException

Create type descriptors from schema and initialize indexing for given cache.

Use with busyLock where appropriate.

Parameters:

cacheInfo - Cache context info.

schema - Initial schema.

isSql - true in case create cache initialized from SQL.

Throws:

IgniteCheckedException - If failed.

onDisconnected

public void onDisconnected(IgniteFuture<?> reconnectFut)
                    throws IgniteCheckedException

Client disconnected callback.

Specified by:

onDisconnected in interface GridComponent

Overrides:

onDisconnected in class GridProcessorAdapter

Parameters:

reconnectFut - Reconnect future.

Throws:

IgniteCheckedException - If failed.

initQueryStructuresForNotStartedCache

public void initQueryStructuresForNotStartedCache(DynamicCacheDescriptor cacheDesc)
                                           throws IgniteCheckedException

Initialize query infrastructure for not started cache.

Parameters:

cacheDesc - Cache descriptor.

Throws:

IgniteCheckedException - If failed.

onCacheStart

public void onCacheStart(GridCacheContextInfo cacheInfo,
                         QuerySchema schema,
                         boolean isSql)
                  throws IgniteCheckedException

Handle cache start. Invoked either from GridCacheProcessor.onKernalStart() method or from exchange worker. When called for the first time, we initialize topology thus understanding whether current node is coordinator or not.

Parameters:

cacheInfo - Cache context info.

schema - Index states.

isSql - true in case create cache initialized from SQL.

Throws:

IgniteCheckedException - If failed.

onCacheStop

public void onCacheStop(String cacheName)

Destroy H2 structures for not started caches.

Parameters:

cacheName - Cache name.

onCacheStop

public void onCacheStop(GridCacheContextInfo cacheInfo,
                        boolean removeIdx)

Parameters:

cacheInfo - Cache context info.

removeIdx - If true, will remove index.

skipFieldLookup

public boolean skipFieldLookup()

Returns:

Skip field lookup flag.

skipFieldLookup

public void skipFieldLookup(boolean skipFieldLookup)

Parameters:

skipFieldLookup - Skip field lookup flag.

onCacheChangeRequested

public void onCacheChangeRequested(DynamicCacheChangeBatch batch)

Handle of cache change request.

Parameters:

batch - Dynamic cache change batch request.

onDiscovery

public void onDiscovery(SchemaAbstractDiscoveryMessage msg)

Handle custom discovery message.

Parameters:

msg - Message.

onCoordinatorFinished

public void onCoordinatorFinished(SchemaAbstractOperation op,
                                  @Nullable
                                  @Nullable SchemaOperationException err)

Invoked when coordinator finished ensuring that all participants are ready.

Parameters:

op - Operation.

err - Error (if any).

onLocalOperationFinished

public void onLocalOperationFinished(SchemaAbstractOperation op,
                                     @Nullable
                                     @Nullable QueryTypeDescriptorImpl type)

Apply positive index operation result.

Parameters:

op - Operation.

type - Type descriptor (if available),

onNodeLeave

public void onNodeLeave(ClusterNode node)

Handle node leave.

Parameters:

node - Node.

processSchemaOperationLocal

public void processSchemaOperationLocal(SchemaAbstractOperation op,
                                        QueryTypeDescriptorImpl type,
                                        IgniteUuid depId,
                                        SchemaIndexOperationCancellationToken cancelTok)
                                 throws SchemaOperationException

Process schema operation.

Parameters:

op - Operation.

type - Type descriptor.

depId - Cache deployment ID.

cancelTok - Cancel token.

Throws:

SchemaOperationException - If failed.

dynamicTableCreate

public void dynamicTableCreate(String schemaName,
                               QueryEntity entity,
                               String templateName,
                               String cacheName,
                               String cacheGroup,
                               @Nullable
                               @Nullable String dataRegion,
                               String affinityKey,
                               @Nullable
                               @Nullable CacheAtomicityMode atomicityMode,
                               @Nullable
                               @Nullable CacheWriteSynchronizationMode writeSyncMode,
                               @Nullable
                               @Nullable Integer backups,
                               boolean ifNotExists,
                               boolean encrypted,
                               @Nullable
                               @Nullable Integer qryParallelism)
                        throws IgniteCheckedException

Create cache and table from given query entity.

Parameters:

schemaName - Schema name to create table in. Case sensitive, must not be \"quoted\".

entity - Entity to create table from.

templateName - Template name.

cacheName - Cache name.

cacheGroup - Cache group name.

dataRegion - Data region name.

affinityKey - Affinity key column name.

atomicityMode - Atomicity mode.

writeSyncMode - Write synchronization mode.

backups - Backups.

ifNotExists - Quietly ignore this command if table already exists.

encrypted - Encrypted flag.

qryParallelism - query parallelism value for configuration of underlying cache.

Throws:

IgniteCheckedException - If failed.

dynamicTableDrop

public void dynamicTableDrop(String cacheName,
                             String tblName,
                             boolean ifExists)
                      throws SchemaOperationException

Drop table by destroying its cache if it's an 1:1 per cache table.

Parameters:

cacheName - Cache name.

tblName - Table name.

ifExists - Quietly ignore this command if table does not exist.

Throws:

SchemaOperationException - if ifExists is false and cache was not found.

onCacheStop0

public void onCacheStop0(GridCacheContextInfo cacheInfo,
                         boolean destroy)

Unregister cache.

Use with busyLock where appropriate.

Parameters:

cacheInfo - Cache context info.

destroy - Destroy flag.

belongsToTable

public boolean belongsToTable(GridCacheContext cctx,
                              String expCacheName,
                              String expTblName,
                              KeyCacheObject key,
                              CacheObject val)
                       throws IgniteCheckedException

Check whether provided key and value belongs to expected cache and table.

Parameters:

cctx - Target cache context.

expCacheName - Expected cache name.

expTblName - Expected table name.

key - Key.

val - Value.

Returns:

True if this key-value pair belongs to expected cache/table, false otherwise or if cache or table doesn't exist.

Throws:

IgniteCheckedException - If failed.

markAsRebuildNeeded

public void markAsRebuildNeeded(GridCacheContext cctx)

Mark that for given cache index should/would be rebuilt.

Parameters:

cctx - Cache context.

rebuildIndexesFromHash

public IgniteInternalFuture<?> rebuildIndexesFromHash(GridCacheContext cctx)

Rebuilds indexes for provided caches from corresponding hash indexes.

Parameters:

cctx - Cache context.

Returns:

Future that will be completed when rebuilding is finished.

indexRebuildFuture

@Nullable
public @Nullable IgniteInternalFuture<?> indexRebuildFuture(int cacheId)

Returns:

Future that will be completed when indexes for given cache are restored.

store

public void store(GridCacheContext cctx,
                  CacheDataRow newRow,
                  @Nullable
                  @Nullable CacheDataRow prevRow,
                  boolean prevRowAvailable)
           throws IgniteCheckedException

Parameters:

cctx - Cache context.

newRow - New row.

prevRow - Previous row.

Throws:

IgniteCheckedException - In case of error.

typeByValue

@Nullable
public @Nullable QueryTypeDescriptorImpl typeByValue(String cacheName,
                                                               CacheObjectContext coctx,
                                                               KeyCacheObject key,
                                                               CacheObject val,
                                                               boolean checkType)
                                                        throws IgniteCheckedException

Parameters:

cacheName - Cache name.

coctx - Cache context.

key - Key.

val - Value.

checkType - If true checks that key and value type correspond to found TypeDescriptor.

Returns:

Type descriptor if found and null otherwise.

Throws:

IgniteCheckedException - If type check failed.

executeUpdateOnDataNodeTransactional

public UpdateSourceIterator<?> 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)
                                                             throws IgniteCheckedException

Execute update on DHT node (i.e. when it is possible to execute and update on all nodes independently).

Parameters:

cctx - Cache context.

cacheIds - Involved cache ids.

parts - Partitions.

schema - Schema name.

qry - Query string.

params - Query parameters.

flags - Flags.

pageSize - Fetch page size.

timeout - Timeout.

topVer - Topology version.

mvccSnapshot - MVCC snapshot.

cancel - Query cancel object.

Returns:

Cursor over entries which are going to be changed.

Throws:

IgniteCheckedException - If failed.

querySqlFields

public List<FieldsQueryCursor<List<?>>> querySqlFields(SqlFieldsQuery qry,
                                                       boolean keepBinary,
                                                       boolean failOnMultipleStmts)

Query SQL fields.

Parameters:

qry - Query.

keepBinary - Keep binary flag.

Returns:

Cursor.

querySqlFields

public FieldsQueryCursor<List<?>> querySqlFields(SqlFieldsQuery qry,
                                                 boolean keepBinary)

Query SQL fields.

Parameters:

qry - Query.

keepBinary - Keep binary flag.

Returns:

Cursor.

querySqlFields

public List<FieldsQueryCursor<List<?>>> querySqlFields(@Nullable
                                                       @Nullable GridCacheContext<?,?> cctx,
                                                       SqlFieldsQuery qry,
                                                       SqlClientContext cliCtx,
                                                       boolean keepBinary,
                                                       boolean failOnMultipleStmts)

Query SQL fields.

Parameters:

cctx - Cache context.

qry - Query.

cliCtx - Client context.

keepBinary - Keep binary flag.

failOnMultipleStmts - If true the method must throws exception when query contains more then one SQL statement.

Returns:

Cursor.

querySqlFields

public List<FieldsQueryCursor<List<?>>> querySqlFields(@Nullable
                                                       @Nullable GridCacheContext<?,?> cctx,
                                                       SqlFieldsQuery qry,
                                                       SqlClientContext cliCtx,
                                                       boolean keepBinary,
                                                       boolean failOnMultipleStmts,
                                                       @Nullable
                                                       @Nullable GridQueryCancel cancel)

Query SQL fields.

Parameters:

cctx - Cache context.

qry - Query.

cliCtx - Client context.

keepBinary - Keep binary flag.

failOnMultipleStmts - If true the method must throws exception when query contains more then one SQL statement.

cancel - Hook for query cancellation.

Returns:

Cursor.

querySqlFields

public List<FieldsQueryCursor<List<?>>> querySqlFields(@Nullable
                                                       @Nullable GridCacheContext<?,?> cctx,
                                                       SqlFieldsQuery qry,
                                                       SqlClientContext cliCtx,
                                                       boolean keepBinary,
                                                       boolean failOnMultipleStmts,
                                                       GridCacheQueryType qryType,
                                                       @Nullable
                                                       @Nullable GridQueryCancel cancel)

Query SQL fields.

Parameters:

cctx - Cache context.

qry - Query.

cliCtx - Client context.

keepBinary - Keep binary flag.

failOnMultipleStmts - If true the method must throws exception when query contains more then one SQL statement.

qryType - Real query type.

cancel - Hook for query cancellation.

Returns:

Cursor.

streamUpdateQuery

public long streamUpdateQuery(@Nullable
                              @Nullable String cacheName,
                              String schemaName,
                              IgniteDataStreamer<?,?> streamer,
                              String qry,
                              Object[] args)

Parameters:

cacheName - Cache name.

schemaName - Schema name.

streamer - Data streamer.

qry - Query.

Returns:

Update counter.

streamBatchedUpdateQuery

public List<Long> streamBatchedUpdateQuery(String schemaName,
                                           SqlClientContext cliCtx,
                                           String qry,
                                           List<Object[]> args)

Parameters:

schemaName - Schema name.

cliCtx - Client context.

qry - Query.

args - Query arguments.

Returns:

Update counters.

querySql

public <K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> querySql(GridCacheContext<?,?> cctx,
                                                                SqlQuery qry,
                                                                boolean keepBinary)

Execute distributed SQL query.

Parameters:

cctx - Cache context.

qry - Query.

keepBinary - Keep binary flag.

Returns:

Cursor.

runningQueries

public Collection<GridRunningQueryInfo> runningQueries(long duration)

Collect queries that already running more than specified duration.

Parameters:

duration - Duration to check.

Returns:

Collection of long running queries.

cancelQueries

public void cancelQueries(Collection<Long> queries)

Cancel specified queries.

Parameters:

queries - Queries ID's to cancel.

dynamicIndexCreate

public IgniteInternalFuture<?> dynamicIndexCreate(String cacheName,
                                                  String schemaName,
                                                  String tblName,
                                                  QueryIndex idx,
                                                  boolean ifNotExists,
                                                  int parallel)

Entry point for index procedure.

Parameters:

cacheName - Cache name.

schemaName - Schema name.

tblName - Table name.

idx - Index.

ifNotExists - When set to true operation will fail if index already exists.

parallel - Index creation parallelism level.

Returns:

Future completed when index is created.

dynamicIndexDrop

public IgniteInternalFuture<?> dynamicIndexDrop(String cacheName,
                                                String schemaName,
                                                String idxName,
                                                boolean ifExists)

Entry point for index drop procedure

Parameters:

cacheName - Cache name.

schemaName - Schema name.

idxName - Index name.

ifExists - When set to true operation fill fail if index doesn't exists.

Returns:

Future completed when index is created.

dynamicColumnAdd

public IgniteInternalFuture<?> dynamicColumnAdd(String cacheName,
                                                String schemaName,
                                                String tblName,
                                                List<QueryField> cols,
                                                boolean ifTblExists,
                                                boolean ifNotExists)

Entry point for add column procedure.

Parameters:

schemaName - Schema name.

tblName - Target table name.

cols - Columns to add.

ifTblExists - Ignore operation if target table doesn't exist.

ifNotExists - Ignore operation if column exists.

dynamicColumnRemove

public IgniteInternalFuture<?> dynamicColumnRemove(String cacheName,
                                                   String schemaName,
                                                   String tblName,
                                                   List<String> cols,
                                                   boolean ifTblExists,
                                                   boolean ifExists)

Entry point for drop column procedure.

Parameters:

schemaName - Schema name.

tblName - Target table name.

cols - Columns to drop.

ifTblExists - Ignore operation if target table doesn't exist.

ifExists - Ignore operation if column does not exist.

dynamicAddQueryEntity

public IgniteInternalFuture<?> dynamicAddQueryEntity(String cacheName,
                                                     String schemaName,
                                                     QueryEntity entity,
                                                     Integer qryParallelism,
                                                     boolean sqlEscape)

Enable dynamically indexing of existing cache.

Parameters:

cacheName - Cache name

schemaName - Target schema name.

entity - Instance of QueryEntity.

qryParallelism - Query parallelism.

sqlEscape - Escape flag, seeQueryUtils.normalizeQueryEntity(org.apache.ignite.cache.QueryEntity, boolean).

remove

public void remove(GridCacheContext cctx,
                   CacheDataRow row)
            throws IgniteCheckedException

Parameters:

cctx - Cache context.

row - Row removed from cache.

Throws:

IgniteCheckedException - Thrown in case of any errors.

queryText

public <K,V> GridCloseableIterator<IgniteBiTuple<K,V>> queryText(String cacheName,
                                                                 String clause,
                                                                 String resType,
                                                                 IndexingQueryFilter filters,
                                                                 int limit)
                                                          throws IgniteCheckedException

Type Parameters:

K - Key type.

V - Value type.

Parameters:

cacheName - Cache name.

clause - Clause.

resType - Result type.

filters - Key and value filters.

limit - Limits response records count. If 0 or less, the limit considered to be Integer.MAX_VALUE, that is virtually no limit.

Returns:

Key/value rows.

Throws:

IgniteCheckedException - If failed.

types

public Collection<GridQueryTypeDescriptor> types(@Nullable
                                                 @Nullable String cacheName)

Gets types for cache.

Parameters:

cacheName - Cache name.

Returns:

Descriptors.

typeDescriptor

@Nullable
public @Nullable GridQueryTypeDescriptor typeDescriptor(@Nullable
                                                                  @Nullable String cacheName,
                                                                  String typeName)

Gets type descriptor for provided cache name and type name if type is still valid.

Parameters:

cacheName - Cache name.

typeName - Type name.

Returns:

Query type descriptor or null if descriptor was not found.

executeQuery

public <R> R executeQuery(GridCacheQueryType qryType,
                          String qry,
                          @Nullable
                          @Nullable GridCacheContext<?,?> cctx,
                          IgniteOutClosureX<R> clo,
                          boolean complete)
                   throws IgniteCheckedException

Parameters:

qryType - Query type.

qry - Query description.

cctx - Cache context.

clo - Closure.

complete - Complete.

Throws:

IgniteCheckedException

sendStatusMessage

public void sendStatusMessage(UUID destNodeId,
                              UUID opId,
                              SchemaOperationException err)

Send status message to coordinator node.

Parameters:

destNodeId - Destination node ID.

opId - Operation ID.

err - Error.

objectContext

public CacheQueryObjectValueContext objectContext()

Returns:

Value object context.

validateKeyAndValue

public void validateKeyAndValue(CacheObjectContext coctx,
                                KeyCacheObject key,
                                CacheObject val)
                         throws IgniteCheckedException

Performs validation of provided key and value against configured constraints. Throws runtime exception if validation fails.

Parameters:

coctx - Cache object context.

key - Key.

val - Value.

Throws:

IgniteCheckedException, - If error happens.

IgniteCheckedException

setRequestAffinityTopologyVersion

public static void setRequestAffinityTopologyVersion(AffinityTopologyVersion ver)

Parameters:

ver - Version.

getRequestAffinityTopologyVersion

public static AffinityTopologyVersion getRequestAffinityTopologyVersion()

Returns:

Affinity topology version of the current request.