org.apache.ignite.internal.visor.query

Class VisorQueryUtils

java.lang.Object

org.apache.ignite.internal.visor.query.VisorQueryUtils

public class VisorQueryUtils
extends Object

Contains utility methods for Visor query tasks and jobs.

Field Summary

Fields

Modifier and Type	Field and Description
static Integer	RMV_DELAY How long to store future with query in node local map: 5 minutes.
static VisorQueryField[]	SCAN_COL_NAMES Columns for SCAN queries.
static String	SCAN_QRY_NAME Prefix for node local key for SCAN queries.
static String	SQL_QRY_NAME Prefix for node local key for SQL queries.

Constructor Summary

Constructors

Constructor and Description
VisorQueryUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static IgniteBiTuple<List<Object[]>,Map.Entry<Object,Object>>	fetchScanQueryRows(CacheQueryFuture<Map.Entry<Object,Object>> fut, Map.Entry<Object,Object> savedNext, int pageSize) Fetch rows from SCAN query future.
static IgniteBiTuple<List<Object[]>,List<?>>	fetchSqlQueryRows(CacheQueryFuture<List<?>> fut, List<?> savedNext, int pageSize) Collects rows from sql query future, first time creates meta and column names arrays.

Methods inherited from class java.lang.Object

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

Field Detail

RMV_DELAY

public static final Integer RMV_DELAY

How long to store future with query in node local map: 5 minutes.

SQL_QRY_NAME

public static final String SQL_QRY_NAME

Prefix for node local key for SQL queries.

See Also:

Constant Field Values

SCAN_QRY_NAME

public static final String SCAN_QRY_NAME

Prefix for node local key for SCAN queries.

See Also:

Constant Field Values

SCAN_COL_NAMES

public static final VisorQueryField[] SCAN_COL_NAMES

Columns for SCAN queries.

Constructor Detail

VisorQueryUtils

public VisorQueryUtils()

Method Detail

fetchScanQueryRows

public static IgniteBiTuple<List<Object[]>,Map.Entry<Object,Object>> fetchScanQueryRows(CacheQueryFuture<Map.Entry<Object,Object>> fut,
                                                                        Map.Entry<Object,Object> savedNext,
                                                                        int pageSize)
                                                                                 throws IgniteCheckedException

Fetch rows from SCAN query future.

Parameters:

fut - Query future to fetch rows from.

savedNext - Last processed element from future.

pageSize - Number of rows to fetch.

Returns:

Fetched rows and last processed element.

Throws:

IgniteCheckedException

fetchSqlQueryRows

public static IgniteBiTuple<List<Object[]>,List<?>> fetchSqlQueryRows(CacheQueryFuture<List<?>> fut,
                                                      List<?> savedNext,
                                                      int pageSize)
                                                               throws IgniteCheckedException

Collects rows from sql query future, first time creates meta and column names arrays.

Parameters:

fut - Query future to fetch rows from.

savedNext - Last processed element from future.

pageSize - Number of rows to fetch.

Returns:

Fetched rows and last processed element.

Throws:

IgniteCheckedException