org.opennms.netmgt.newts

Class NewtsWriter

java.lang.Object

org.opennms.netmgt.newts.NewtsWriter

All Implemented Interfaces:

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

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

Used to write samples to the SampleRepository. Calls to #insert() 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
NewtsWriter(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	setIndexer(org.opennms.newts.api.search.Indexer indexer)
void	setSampleRepository(org.opennms.newts.api.SampleRepository sampleRepository)

Methods inherited from class java.lang.Object

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

Constructor Detail

NewtsWriter

@Inject
public NewtsWriter(@Named(value="newts.max_batch_size")
                           Integer maxBatchSize,
                           @Named(value="newts.ring_buffer_size")
                           Integer ringBufferSize,
                           @Named(value="newts.writer_threads")
                           Integer numWriterThreads,
                           @Named(value="newtsMetricRegistry")
                           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

setSampleRepository

public void setSampleRepository(org.opennms.newts.api.SampleRepository sampleRepository)

setIndexer

public void setIndexer(org.opennms.newts.api.search.Indexer indexer)