org.apache.ignite.internal.processors.cache.query

Class GridCacheTwoStepQuery

java.lang.Object

org.apache.ignite.internal.processors.cache.query.GridCacheTwoStepQuery

public class GridCacheTwoStepQuery
extends Object

Two step map-reduce style query.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DFLT_PAGE_SIZE

Constructor Summary

Constructors

Constructor and Description
GridCacheTwoStepQuery(Set<String> schemas, Set<String> tbls)

Method Summary

Methods

Modifier and Type	Method and Description
GridCacheTwoStepQuery	addMapQuery(GridCacheSqlQuery qry)
List<Integer>	caches()
void	caches(List<Integer> caches)
GridCacheTwoStepQuery	copy(Object[] args)
boolean	distributedJoins() Check if distributed joins are enabled for this query.
void	distributedJoins(boolean distributedJoins) Specify if distributed joins are enabled for this query.
boolean	explain()
void	explain(boolean explain)
List<Integer>	extraCaches()
void	extraCaches(List<Integer> extraCaches)
List<GridCacheSqlQuery>	mapQueries()
int	pageSize()
void	pageSize(int pageSize)
GridCacheSqlQuery	reduceQuery()
void	reduceQuery(GridCacheSqlQuery rdc)
Set<String>	schemas()
boolean	skipMergeTable()
void	skipMergeTable(boolean skipMergeTbl)
Collection<String>	spaces()
void	spaces(Collection<String> spaces)
Set<String>	tables()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_PAGE_SIZE

public static final int DFLT_PAGE_SIZE

See Also:

Constant Field Values

Constructor Detail

GridCacheTwoStepQuery

public GridCacheTwoStepQuery(Set<String> schemas,
                     Set<String> tbls)

Parameters:

schemas - Schema names in query.

tbls - Tables in query.

Method Detail

distributedJoins

public void distributedJoins(boolean distributedJoins)

Specify if distributed joins are enabled for this query.

Parameters:

distributedJoins - Distributed joins enabled.

distributedJoins

public boolean distributedJoins()

Check if distributed joins are enabled for this query.

Returns:

true If distributed joind enabled.

skipMergeTable

public boolean skipMergeTable()

Returns:

True if reduce query can skip merge table creation and get data directly from merge index.

skipMergeTable

public void skipMergeTable(boolean skipMergeTbl)

Parameters:

skipMergeTbl - Skip merge table.

explain

public boolean explain()

Returns:

If this is explain query.

explain

public void explain(boolean explain)

Parameters:

explain - If this is explain query.

pageSize

public void pageSize(int pageSize)

Parameters:

pageSize - Page size.

pageSize

public int pageSize()

Returns:

Page size.

addMapQuery

public GridCacheTwoStepQuery addMapQuery(GridCacheSqlQuery qry)

Parameters:

qry - SQL Query.

Returns:

this.

reduceQuery

public GridCacheSqlQuery reduceQuery()

Returns:

Reduce query.

reduceQuery

public void reduceQuery(GridCacheSqlQuery rdc)

Parameters:

rdc - Reduce query.

mapQueries

public List<GridCacheSqlQuery> mapQueries()

Returns:

Map queries.

caches

public List<Integer> caches()

Returns:

Caches.

caches

public void caches(List<Integer> caches)

Parameters:

caches - Caches.

extraCaches

public List<Integer> extraCaches()

Returns:

Caches.

extraCaches

public void extraCaches(List<Integer> extraCaches)

Parameters:

extraCaches - Caches.

spaces

public Collection<String> spaces()

Returns:

Spaces.

spaces

public void spaces(Collection<String> spaces)

Parameters:

spaces - Spaces.

schemas

public Set<String> schemas()

Returns:

Schemas.

copy

public GridCacheTwoStepQuery copy(Object[] args)

Parameters:

args - New arguments to copy with.

Returns:

Copy.

tables

public Set<String> tables()

Returns:

Tables.

toString

public String toString()

Overrides:

toString in class Object