Package org.opennms.netmgt.timeseries.samplewrite

Class TimeseriesPersister

java.lang.Object

org.opennms.netmgt.collection.support.AbstractCollectionSetVisitor

org.opennms.netmgt.collection.api.AbstractPersister

org.opennms.netmgt.timeseries.samplewrite.TimeseriesPersister

All Implemented Interfaces:

CollectionSetVisitor, Persister

public class TimeseriesPersister
extends AbstractPersister

TimeseriesPersister persistence strategy. Both string and numeric attributes are persisted via TimeseriesPersistOperationBuilder. String attributes: We collect all attributes within a resource and commit them when we finished the collection. We cannot commit earlier since we need to collect the resource level string attributes. They can be part of any group within the resource but need to be applied to all metrics in the resource. Therefore, we need to collect all attributes under the resource Structure: - resource + group + resource level string attribute + numeric attributes

Field Summary

Fields inherited from class org.opennms.netmgt.collection.api.AbstractPersister

LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TimeseriesPersister(ServiceParameters params, RrdRepository repository, TimeseriesWriter timeseriesWriter, MetaTagDataLoader metaDataLoader, Cache<ResourcePath,Set<org.opennms.integration.api.v1.timeseries.Tag>> configuredAdditionalMetaTagCache, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
void	commitBuilder(TimeseriesPersistOperationBuilder builder)
void	completeResource(CollectionResource resource)	completeResource
void	persistNumericAttribute(CollectionAttribute attribute)	Persists a metric level string attribute.
protected void	persistStringAttribute(ResourcePath path, String key, String value)	Persists a resource level string attribute.
void	visitGroup(AttributeGroup group)	visitGroup
void	visitResource(CollectionResource resource)	visitResource

Methods inherited from class org.opennms.netmgt.collection.api.AbstractPersister

commitBuilder, completeAttribute, completeGroup, getRepository, isIgnorePersist, isPersistDisabled, persistStringAttribute, popShouldPersist, pushShouldPersist, pushShouldPersist, pushShouldPersist, setBuilder, setIgnorePersist, setRepository, shouldPersist, storeAttribute, visitAttribute

Methods inherited from class org.opennms.netmgt.collection.support.AbstractCollectionSetVisitor

completeCollectionSet, visitCollectionSet

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opennms.netmgt.collection.api.CollectionSetVisitor

completeCollectionSet, visitCollectionSet

Constructor Detail

TimeseriesPersister

protected TimeseriesPersister(ServiceParameters params,
                              RrdRepository repository,
                              TimeseriesWriter timeseriesWriter,
                              MetaTagDataLoader metaDataLoader,
                              Cache<ResourcePath,Set<org.opennms.integration.api.v1.timeseries.Tag>> configuredAdditionalMetaTagCache,
                              com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

visitResource

public void visitResource(CollectionResource resource)

Description copied from class: AbstractPersister

visitResource

Specified by:

visitResource in interface CollectionSetVisitor

Overrides:

visitResource in class AbstractPersister

Parameters:

resource - a CollectionResource object.

visitGroup

public void visitGroup(AttributeGroup group)

visitGroup

Specified by:

visitGroup in interface CollectionSetVisitor

Overrides:

visitGroup in class AbstractPersister

Parameters:

group - a org.opennms.netmgt.collectd.AttributeGroup object.

persistStringAttribute

protected void persistStringAttribute(ResourcePath path,
                                      String key,
                                      String value)
                               throws PersistException

Persists a resource level string attribute.

Specified by:

persistStringAttribute in class AbstractPersister

Throws:

PersistException

completeResource

public void completeResource(CollectionResource resource)

Description copied from class: AbstractPersister

completeResource

Specified by:

completeResource in interface CollectionSetVisitor

Overrides:

completeResource in class AbstractPersister

Parameters:

resource - a CollectionResource object.

commitBuilder

public void commitBuilder(TimeseriesPersistOperationBuilder builder)

persistNumericAttribute

public void persistNumericAttribute(CollectionAttribute attribute)

Persists a metric level string attribute.

Specified by:

persistNumericAttribute in interface Persister

Overrides:

persistNumericAttribute in class AbstractPersister

Parameters:

attribute - a CollectionAttribute object.