Package org.apache.ignite.internal.processors.performancestatistics

Class PerformanceStatisticsProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.performancestatistics.PerformanceStatisticsProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class PerformanceStatisticsProcessor
extends GridProcessorAdapter

Performance statistics processor.

Manages collecting performance statistics.

See Also:

FilePerformanceStatisticsWriter, FilePerformanceStatisticsReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PerformanceStatisticsProcessor.PerformanceStatisticsStateListener	Performance statistics state listener.

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor	Description
PerformanceStatisticsProcessor(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
void	cacheOperation(OperationType type, int cacheId, long startTime, long duration)
void	cacheStart(int cacheId, String name)
void	checkpoint(long beforeLockDuration, long lockWaitDuration, long listenersExecDuration, long markDuration, long lockHoldDuration, long pagesWriteDuration, long fsyncDuration, long walCpRecordFsyncDuration, long writeCpEntryDuration, long splitAndSortCpPagesDuration, long totalDuration, long cpStartTime, int pagesSize, int dataPagesWritten, int cowPagesWritten)
boolean	enabled()
static String	indexQueryText(String cacheName, IndexQueryDesc desc)
void	job(IgniteUuid sesId, long queuedTime, long startTime, long duration, boolean timedOut)
void	onDisconnected(IgniteFuture<?> reconnectFut)	Client disconnected callback.
void	onKernalStop(boolean cancel)	Callback to notify that kernal is about to stop.
void	pagesWriteThrottle(long endTime, long duration)
void	query(GridCacheQueryType type, String text, long id, long startTime, long duration, boolean success)
void	queryProperty(GridCacheQueryType type, UUID qryNodeId, long id, String name, String val)
void	queryReads(GridCacheQueryType type, UUID queryNodeId, long id, long logicalReads, long physicalReads)
void	queryRowsProcessed(GridCacheQueryType type, UUID qryNodeId, long id, String action, long rows)
void	registerStateListener(PerformanceStatisticsProcessor.PerformanceStatisticsStateListener lsnr)	Registers state listener.
void	rotateCollectStatistics()	Rotate collecting performance statistics.
void	start()	Starts grid component.
void	startCollectStatistics()	Starts collecting performance statistics.
void	stopCollectStatistics()	Stops collecting performance statistics.
void	task(IgniteUuid sesId, String taskName, long startTime, long duration, int affPartId)
void	transaction(GridIntList cacheIds, long startTime, long duration, boolean commited)

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onReconnected, printMemoryStats, stop, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

PerformanceStatisticsProcessor

public PerformanceStatisticsProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

registerStateListener

public void registerStateListener(PerformanceStatisticsProcessor.PerformanceStatisticsStateListener lsnr)

Registers state listener.

cacheStart

public void cacheStart(int cacheId,
                       String name)

Parameters:

cacheId - Cache id.

name - Cache name.

cacheOperation

public void cacheOperation(OperationType type,
                           int cacheId,
                           long startTime,
                           long duration)

Parameters:

type - Operation type.

cacheId - Cache id.

startTime - Start time in milliseconds.

duration - Duration in nanoseconds.

transaction

public void transaction(GridIntList cacheIds,
                        long startTime,
                        long duration,
                        boolean commited)

Parameters:

cacheIds - Cache IDs.

startTime - Start time in milliseconds.

duration - Duration in nanoseconds.

commited - True if commited.

query

public void query(GridCacheQueryType type,
                  String text,
                  long id,
                  long startTime,
                  long duration,
                  boolean success)

Parameters:

type - Cache query type.

text - Query text in case of SQL query. Cache name in case of SCAN query. In case of an INDEX query, the text represents the pattern:

<cacheName>:<indexName>:<valueType>:<comma separated fields>

id - Query id.

startTime - Start time in milliseconds.

duration - Duration in nanoseconds.

success - Success flag.

queryReads

public void queryReads(GridCacheQueryType type,
                       UUID queryNodeId,
                       long id,
                       long logicalReads,
                       long physicalReads)

Parameters:

type - Cache query type.

queryNodeId - Originating node id.

id - Query id.

logicalReads - Number of logical reads.

physicalReads - Number of physical reads.

queryRowsProcessed

public void queryRowsProcessed(GridCacheQueryType type,
                               UUID qryNodeId,
                               long id,
                               String action,
                               long rows)

Parameters:

type - Cache query type.

qryNodeId - Originating node id.

id - Query id.

action - Action with rows.

rows - Number of rows processed.

queryProperty

public void queryProperty(GridCacheQueryType type,
                          UUID qryNodeId,
                          long id,
                          String name,
                          String val)

Parameters:

type - Cache query type.

qryNodeId - Originating node id.

id - Query id.

name - Query property name.

val - Query property value.

task

public void task(IgniteUuid sesId,
                 String taskName,
                 long startTime,
                 long duration,
                 int affPartId)

Parameters:

sesId - Session id.

taskName - Task name.

startTime - Start time in milliseconds.

duration - Duration.

affPartId - Affinity partition id.

job

public void job(IgniteUuid sesId,
                long queuedTime,
                long startTime,
                long duration,
                boolean timedOut)

Parameters:

sesId - Session id.

queuedTime - Time job spent on waiting queue.

startTime - Start time in milliseconds.

duration - Job execution time.

timedOut - True if job is timed out.

checkpoint

public void checkpoint(long beforeLockDuration,
                       long lockWaitDuration,
                       long listenersExecDuration,
                       long markDuration,
                       long lockHoldDuration,
                       long pagesWriteDuration,
                       long fsyncDuration,
                       long walCpRecordFsyncDuration,
                       long writeCpEntryDuration,
                       long splitAndSortCpPagesDuration,
                       long totalDuration,
                       long cpStartTime,
                       int pagesSize,
                       int dataPagesWritten,
                       int cowPagesWritten)

Parameters:

beforeLockDuration - Before lock duration.

lockWaitDuration - Lock wait duration.

listenersExecDuration - Listeners execute duration.

markDuration - Mark duration.

lockHoldDuration - Lock hold duration.

pagesWriteDuration - Pages write duration.

fsyncDuration - Fsync duration.

walCpRecordFsyncDuration - Wal cp record fsync duration.

writeCpEntryDuration - Write checkpoint entry duration.

splitAndSortCpPagesDuration - Split and sort cp pages duration.

totalDuration - Total duration in milliseconds.

cpStartTime - Checkpoint start time in milliseconds.

pagesSize - Pages size.

dataPagesWritten - Data pages written.

cowPagesWritten - Cow pages written.

pagesWriteThrottle

public void pagesWriteThrottle(long endTime,
                               long duration)

Parameters:

endTime - End time in milliseconds.

duration - Duration in milliseconds.

startCollectStatistics

public void startCollectStatistics()
                            throws IgniteCheckedException

Starts collecting performance statistics.

Throws:

IgniteCheckedException - If starting failed.

stopCollectStatistics

public void stopCollectStatistics()
                           throws IgniteCheckedException

Stops collecting performance statistics.

Throws:

IgniteCheckedException - If stopping failed.

rotateCollectStatistics

public void rotateCollectStatistics()
                             throws IgniteCheckedException

Rotate collecting performance statistics.

Throws:

IgniteCheckedException - If rotation failed.

enabled

public boolean enabled()

Returns:

True if collecting performance statistics is enabled.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

onDisconnected

public void onDisconnected(IgniteFuture<?> reconnectFut)

Client disconnected callback.

Specified by:

onDisconnected in interface GridComponent

Overrides:

onDisconnected in class GridProcessorAdapter

Parameters:

reconnectFut - Reconnect future.

indexQueryText

public static String indexQueryText(String cacheName,
                                    IndexQueryDesc desc)

Returns:

Text representation of index query.