org.opennms.netmgt.timeseries.integration

Class TimeseriesWriter

java.lang.Object

org.opennms.netmgt.timeseries.integration.TimeseriesWriter

All Implemented Interfaces:

com.lmax.disruptor.WorkHandler<SampleBatchEvent>, org.springframework.beans.factory.DisposableBean

public class TimeseriesWriter
extends Object
implements com.lmax.disruptor.WorkHandler<SampleBatchEvent>, org.springframework.beans.factory.DisposableBean

Used to write samples to the SampleRepository. Calls to publish the samples to a ring buffer so that they don't block while the data is being persisted.

Author:

jwhite

Constructor Summary

Constructors

Constructor and Description
TimeseriesWriter(Integer maxBatchSize, Integer ringBufferSize, Integer numWriterThreads, com.codahale.metrics.MetricRegistry registry)

Method Summary

Modifier and Type	Method and Description
void	destroy()
void	index(List<org.opennms.newts.api.Sample> samples)
void	insert(List<org.opennms.newts.api.Sample> samples)
void	onEvent(SampleBatchEvent event)
void	setTimeSeriesMetaDataDao(TimeSeriesMetaDataDao timeSeriesMetaDataDao)
void	setTimeSeriesStorage(TimeseriesStorageManager timeseriesStorage)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeseriesWriter

@Inject
public TimeseriesWriter(@Named(value="timeseries.max_batch_size")
                                Integer maxBatchSize,
                                @Named(value="timeseries.ring_buffer_size")
                                Integer ringBufferSize,
                                @Named(value="timeseries.writer_threads")
                                Integer numWriterThreads,
                                @Named(value="timeseriesMetricRegistry")
                                com.codahale.metrics.MetricRegistry registry)

Method Detail

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

insert

public void insert(List<org.opennms.newts.api.Sample> samples)

index

public void index(List<org.opennms.newts.api.Sample> samples)

onEvent

public void onEvent(SampleBatchEvent event)
             throws Exception

Specified by:

onEvent in interface com.lmax.disruptor.WorkHandler<SampleBatchEvent>

Throws:

Exception

setTimeSeriesStorage

public void setTimeSeriesStorage(TimeseriesStorageManager timeseriesStorage)

setTimeSeriesMetaDataDao

public void setTimeSeriesMetaDataDao(TimeSeriesMetaDataDao timeSeriesMetaDataDao)