org.apache.ignite.internal.processors.streamer

Class StreamerStageMetricsAdapter

java.lang.Object

org.apache.ignite.internal.processors.streamer.StreamerStageMetricsAdapter

All Implemented Interfaces:

StreamerStageMetrics

public class StreamerStageMetricsAdapter
extends Object
implements StreamerStageMetrics

Streamer stage metrics adapter.

Constructor Summary

Constructors

Constructor and Description
StreamerStageMetricsAdapter() Empty constructor.
StreamerStageMetricsAdapter(StreamerStageMetrics metrics)

Method Summary

Methods

Modifier and Type	Method and Description
long	averageExecutionTime() Gets stage average execution time.
long	averageWaitingTime() Stage average waiting time.
boolean	executing() Gets flag indicating if stage is being currently executed by at least one thread on current node.
int	failuresCount() Gets stage failure count.
long	maximumExecutionTime() Gets stage maximum execution time.
long	maximumWaitingTime() Gets stage maximum waiting time.
long	minimumExecutionTime() Gets stage minimum execution time.
long	minimumWaitingTime() Gets stage minimum waiting time.
String	name() Gets stage name.
String	toString()
long	totalExecutionCount() Gets total stage execution count since last reset.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamerStageMetricsAdapter

public StreamerStageMetricsAdapter()

Empty constructor.

StreamerStageMetricsAdapter

public StreamerStageMetricsAdapter(StreamerStageMetrics metrics)

Parameters:

metrics - Metrics.

Method Detail

name

public String name()

Gets stage name.

Specified by:

name in interface StreamerStageMetrics

Returns:

Stage name.

minimumExecutionTime

public long minimumExecutionTime()

Gets stage minimum execution time.

Specified by:

minimumExecutionTime in interface StreamerStageMetrics

Returns:

Stage minimum execution time.

maximumExecutionTime

public long maximumExecutionTime()

Gets stage maximum execution time.

Specified by:

maximumExecutionTime in interface StreamerStageMetrics

Returns:

Stage maximum execution time.

averageExecutionTime

public long averageExecutionTime()

Gets stage average execution time.

Specified by:

averageExecutionTime in interface StreamerStageMetrics

Returns:

Stage average execution time.

totalExecutionCount

public long totalExecutionCount()

Gets total stage execution count since last reset.

Specified by:

totalExecutionCount in interface StreamerStageMetrics

Returns:

Number of times this stage was executed.

minimumWaitingTime

public long minimumWaitingTime()

Gets stage minimum waiting time.

Specified by:

minimumWaitingTime in interface StreamerStageMetrics

Returns:

Stage minimum waiting time.

maximumWaitingTime

public long maximumWaitingTime()

Gets stage maximum waiting time.

Specified by:

maximumWaitingTime in interface StreamerStageMetrics

Returns:

Stage maximum waiting time.

averageWaitingTime

public long averageWaitingTime()

Stage average waiting time.

Specified by:

averageWaitingTime in interface StreamerStageMetrics

Returns:

Stage average waiting time.

failuresCount

public int failuresCount()

Gets stage failure count.

Specified by:

failuresCount in interface StreamerStageMetrics

Returns:

Stage failure count.

executing

public boolean executing()

Gets flag indicating if stage is being currently executed by at least one thread on current node.

Specified by:

executing in interface StreamerStageMetrics

Returns:

True if stage is executing now.

toString

public String toString()

Overrides:

toString in class Object