Package com.inductiveautomation.historian.gateway.interop

Class TagHistoryStorageEngineBridge

java.lang.Object

com.inductiveautomation.historian.gateway.api.storage.AbstractStorageEngine

com.inductiveautomation.historian.gateway.interop.TagHistoryStorageEngineBridge

All Implemented Interfaces:

SnapshotProcessor, StorageEngine

public class TagHistoryStorageEngineBridge
extends AbstractStorageEngine
implements SnapshotProcessor

This class is used to store TagGroupHistorySets from our new Historian system. This would be used by an old implmentation that was being adapted, but which did not want to move away from using these structures. This class attempts to preserve as much of the original behavior as possible, though of course with the changes to the methodology between systems, some minor variances may be present. The old system did not work off of registration, it simply sent the information it thought that storage needed each time through HistoricalTagValues, in addition to info on the set. This implementation, however, DOES rely on tag registration for key attributes, such as timestamp mode and interpolation mode.

Nested Class Summary

Nested classes/interfaces inherited from class com.inductiveautomation.historian.gateway.api.storage.AbstractStorageEngine

AbstractStorageEngine.StorageMetrics

Field Summary

Fields inherited from class com.inductiveautomation.historian.gateway.api.storage.AbstractStorageEngine

gatewayContext, historianName, logger, metrics, pathAdapter, supportedChangeTypes, supportedComplexTypes

Method Summary

Modifier and Type	Method	Description
protected StorageResult<AnnotationChangePoint>	applyAnnotationChanges(List<AnnotationChangePoint> annotationChangePoints)
protected StorageResult<SourceChangePoint>	applySourceChanges(List<SourceChangePoint> sourceChangePoints)
protected StorageResult<AnnotationPoint>	doStoreAnnotations(List<AnnotationPoint> annotationPoints)
protected StorageResult<AtomicPoint<?>>	doStoreAtomic(List<AtomicPoint<?>> atomicPoints)
protected StorageResult<MetadataPoint>	doStoreMetadata(List<MetadataPoint> metadataPoints)
static TagHistoryStorageEngineBridge	getOrCreate(GatewayContext context, String historianName)
static TagHistoryStorageEngineBridge	getOrCreate(GatewayContext context, String historianName, String databaseName)
DataCollector	getOrCreateDataCollector(CollectorId collectorId)	Creates an instance of DataCollector for managing data collection and storage operations based on the specified CollectorId.
StorageId	getSfStorageId()
protected boolean	isEngineUnavailable()
CompletionStage<Void>	process(CollectionSnapshot snapshot)
static void	removeInstance(String historianName)

Methods inherited from class com.inductiveautomation.historian.gateway.api.storage.AbstractStorageEngine

applyChanges, doApplyChanges, doStoreComplex, shutdownProcessor, storeAtomic, storeComplex

Methods inherited from class java.lang.Object

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

Method Details

getOrCreate

public static TagHistoryStorageEngineBridge getOrCreate(GatewayContext context,
 String historianName,
 @Nullable
 String databaseName)

getOrCreate

public static TagHistoryStorageEngineBridge getOrCreate(GatewayContext context,
 String historianName)

removeInstance

public static void removeInstance(String historianName)

getOrCreateDataCollector

public DataCollector getOrCreateDataCollector(CollectorId collectorId)

Description copied from interface: StorageEngine

Creates an instance of DataCollector for managing data collection and storage operations based on the specified CollectorId.

Specified by:

getOrCreateDataCollector in interface StorageEngine

Parameters:

collectorId - the CollectorId that will be used to identify and configure the data collector.

Returns:

an instance of DataCollector configured for the given collection mode

process

public CompletionStage<Void> process(CollectionSnapshot snapshot)

Specified by:

process in interface SnapshotProcessor

getSfStorageId

public StorageId getSfStorageId()

applySourceChanges

protected StorageResult<SourceChangePoint> applySourceChanges(List<SourceChangePoint> sourceChangePoints)

Specified by:

applySourceChanges in class AbstractStorageEngine

doStoreAtomic

protected StorageResult<AtomicPoint<?>> doStoreAtomic(List<AtomicPoint<?>> atomicPoints)

Specified by:

doStoreAtomic in class AbstractStorageEngine

isEngineUnavailable

protected boolean isEngineUnavailable()

Specified by:

isEngineUnavailable in class AbstractStorageEngine

doStoreAnnotations

protected StorageResult<AnnotationPoint> doStoreAnnotations(List<AnnotationPoint> annotationPoints)

Overrides:

doStoreAnnotations in class AbstractStorageEngine

doStoreMetadata

protected StorageResult<MetadataPoint> doStoreMetadata(List<MetadataPoint> metadataPoints)

Overrides:

doStoreMetadata in class AbstractStorageEngine

applyAnnotationChanges

protected StorageResult<AnnotationChangePoint> applyAnnotationChanges(List<AnnotationChangePoint> annotationChangePoints)

Overrides:

applyAnnotationChanges in class AbstractStorageEngine