Skip navigation links
A B C D E F G H I J O P R S T V W 

A

AbstractSampleDecimator<SampleType extends Sample> - Class in com.aquenos.cassandra.pvarchiver.controlsystem
Abstract base class for sample decimator implementations.
AbstractSampleDecimator(String, long, long) - Constructor for class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractSampleDecimator
Creates the sample decimator and initializes the channel name and the interval start-time and length with the specified values.
AbstractStatefulSampleDecimator<SampleType extends Sample> - Class in com.aquenos.cassandra.pvarchiver.controlsystem
Abstract base class for sample decimator implementations, handling some of the state management.
AbstractStatefulSampleDecimator(String, long, long) - Constructor for class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractStatefulSampleDecimator
Creates the sample decimator and initializes the channel name and the interval start-time and length with the specified values.
all() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
 

B

buildDecimatedSample() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractStatefulSampleDecimator
 
buildDecimatedSample() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleDecimator
Builds the decimated sample.
buildDecimatedSampleInternal() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractStatefulSampleDecimator
Builds the decimated sample.

C

com.aquenos.cassandra.pvarchiver.controlsystem - package com.aquenos.cassandra.pvarchiver.controlsystem
Provides the link between the archive server and the control-system specific support modules.
com.aquenos.cassandra.pvarchiver.controlsystem.util - package com.aquenos.cassandra.pvarchiver.controlsystem.util
Utility classes that are used by both the server and control-system-specific code.
connected() - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
Returns a status that indicates that the channel is connected.
ControlSystemChannel - Interface in com.aquenos.cassandra.pvarchiver.controlsystem
Control-system side of an archived channel.
ControlSystemChannelStatus - Class in com.aquenos.cassandra.pvarchiver.controlsystem
ControlSystemChannelStatus.State - Enum in com.aquenos.cassandra.pvarchiver.controlsystem
State of a control-system channel.
ControlSystemSupport<SampleType extends Sample> - Interface in com.aquenos.cassandra.pvarchiver.controlsystem
Interface to a control-system support module.
ControlSystemSupportFactory - Interface in com.aquenos.cassandra.pvarchiver.controlsystem
Factory that can create a ControlSystemSupport.
createChannel(String, Map<String, String>, SampleBucketId, SampleListener<SampleType>) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Creates the control-system-specific support for an archived channel.
createControlSystemSupport(Map<String, String>, Session) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupportFactory
Creates an instance of the control-system support associated with this factory.
createSampleDecimator(String, Map<String, String>, long, long) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Creates a sample decimator.

D

deleteSamples(SampleBucketId) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Deletes all samples associated with the specified sample bucket.
destroy() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannel
Destroys the control-system channel.
destroy() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Destroys this control-system support.
disabled() - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
Returns a status that indicates that archiving for the channel has been temporarily disabled.
disconnected() - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
Returns a status that indicates that the channel is disconnected.

E

equals(Object) - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
 
equals(Object) - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketId
 
equals(Object) - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketState
 
equals(Object) - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleWithSizeEstimate
 
error(Throwable) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
Returns a status that indicates that the channel is in the error state.

F

fetchMoreResults() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
 

G

generateChannelDisabledSample(String, Map<String, String>, SampleBucketId) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Generates a sample that indicates that the specified channel is disabled.
getAvailableWithoutFetching() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
 
getBucketStartTime() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketId
Returns the start time of the sample bucket as the number of nanoseconds since epoch (January 1st, 1970, 00:00:00 UTC).
getChannelDataId() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketId
Returns the unique identifier that is associated with the data (samples) for the channel.
getChannelName() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractSampleDecimator
 
getChannelName() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannel
Returns the channel name identifying this channel.
getChannelName() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleDecimator
Returns the name of the channel for which this sample decimator decimates samples.
getConfigurationPrefix() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupportFactory
Returns the prefix used for the configuration options associated with this control-system support.
getCurrentBucketSize() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketState
Returns the current size of the sample bucket (in bytes).
getDecimatedSample() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleDecimator
Returns the decimated sample that has been generated by SampleDecimator.buildDecimatedSample().
getDecimatedSampleEstimatedSize() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleDecimator
Returns the estimated size of the decimated sample.
getDecimationLevel() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketId
Returns the decimation level for which the sample bucket stores data.
getError() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
Returns the error associated with the channel status.
getEstimatedSampleSize() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleWithSizeEstimate
Returns the estimated size of the sample that is returned by SampleWithSizeEstimate.getSample().
getId() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Returns the identifier that uniquely identifies the control-system support module.
getIntervalLength() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractSampleDecimator
 
getIntervalLength() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleDecimator
Returns the length of the period for which this sample decimator generates a decimated sample.
getIntervalStartTime() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractSampleDecimator
 
getIntervalStartTime() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleDecimator
Returns the start time of the period for which this sample decimator generated a decimated sample.
getLatestSampleTimeStamp() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketState
Returns the time stamp of the newest sample in the bucket.
getName() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Returns a short, descriptive name for this control-system support, suitable for display.
getSample() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleWithSizeEstimate
Returns the sample that is supposed to be written.
getSampleBucketState(SampleBucketId) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Returns the state of the specified sample bucket.
getSamples(SampleBucketId, long, long, int) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Retrieves samples from the specified sample bucket.
getSamplesInReverseOrder(SampleBucketId, long, long, int) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Retrieves samples from the specified sample bucket in reverse order (newer samples first).
getState() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
Returns the channel's state.
getStatus() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannel
Returns the channel status.
getTimeStamp() - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.Sample
Returns the time stamp associated with the sample.

H

hashCode() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
 
hashCode() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketId
 
hashCode() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketState
 
hashCode() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleWithSizeEstimate
 

I

isExhausted() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
 
isFullyFetched() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
 
iterator() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
 

J

JsonV1SampleSerializer - Class in com.aquenos.cassandra.pvarchiver.controlsystem.util
Utility for serializing samples in the JSON format version 1.
JsonV1SampleSerializer.Quality - Enum in com.aquenos.cassandra.pvarchiver.controlsystem.util
Sample quality.
JsonV1SampleSerializer.Severity - Enum in com.aquenos.cassandra.pvarchiver.controlsystem.util
Alarm severity associated with a sample.

O

one() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
 
onSampleReceived(ControlSystemChannel, SampleType, int) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleListener
Notifies the listener that a new sample is available.

P

processSample(SampleType) - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractStatefulSampleDecimator
 
processSample(SampleType) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.SampleDecimator
Processes a sample, updating the internal state with the information from the sample.
processSampleInternal(SampleType, long, long) - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.AbstractStatefulSampleDecimator
Processes a sample, updating the decimators internal state.

R

ResultSetBasedObjectResultSet<V> - Class in com.aquenos.cassandra.pvarchiver.controlsystem.util
Object result-set implementation that is backed by a Cassandra ResultSet.
ResultSetBasedObjectResultSet(ResultSet, Function<? super Row, ? extends V>) - Constructor for class com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet
Creates a object result-set that is backed by the specified Cassandra result-set.

S

Sample - Interface in com.aquenos.cassandra.pvarchiver.controlsystem
Base interface for control-system samples.
SampleBucketId - Class in com.aquenos.cassandra.pvarchiver.controlsystem
Identifier for a sample bucket.
SampleBucketId(UUID, int, long) - Constructor for class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketId
Create an identifier for a sample bucket.
SampleBucketState - Class in com.aquenos.cassandra.pvarchiver.controlsystem
State information about a sample bucket.
SampleBucketState(int, long) - Constructor for class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketState
Creates an object representing the specified sample-bucket state.
SampleDecimator<SampleType extends Sample> - Interface in com.aquenos.cassandra.pvarchiver.controlsystem
Stateful utility that decimates samples.
SampleListener<SampleType extends Sample> - Interface in com.aquenos.cassandra.pvarchiver.controlsystem
Listener that is notified of new samples for a control-system channel.
SAMPLES_LIMIT_UNBOUNDED - Static variable in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Number to be specified when samples should be retrieved without limiting their number.
SampleWithSizeEstimate<SampleType extends Sample> - Class in com.aquenos.cassandra.pvarchiver.controlsystem
Pair of a sample and its estimated size.
SampleWithSizeEstimate(SampleType, int) - Constructor for class com.aquenos.cassandra.pvarchiver.controlsystem.SampleWithSizeEstimate
Creates a pair that stored the specified sample and estimated size.
serializeDoubleSample(JsonGenerator, long, double, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar double sample without additional meta-data.
serializeDoubleSample(JsonGenerator, long, double, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, int, String, double, double, double, double, double, double) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar double sample with additional meta-data.
serializeDoubleSample(JsonGenerator, long, double[], JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array double sample without additional meta-data.
serializeDoubleSample(JsonGenerator, long, double[], JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, int, String, double, double, double, double, double, double) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array double sample with additional meta-data.
serializeEnumSample(JsonGenerator, long, int, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar enum sample without additional meta-data.
serializeEnumSample(JsonGenerator, long, int, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, String[]) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar enum sample with additional meta-data.
serializeEnumSample(JsonGenerator, long, int[], JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array enum sample without additional meta-data.
serializeEnumSample(JsonGenerator, long, int[], JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, String[]) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array enum sample without additional meta-data.
serializeLongSample(JsonGenerator, long, long, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar long sample without additional meta-data.
serializeLongSample(JsonGenerator, long, long, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, int, String, double, double, double, double, double, double) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar long sample with additional meta-data.
serializeLongSample(JsonGenerator, long, long[], JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array long sample without additional meta-data.
serializeLongSample(JsonGenerator, long, long[], JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, int, String, double, double, double, double, double, double) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array long sample with additional meta-data.
serializeMinMaxDoubleSample(JsonGenerator, long, double, double, double, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar min-max double sample without additional meta-data.
serializeMinMaxDoubleSample(JsonGenerator, long, double, double, double, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, int, String, double, double, double, double, double, double) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar min-max double sample with additional meta-data.
serializeMinMaxDoubleSample(JsonGenerator, long, double[], double, double, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array min-max double sample without additional meta-data.
serializeMinMaxDoubleSample(JsonGenerator, long, double[], double, double, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality, int, String, double, double, double, double, double, double) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array min-max double sample with additional meta-data.
serializeSampleToJsonV1(SampleType, JsonGenerator) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Serializes a sample in the JSON format version 1.
serializeStringSample(JsonGenerator, long, String, JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes a scalar (single element) string sample.
serializeStringSample(JsonGenerator, long, String[], JsonV1SampleSerializer.Severity, boolean, String, JsonV1SampleSerializer.Quality) - Static method in class com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer
Serializes an array string sample.

T

toString() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus
 
toString() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketId
 
toString() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleBucketState
 
toString() - Method in class com.aquenos.cassandra.pvarchiver.controlsystem.SampleWithSizeEstimate
 

V

valueOf(String) - Static method in enum com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer.Quality
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer.Severity
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemChannelStatus.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer.Quality
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.aquenos.cassandra.pvarchiver.controlsystem.util.JsonV1SampleSerializer.Severity
Returns an array containing the constants of this enum type, in the order they are declared.

W

writeSample(SampleType, SampleBucketId, int) - Method in interface com.aquenos.cassandra.pvarchiver.controlsystem.ControlSystemSupport
Writes a sample to the database.
A B C D E F G H I J O P R S T V W 
Skip navigation links

Copyright © 2011–2019 aquenos GmbH. All rights reserved.