Package org.apache.ignite.cache.query
Class Query<R>
- java.lang.Object
-
- org.apache.ignite.cache.query.Query<R>
-
- All Implemented Interfaces:
Serializable
- Direct Known Subclasses:
AbstractContinuousQuery,IndexQuery,ScanQuery,SpiQuery,SqlFieldsQuery,SqlQuery,TextQuery
public abstract class Query<R> extends Object implements Serializable
Main API for configuring and executing cache queries. Supported queries are:- SQL Fields query.Provides SQL way with full syntax to access cache data.
See
SqlFieldsQueryfor details. - Full-text query. Uses full-text search engine based on Apache Lucene engine.
See
TextQueryfor details. - Scan query. Provides effective and flexible way to full cache\partition scan.
See
ScanQueryfor details. - Continuous query. Provides flexible way to process all existed cache data and all future cache updates as well.
See
ContinuousQueryfor details. - Spi query. Allow run queries for pluggable user query engine implementation.
See
SpiQueryfor details.
- See Also:
IgniteCache.query(Query), Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static intDFLT_PAGE_SIZEDefault query page size.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetPageSize()Gets optional page size, if0, then default is used.booleanisLocal()Returnstrueif this query should be executed on local node only.protected int[]prepare(int[] parts)Prepares the partitions.Query<R>setLocal(boolean loc)Sets whether this query should be executed on local node only.Query<R>setPageSize(int pageSize)Sets optional page size, if0, then default is used.StringtoString()
-
-
-
Field Detail
-
DFLT_PAGE_SIZE
public static final int DFLT_PAGE_SIZE
Default query page size.- See Also:
- Constant Field Values
-
-
Method Detail
-
getPageSize
public int getPageSize()
Gets optional page size, if0, then default is used.- Returns:
- Optional page size.
-
setPageSize
public Query<R> setPageSize(int pageSize)
Sets optional page size, if0, then default is used.- Parameters:
pageSize- Optional page size.- Returns:
thisfor chaining.
-
isLocal
public boolean isLocal()
Returnstrueif this query should be executed on local node only.- Returns:
- Local flag.
-
setLocal
public Query<R> setLocal(boolean loc)
Sets whether this query should be executed on local node only.- Parameters:
loc- Local flag.- Returns:
thisfor chaining.
-
prepare
protected int[] prepare(int[] parts)
Prepares the partitions.- Parameters:
parts- Partitions.
-
-