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

Status of a ControlSystemChannel.

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