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()
IndexingSpi
public 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
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015