public abstract class Query<T extends Query> extends Object implements Serializable
SqlQuery and TextQuery for SQL and
text queries accordingly.
Also contains convenience shortcuts for query object construction:
sql(Class, String), sql(String), text(Class, String),
scan(IgniteBiPredicate) and spi().
| Modifier and Type | Method and Description |
|---|---|
static <K,V> ContinuousQuery<K,V> |
continuous()
Factory method for continuous queries.
|
int |
getPageSize()
Gets optional page size, if
0, then CacheQueryConfiguration#getPageSize() is used. |
static <K,V> ScanQuery<K,V> |
scan(IgniteBiPredicate<K,V> filter)
Factory method for SPI queries.
|
T |
setPageSize(int pageSize)
Sets optional page size, if
0, then CacheQueryConfiguration#getPageSize() is used. |
static SpiQuery |
spi()
Factory method for SPI queries.
|
static SqlQuery |
sql(Class<?> type,
String sql)
Factory method for SQL queries.
|
static SqlFieldsQuery |
sql(String sql)
Factory method for SQL fields queries.
|
static TextQuery |
text(Class<?> type,
String txt)
Factory method for Lucene fulltext queries.
|
String |
toString() |
public static SqlFieldsQuery sql(String sql)
sql - SQL Query string.public static SqlQuery sql(Class<?> type, String sql)
type - Type to be queried.sql - SQL Query string.public static TextQuery text(Class<?> type, String txt)
type - Type to be queried.txt - Search string.public static <K,V> ScanQuery<K,V> scan(IgniteBiPredicate<K,V> filter)
filter - Filter.public static SpiQuery spi()
IndexingSpipublic static <K,V> ContinuousQuery<K,V> continuous()
public int getPageSize()
0, then CacheQueryConfiguration#getPageSize() is used.public T setPageSize(int pageSize)
0, then CacheQueryConfiguration#getPageSize() is used.pageSize - Optional page size.this For chaining.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015