Top Inners Fields Constructors Methods
org.terracotta.statistics.archive

public Class StatisticSampler<T extends java.lang.Number>

extends Object
Class Inheritance
Imports
java.util.Date, java.util.concurrent.Executors, .ScheduledExecutorService, .ScheduledFuture, .ThreadFactory, .TimeUnit, org.terracotta.statistics.ValueStatistic

Author
cdennis

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
pack-priv static class
pack-priv static class

Field Summary

Modifier and TypeField and Description
private ScheduledFuture<?>
private final boolean
private final ScheduledExecutorService
private long
private final StatisticSampler.SamplingTask<T>

Constructor Summary

AccessConstructor and Description
public
StatisticSampler(long time, TimeUnit unit, ValueStatistic<T> statistic, SampleSink<Timestamped<T>> sink)

public
StatisticSampler(ScheduledExecutorService executor, long time, TimeUnit unit, ValueStatistic<T> statistic, SampleSink<Timestamped<T>> sink)

Method Summary

Modifier and TypeMethod and Description
public synchronized void
setPeriod(long time, TimeUnit unit)

public synchronized void
public synchronized void
public synchronized void
stop()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

currentExecutionback to summary
private ScheduledFuture<?> currentExecution
exclusiveExecutorback to summary
private final boolean exclusiveExecutor
executorback to summary
private final ScheduledExecutorService executor
periodback to summary
private long period
taskback to summary
private final StatisticSampler.SamplingTask<T> task

Constructor Detail

StatisticSamplerback to summary
public StatisticSampler(long time, TimeUnit unit, ValueStatistic<T> statistic, SampleSink<Timestamped<T>> sink)
StatisticSamplerback to summary
public StatisticSampler(ScheduledExecutorService executor, long time, TimeUnit unit, ValueStatistic<T> statistic, SampleSink<Timestamped<T>> sink)

Method Detail

setPeriodback to summary
public synchronized void setPeriod(long time, TimeUnit unit)
shutdownback to summary
public synchronized void shutdown() throws InterruptedException
startback to summary
public synchronized void start()
stopback to summary
public synchronized void stop()
org.terracotta.statistics.archive back to summary

pack-priv Class StatisticSampler.Sample<T>

extends Object
implements Timestamped<T extends Number>
Class Inheritance
All Implemented Interfaces
org.terracotta.statistics.archive.Timestamped

Field Summary

Modifier and TypeField and Description
private final T
private final long

Constructor Summary

AccessConstructor and Description
public
Sample(long timestamp, T sample)

Method Summary

Modifier and TypeMethod and Description
public T
public long
public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait

Field Detail

sampleback to summary
private final T sample
timestampback to summary
private final long timestamp

Constructor Detail

Sampleback to summary
public Sample(long timestamp, T sample)

Method Detail

getSampleback to summary
public T getSample()

Implements org.terracotta.statistics.archive.Timestamped.getSample.

Annotations
@Override
getTimestampback to summary
public long getTimestamp()

Implements org.terracotta.statistics.archive.Timestamped.getTimestamp.

Annotations
@Override
toStringback to summary
public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations
@Override
org.terracotta.statistics.archive back to summary

pack-priv Class StatisticSampler.SamplerThreadFactory

extends Object
implements ThreadFactory
Class Inheritance
  • java.lang.Object
  • org.terracotta.statistics.archive.StatisticSampler.SamplerThreadFactory
All Implemented Interfaces
java.util.concurrent.ThreadFactory

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
public Thread
newThread(Runnable
a runnable to be executed by new thread instance
r
)

Implements java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

SamplerThreadFactoryback to summary
pack-priv SamplerThreadFactory()

Method Detail

newThreadback to summary
public Thread newThread(Runnable r)

Implements java.util.concurrent.ThreadFactory.newThread.

Doc from java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.

Parameters
r:Runnable

a runnable to be executed by new thread instance

Returns:Thread

constructed thread, or null if the request to create a thread is rejected

Annotations
@Override
org.terracotta.statistics.archive back to summary

pack-priv Class StatisticSampler.SamplingTask<T extends java.lang.Number>

extends Object
implements Runnable
Class Inheritance
  • java.lang.Object
  • org.terracotta.statistics.archive.StatisticSampler.SamplingTask
All Implemented Interfaces
java.lang.Runnable

Field Summary

Modifier and TypeField and Description
private final SampleSink<Timestamped<T>>
private final ValueStatistic<T>

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
public void
run()

Implements java.lang.Runnable.run.

Runs this operation.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sinkback to summary
private final SampleSink<Timestamped<T>> sink
statisticback to summary
private final ValueStatistic<T> statistic

Constructor Detail

SamplingTaskback to summary
pack-priv SamplingTask(ValueStatistic<T> statistic, SampleSink<Timestamped<T>> sink)

Method Detail

runback to summary
public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations
@Override