public class RemoteHistorianProvider extends java.lang.Object implements TagHistoryProvider
Modifier and Type | Field and Description |
---|---|
protected LoggerEx |
logger |
protected static ProfileStatus |
RUNNING_READONLY |
protected static ProfileStatus |
SINK_FAULTED |
Constructor and Description |
---|
RemoteHistorianProvider(GatewayContext context,
java.lang.String name,
RemoteHistorianSettings settings) |
Modifier and Type | Method and Description |
---|---|
BrowseResults |
browse(QualifiedPath root,
BrowseFilter filter) |
HistoryQueryExecutor |
createQuery(java.util.List<ColumnQueryDefinition> columns,
QueryController queryController) |
java.util.List<Aggregate> |
getAvailableAggregates()
Returns a list of aggregate functions that can be used with the server.
|
java.lang.String |
getName() |
ProfileStatus |
getStatus() |
TagHistoryProviderInformation |
getStatusInformation() |
protected TagHistoryService |
provider() |
TimelineSet |
queryDensity(java.util.List<QualifiedPath> paths,
java.util.Date start,
java.util.Date end,
java.lang.String queryId) |
void |
shutdown() |
void |
startup() |
protected QualifiedPath |
transformPath(QualifiedPath path,
boolean fromRemote) |
protected QualifiedPath |
transformPathFromRemote(QualifiedPath path) |
protected QualifiedPath |
transformPathToRemote(QualifiedPath path)
Replaces "histProvider" elements with remote provider name
|
protected java.util.Collection<Result> |
transformResultsFromRemote(java.util.Collection<Result> results) |
protected static final ProfileStatus RUNNING_READONLY
protected static final ProfileStatus SINK_FAULTED
protected LoggerEx logger
public RemoteHistorianProvider(GatewayContext context, java.lang.String name, RemoteHistorianSettings settings)
public TagHistoryProviderInformation getStatusInformation()
getStatusInformation
in interface TagHistoryProvider
protected TagHistoryService provider()
public BrowseResults browse(QualifiedPath root, BrowseFilter filter)
browse
in interface TagHistoryProvider
protected java.util.Collection<Result> transformResultsFromRemote(java.util.Collection<Result> results)
protected QualifiedPath transformPathFromRemote(QualifiedPath path)
protected QualifiedPath transformPathToRemote(QualifiedPath path)
protected QualifiedPath transformPath(QualifiedPath path, boolean fromRemote)
public HistoryQueryExecutor createQuery(java.util.List<ColumnQueryDefinition> columns, QueryController queryController)
createQuery
in interface TagHistoryProvider
public java.lang.String getName()
getName
in interface TagHistoryProvider
public ProfileStatus getStatus()
getStatus
in interface TagHistoryProvider
public java.util.List<Aggregate> getAvailableAggregates()
TagHistoryProvider
getAvailableAggregates
in interface TagHistoryProvider
public TimelineSet queryDensity(java.util.List<QualifiedPath> paths, java.util.Date start, java.util.Date end, java.lang.String queryId) throws java.lang.Exception
queryDensity
in interface TagHistoryProvider
java.lang.Exception
public void startup()
startup
in interface TagHistoryProvider
public void shutdown()
shutdown
in interface TagHistoryProvider