Modifier and Type | Method and Description |
---|---|
Serializable |
Content.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
Content.encode(PointValue pointValue)
Encodes the value of a point value.
|
Serializable |
Content.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
PipeEngineRequest.getInputs()
Gets the inputs.
|
PointValue |
PipeSinkRequest.getPointValue()
Gets the point value.
|
PointValue |
PipeEngineRequest.getResult()
Gets the result.
|
protected static PointValue |
PipeRequest.nextPointValue(boolean stampRequired)
Returns the point value from the next input line.
|
static PointValue |
PipeRequest.stringToPointValue(String string)
Converts a string to a point value.
|
Modifier and Type | Method and Description |
---|---|
void |
PipeEngineRequest.addResult(PointValue result)
Adds a result.
|
static String |
PipeRequest.pointValueToString(PointValue pointValue)
Converts a point value to a string.
|
protected static void |
PipeRequest.writePointValue(PointValue pointValue)
Writes a point value.
|
Modifier and Type | Method and Description |
---|---|
PointValue |
StoreValues.getPointValue(int index)
Gets a specified point value.
|
PointValue |
StoreSessionProxy.ValuesIterator.next() |
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
StoreValues.getFirstPointValue()
Gets the first point value.
|
Optional<PointValue> |
StoreValues.getLastPointValue()
Gets the last point value.
|
Optional<PointValue> |
StoreValues.getPointValue()
Gets the single point value.
|
List<PointValue> |
StoreValues.getPointValues()
Gets the point values.
|
Collection<PointValue> |
Store.getUpdates()
Gets the updates not yet sent.
|
Iterable<PointValue> |
StoreValuesQuery.iterate()
Iterates on the point values returned for this store query.
|
Iterable<PointValue> |
Store.iterate(StoreValuesQuery storeQuery)
Iterates on the point values returned for a store query.
|
Iterable<PointValue> |
StoreSessionProxy.iterate(StoreValuesQuery storeQuery,
Optional<Points> points)
Iterates on the point values returned for a store query.
|
ListIterator<PointValue> |
StoreValues.iterator()
Returns a list iterator on the point values.
|
Iterator<PointValue> |
StoreSessionProxy.ValuesIterator.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
StoreValues.add(PointValue pointValue)
Adds a point value.
|
void |
Store.addUpdate(PointValue pointValue)
Added an update for a point value.
|
boolean |
Store.confirm(PointValue pointValue,
boolean confirmValue)
Confirms a point value.
|
void |
StoreValues.mark(PointValue pointValue,
int done)
Creates a mark for the next point value.
|
Optional<Exception> |
StoreSessionProxy.update(PointValue pointValue)
Updates a point value.
|
Exception[] |
StoreSessionProxy.update(PointValue[] pointValues)
Updates point values.
|
Exception[] |
StoreSession.update(PointValue[] pointValues)
Updates point values.
|
boolean |
StoreSessionProxy.updateAndCheck(PointValue[] pointValues,
Logger logger)
Updates point values and check the responses.
|
boolean |
StoreSessionProxy.updateAndCheck(PointValue pointValue,
Logger logger)
Updates a point value and check the response.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Store.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
List<Exception> |
StoreSessionProxy.update(Collection<PointValue> pointValues)
Updates point values.
|
boolean |
StoreSessionProxy.updateAndCheck(Collection<PointValue> pointValues,
Logger logger)
Updates point values and check the responses.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
PointValuesLoader.Input.input()
Inputs a point value.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
PointValueFilters.filter(PointValue pointValue)
Filters a point value.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
PointValueFilters.filter(PointValue pointValue)
Filters a point value.
|
Modifier and Type | Class and Description |
---|---|
class |
ExtrapolatedValue
Extrapolated point value.
|
class |
InterpolatedValue
Interpolated point value.
|
class |
NormalizedValue
Normalized point value.
|
static class |
PointValue.Null
Null.
|
class |
RecalcTrigger
Recalc trigger.
|
class |
ReplicatedValue
Replicated point value.
|
class |
ResultValue
Result Value.
|
class |
SynthesizedValue
Synthesized point value.
|
class |
VersionedValue
Versioned value.
|
static class |
VersionedValue.Deleted
Deleted.
|
static class |
VersionedValue.Purged
Purged.
|
Modifier and Type | Field and Description |
---|---|
static PointValue |
PointValue.NULL
The null point value.
|
Modifier and Type | Method and Description |
---|---|
PointValue |
PointValue.copy()
Creates a copy of this point value.
|
PointValue |
PointValue.decoded()
Returns this or a decoded clone of this.
|
PointValue |
PointValue.denormalized()
Denormalizes this.
|
PointValue |
NormalizedValue.denormalized()
Denormalizes this.
|
PointValue |
PointValue.encoded()
Returns this or an encoded clone of this.
|
PointValue |
PointValue.frozen()
Returns a frozen instance of this.
|
PointValue |
PointValue.morph(Optional<Point> point,
Optional<DateTime> stamp)
Morphs this into a point value for an other point and/or an other time.
|
PointValue |
PointValue.morph(Optional<UUID> uuid)
Morphs this into a point value for an other point.
|
PointValue |
PointValue.reset()
Substitutes serialization/deserialization.
|
PointValue |
PointValue.restore(Point point)
Restores the reference to the point definition.
|
PointValue |
PointValue.restore(Points points)
Restores the reference to the point definition.
|
PointValue |
PointValue.thawed()
Returns a thawed instance of this.
|
Modifier and Type | Method and Description |
---|---|
List<PointValue> |
ResultValue.getInputValues()
Gets the input values.
|
Modifier and Type | Method and Description |
---|---|
void |
ResultValue.addInputValue(PointValue inputValue)
Adds an input value.
|
void |
PointValue.copyValueFrom(PointValue pointValue)
Copies the value from an other point value.
|
boolean |
PointValue.sameValueAs(PointValue pointValue)
Asks if an other point value has the same value.
|
boolean |
PointValue.Null.sameValueAs(PointValue pointValue)
Asks if an other point value has the same value.
|
Constructor and Description |
---|
Deleted(PointValue pointValue)
Constructs an instance.
|
NormalizedValue(PointValue pointValue)
Constructs an instance.
|
Null(PointValue pointValue)
Constructs an instance.
|
PointValue(PointValue other)
Constructs an instance from an other.
|
Purged(PointValue pointValue)
Constructs an instance.
|
ReplicatedValue(PointValue pointValue)
Constructs an instance.
|
VersionedValue(PointValue pointValue)
Constructs an instance from a point value.
|
Modifier and Type | Field and Description |
---|---|
protected static PointValue[] |
ValueFilter.Abstract.NO_POINT_VALUES
No point values.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
ValueFilter.filter(Optional<PointValue> pointValue)
Filters a point value.
|
PointValue[] |
ValueFilter.Abstract.filter(Optional<PointValue> optionalPointValue)
Filters a point value.
|
PointValue[] |
DisabledFilter.filter(Optional<PointValue> pointValue)
Filters a point value.
|
protected PointValue[] |
ValueFilter.Abstract.pointValues(PointValue... pointValues)
Returns the point values into an array.
|
protected PointValue |
ValueFilter.Abstract.snap(PointValue pointValue)
Snaps the point value.
|
protected PointValue |
StepFilter.snap(PointValue pointValue)
Snaps the point value.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Optional<PointValue> |
ValueFilter.Abstract.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected Optional<PointValue> |
LinearFilter.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected Optional<PointValue> |
InterpolatorFilter.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected Optional<PointValue> |
DeadbandFilter.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected Optional<PointValue> |
ValueFilter.Abstract.getHeldPointValue()
Gets the held point value.
|
protected Optional<PointValue> |
ValueFilter.Abstract.getPreviousPointValue()
Gets the previous point value.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Optional<PointValue> |
ValueFilter.Abstract.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected Optional<PointValue> |
LinearFilter.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected Optional<PointValue> |
InterpolatorFilter.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected Optional<PointValue> |
DeadbandFilter.doFilter(PointValue pointValue)
Says if a value should be filtered.
|
protected PointValue[] |
ValueFilter.Abstract.pointValues(PointValue... pointValues)
Returns the point values into an array.
|
protected static Double |
InterpolatorFilter.polate(DateTime stamp,
PointValue pointValue1,
PointValue pointValue2)
Polates.
|
protected void |
ValueFilter.Abstract.setHeldPointValue(PointValue heldPointValue)
Sets the held point value.
|
protected void |
ValueFilter.Abstract.setPreviousPointValue(PointValue previousValue)
Sets the previous point value.
|
protected PointValue |
ValueFilter.Abstract.snap(PointValue pointValue)
Snaps the point value.
|
protected PointValue |
StepFilter.snap(PointValue pointValue)
Snaps the point value.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
ValueFilter.filter(Optional<PointValue> pointValue)
Filters a point value.
|
PointValue[] |
ValueFilter.Abstract.filter(Optional<PointValue> optionalPointValue)
Filters a point value.
|
PointValue[] |
DisabledFilter.filter(Optional<PointValue> pointValue)
Filters a point value.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
PointValuesLoaderInput.input()
Inputs a point value.
|
Modifier and Type | Method and Description |
---|---|
void |
XMLPointValuesPortClient.sendValue(PointValue pointValue)
Sends a point value.
|
Modifier and Type | Method and Description |
---|---|
Short |
ClockContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Long |
ClockContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Modifier and Type | Method and Description |
---|---|
Serializable |
TupleContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
String |
StringContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
State |
StateContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
SIContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Short |
ShortContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
RationalContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Long |
LongContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Integer |
IntegerContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Float |
FloatContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Double |
DoubleContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
DictContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
ComplexContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Byte |
ByteContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Boolean |
BooleanContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
BigRationalContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
BigIntegerContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
BigDecimalContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
AbstractContent.decode(PointValue pointValue)
Decodes the value of a point value.
|
Serializable |
TupleContent.encode(PointValue pointValue)
Encodes the value of a point value.
|
Serializable |
DictContent.encode(PointValue pointValue)
Encodes the value of a point value.
|
Serializable |
AbstractContent.encode(PointValue pointValue)
Encodes the value of a point value.
|
protected Double |
DoubleContent.getDouble(PointValue pointValue)
Gets a Double object from the value.
|
protected Float |
FloatContent.getFloat(PointValue pointValue)
Gets a Float object from the value.
|
Double |
UnitValueContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
TupleContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Double |
TemperatureContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
String |
StringContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
SIContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Short |
ShortContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
RationalContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Long |
LongContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Integer |
IntegerContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Float |
FloatContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Double |
DoubleContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
DictContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
ComplexContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Byte |
ByteContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Boolean |
BooleanContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
BigRationalContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
BigIntegerContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
BigDecimalContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
Serializable |
AbstractContent.normalize(PointValue pointValue)
Normalizes the value of a point value.
|
protected void |
AbstractContent.warnBadValue(PointValue pointValue)
Warns about the bad format of a value.
|
Modifier and Type | Method and Description |
---|---|
protected Optional<PointValue> |
ForwarderFilter.Abstract.knownPointValue(Serializable message)
Returns the message as a known point value.
|
Modifier and Type | Method and Description |
---|---|
void |
SOMNotifier.notify(PointValue[] notices)
Queues the supplied point values.
|
abstract void |
NoticeContext.notify(PointValue[] notices)
Queues the supplied point values.
|
Modifier and Type | Method and Description |
---|---|
boolean |
BehaviorEntityReference.isInputValid(PointValue inputValue,
ResultValue resultValue)
Asks if a point value is valid for the computation of a result value.
|
boolean |
BehaviorEntityReference.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
BehaviorEntityReference.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
void |
BehaviorEntityReference.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
Modifier and Type | Field and Description |
---|---|
static PointValue |
Batch.DISABLED_UPDATE
Disabled update marker.
|
Modifier and Type | Field and Description |
---|---|
static Comparator<PointValue> |
Batch.POINT_EVENT_COMPARATOR
Point event comparator
|
Modifier and Type | Method and Description |
---|---|
PointValue |
Batch.getPointValue(BatchValuesQuery batchQuery)
Gets a point value as specified in a batch query.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
Transform.applyTo(ResultValue resultValue,
Batch batch)
Applies the program to provide the specified result value.
|
Collection<PointValue> |
Batch.getPointValues(BatchValuesQuery batchQuery)
Gets point values as specified in a batch query.
|
Optional<Collection<PointValue>> |
Processor.process(Collection<PointValue> pointValues)
Processes point values.
|
Modifier and Type | Method and Description |
---|---|
void |
Batch.addUpdate(PointValue pointValue)
Adds an update.
|
void |
Batch.forgetInputValue(PointValue inputValue)
Forgets an input value.
|
Optional<ResultValue> |
Batch.getResultValue(PointValue pointValue)
Gets a result value.
|
boolean |
Behavior.isInputValid(PointValue inputValue,
ResultValue resultValue)
Asks if a point value is valid for the computation of a result value.
|
boolean |
Behavior.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
Behavior.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
void |
Batch.scheduleUpdate(PointValue update)
Schedules an update.
|
ResultValue |
Batch.setUpResultValue(PointValue notice,
DateTime stamp,
Behavior caller)
Sets up a result value for processing.
|
void |
Behavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
Modifier and Type | Method and Description |
---|---|
void |
Batch.acceptNotices(Collection<PointValue> notices)
Accepts notices.
|
Optional<Collection<PointValue>> |
Processor.process(Collection<PointValue> pointValues)
Processes point values.
|
Modifier and Type | Method and Description |
---|---|
Optional<Collection<PointValue>> |
ProcessorServiceAppImpl.process(Collection<PointValue> pointValues)
Processes point values.
|
Modifier and Type | Method and Description |
---|---|
Optional<Collection<PointValue>> |
ProcessorServiceAppImpl.process(Collection<PointValue> pointValues)
Processes point values.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
PrimaryBehavior.addInputToResult(PointValue inputValue,
ResultValue resultValue)
Adds an input for computing the result.
|
protected Optional<DateTime> |
PrimaryBehavior.getSynchronizedResultStamp(PointValue inputValue,
Batch batch)
Gets the synchronized result stamp.
|
boolean |
Synchronized.isInputValid(PointValue inputValue,
ResultValue resultValue)
Asks if a point value is valid for the computation of a result value.
|
boolean |
AbstractBehavior.isInputValid(PointValue inputValue,
ResultValue resultValue)
Asks if a point value is valid for the computation of a result value.
|
boolean |
TriggersNew.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
Retriggers.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
AlwaysTriggers.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
AbstractBehavior.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
TriggersNew.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
boolean |
Synchronized.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
boolean |
Retriggers.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
boolean |
NeverTriggers.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
boolean |
AlwaysTriggers.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
boolean |
AbstractBehavior.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
void |
TriggersNew.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
void |
Synchronized.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
void |
Retriggers.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
void |
NeverTriggers.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
void |
AlwaysTriggers.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
void |
AbstractBehavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractTransform.addUpdate(PointValue pointValue,
Batch batch)
Adds an update to the point's store.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
ControlTransform.applyTo(ResultValue resultValue,
Batch batch)
Applies the program to provide the specified result value.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ControlsBehavior.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
void |
ControlsBehavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
Modifier and Type | Method and Description |
---|---|
List<PointValue> |
ScriptExecutor.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
List<PointValue> |
PipeExecutor.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
List<PointValue> |
EngineExecutor.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
RemoteExecutorTransform.applyTo(ResultValue resultValue,
Batch batch)
Applies the program to provide the specified result value.
|
List<PointValue> |
RemoteEngineSessionImpl.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
List<PointValue> |
RemoteEngineSession.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
List<PointValue> |
RemoteEngineProxy.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
StepFilteredBehavior.filter(PointValue noticeValue,
Optional<PointValue> previousValue,
Optional<PointValue> synthesizedValue)
Asks if a point value notice should be filtered out.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
StepFilteredBehavior.filter(PointValue noticeValue,
Optional<PointValue> previousValue,
Optional<PointValue> synthesizedValue)
Asks if a point value notice should be filtered out.
|
boolean |
StepFilteredBehavior.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
StepFilteredBehavior.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
void |
StepFilteredBehavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
Modifier and Type | Method and Description |
---|---|
PointValue[] |
StepFilteredBehavior.filter(PointValue noticeValue,
Optional<PointValue> previousValue,
Optional<PointValue> synthesizedValue)
Asks if a point value notice should be filtered out.
|
PointValue[] |
StepFilteredBehavior.filter(PointValue noticeValue,
Optional<PointValue> previousValue,
Optional<PointValue> synthesizedValue)
Asks if a point value notice should be filtered out.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ReplicatedBehavior.isResultFetched(PointValue noticeValue,
ResultValue resultValue)
Asks if result value has been fetched.
|
boolean |
ResynchronizedBehavior.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
void |
ResynchronizedBehavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
void |
ReplicatedBehavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
Modifier and Type | Method and Description |
---|---|
PointValue |
RPNExecutor.execute(String source,
String[] macros,
String[] words,
ResultValue resultValue,
Logger logger)
Executes the program compiled from the source on the resultValue's
inputs.
|
PointValue |
Task.Context.getNormalizedResultValue()
Gets the result value.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
RPNTransform.applyTo(ResultValue resultValue,
Batch batch)
Applies the program to provide the specified result value.
|
Optional<PointValue> |
Task.execute(Program program)
Executes the program to compute a result value.
|
Optional<PointValue> |
Task.getInput(Integer index)
Gets a numbered input.
|
protected Optional<PointValue> |
Task.Context.getInputValue(int index)
Gets a numbered input.
|
Optional<? extends PointValue> |
Task.getNormalizedInput(Integer index)
Gets a normalized numbered input.
|
Optional<PointValue> |
Task.Context.getResult()
Gets the result.
|
Optional<PointValue> |
Task.Context.getStoredValue()
Gets the stored value.
|
static Optional<PointValue> |
RPNExecutor.returnResult(ResultValue resultValue,
Optional<PointValue> optionalPointValue)
Returns a result from a result value and a point value.
|
Modifier and Type | Method and Description |
---|---|
void |
Task.Context.addUpdate(PointValue update)
Adds an update.
|
Modifier and Type | Method and Description |
---|---|
static Optional<PointValue> |
RPNExecutor.returnResult(ResultValue resultValue,
Optional<PointValue> optionalPointValue)
Returns a result from a result value and a point value.
|
Modifier and Type | Class and Description |
---|---|
class |
Selection
Selection.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
SelectorTransform.applyTo(ResultValue resultValue,
Batch batch)
Applies the program to provide the specified result value.
|
Optional<? extends PointValue> |
SelectorTransform.Context.getCurrentStep()
Gets the current step.
|
Optional<? extends PointValue> |
SelectorTransform.Context.getFirstStep()
Gets the first step.
|
Optional<? extends PointValue> |
SelectorTransform.Context.getLastStep()
Gets the last step.
|
Optional<? extends PointValue> |
SelectorTransform.Context.getNextStep()
Gets the next step.
|
Optional<? extends PointValue> |
SelectorTransform.Context.getPreviousStep()
Gets the previous step.
|
Optional<? extends PointValue> |
SelectorTransform.Context.getStart()
Gets the start point value for the interval.
|
Optional<PointValue> |
Selection.getStartValue()
Gets the point value starting the interval.
|
Optional<PointValue> |
SelectorTransform.Context.getStop()
Gets the stop point value for the interval.
|
Optional<PointValue> |
Selection.getStopValue()
Gets the point value stopping the interval.
|
protected abstract Optional<PointValue> |
SelectorTransform.returnResult(ResultValue resultValue,
Optional<PointValue> pointValue)
Returns a result.
|
Modifier and Type | Method and Description |
---|---|
void |
Selection.setStartValue(PointValue startValue)
Sets the point value starting the interval.
|
void |
Selection.setStopValue(PointValue stopValue)
Sets the point value stopping the interval.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Optional<PointValue> |
SelectorTransform.returnResult(ResultValue resultValue,
Optional<PointValue> pointValue)
Returns a result.
|
Modifier and Type | Method and Description |
---|---|
protected Optional<PointValue> |
SummarizerTransform.returnResult(ResultValue resultValue,
Optional<PointValue> pointValue)
Returns a result.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SummarizesBehavior.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
boolean |
SummarizedBehavior.prepareTrigger(PointValue noticeValue,
Batch batch)
Allows a behavior to prepare for a call to
Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) . |
void |
SummarizesBehavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
void |
SummarizedBehavior.trigger(PointValue noticeValue,
Batch batch)
Triggers the computation of results if needed.
|
Modifier and Type | Method and Description |
---|---|
protected Optional<PointValue> |
SummarizerTransform.returnResult(ResultValue resultValue,
Optional<PointValue> pointValue)
Returns a result.
|
Modifier and Type | Method and Description |
---|---|
protected Optional<PointValue> |
StoreListenerReceptionist.doFetchNotice(int limit,
long wait)
Fetches a notice.
|
protected Optional<PointValue> |
SOMReceptionist.doFetchNotice(int limit,
long wait)
Fetches a notice.
|
protected abstract Optional<PointValue> |
Receptionist.Abstract.doFetchNotice(int limit,
long wait)
Fetches a notice.
|
List<PointValue> |
Receptionist.fetchNotices(int limit,
long wait)
Fetches notices.
|
List<PointValue> |
Receptionist.Abstract.fetchNotices(int limit,
long wait)
Fetches notices.
|
Modifier and Type | Method and Description |
---|---|
Collection<PointValue> |
AbstractStore.getUpdates()
Gets the updates not yet sent.
|
Iterable<PointValue> |
RMIStore.iterate(StoreValuesQuery query)
Iterates on the point values returned for a store query.
|
Iterable<PointValue> |
AbstractStore.iterate(StoreValuesQuery query)
Iterates on the point values returned for a store query.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractStore.addUpdate(PointValue pointValue)
Added an update for a point value.
|
boolean |
RMIStore.confirm(PointValue pointValue,
boolean confirmValue)
Confirms a point value.
|
boolean |
AbstractStore.confirm(PointValue pointValue,
boolean confirmValue)
Confirms a point value.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SOMSink.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
RMIStore.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
RMISink.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
NullStore.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
Modifier and Type | Method and Description |
---|---|
protected PointValue[] |
Replicator.Abstract.filter(PointValue pointValue)
Filters a point value.
|
Modifier and Type | Method and Description |
---|---|
Optional<? extends PointValue> |
StoreCursor.Responder.next()
Returns the next point value.
|
protected abstract Optional<PointValue> |
UpdatesListener.Abstract.nextUpdate(int limit,
boolean wait)
Returns the next update.
|
Modifier and Type | Method and Description |
---|---|
void |
StoreServiceAppImpl.addNotice(PointValue notice)
Adds a notice.
|
void |
StoreServer.Abstract.addNotice(PointValue notice)
Adds a notice.
|
protected Optional<Exception> |
StoreServer.Abstract.checkUpdate(PointValue pointValue,
Optional<Identity> identity)
Checks if an update on a point's values is allowed for the identity.
|
protected boolean |
NullNotifier.doNotify(PointValue pointValue)
Does notify of a new Point value.
|
protected abstract boolean |
Notifier.Abstract.doNotify(PointValue pointValue)
Does notify of a new Point value.
|
protected PointValue[] |
Replicator.Abstract.filter(PointValue pointValue)
Filters a point value.
|
protected boolean |
Replicator.Abstract.isReplicated(PointValue pointValue)
Asks if a point value is replicated.
|
void |
Notifier.Abstract.notify(PointValue pointValue)
Notifies of a new Point value.
|
void |
NoticeListener.notify(PointValue pointValue)
Notifies of a new Point value.
|
void |
Replicator.replicate(PointValue pointValue)
Replicates of a point value.
|
void |
Replicator.Abstract.replicate(PointValue pointValue)
Replicates of a point value.
|
protected Exception[] |
StoreServer.Abstract.restoreUpdates(PointValue[] updates)
Restore point references and values for updates.
|
Exception[] |
StoreServer.update(PointValue[] pointValues,
Optional<Identity> identity)
Updates point values.
|
protected VersionedValue |
StoreServer.Abstract.versionedValue(PointValue update)
Returns a versioned value for an update.
|
Modifier and Type | Method and Description |
---|---|
void |
Archiver.Attic.put(Collection<PointValue> archivedValues)
Puts archived point values into the attic.
|
Modifier and Type | Method and Description |
---|---|
protected abstract PointValue |
Polator.Abstract.extrapolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore)
Extrapolates a value.
|
protected PointValue |
LinearPolator.extrapolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore)
Extrapolates a value.
|
protected PointValue |
LevelPolator.extrapolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore)
Extrapolates a value.
|
protected abstract PointValue |
Polator.Abstract.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
protected PointValue |
LinearPolator.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
protected PointValue |
LevelPolator.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
Modifier and Type | Method and Description |
---|---|
protected static Double |
Polator.Abstract.decode(PointValue pointValue)
Decodes the value from a point value.
|
protected abstract PointValue |
Polator.Abstract.extrapolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore)
Extrapolates a value.
|
protected PointValue |
LinearPolator.extrapolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore)
Extrapolates a value.
|
protected PointValue |
LevelPolator.extrapolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore)
Extrapolates a value.
|
protected abstract PointValue |
Polator.Abstract.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
protected abstract PointValue |
Polator.Abstract.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
protected PointValue |
LinearPolator.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
protected PointValue |
LinearPolator.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
protected PointValue |
LevelPolator.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
protected PointValue |
LevelPolator.interpolate(StoreValuesQuery polatedQuery,
DateTime stamp,
PointValue[] pointValuesBefore,
PointValue[] pointValuesAfter)
Interpolates a value.
|
Modifier and Type | Method and Description |
---|---|
void |
StoreSessionImpl.notify(PointValue pointValue)
Notifies of a new Point value.
|
Exception[] |
StoreSessionImpl.update(PointValue[] updates)
Updates point values.
|
Modifier and Type | Method and Description |
---|---|
protected Optional<PointValue> |
SOMUpdatesListener.nextUpdate(int limit,
boolean wait)
Returns the next update.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
SOMNotifier.doNotify(PointValue pointValue)
Does notify of a new Point value.
|
Modifier and Type | Method and Description |
---|---|
void |
SOMAttic.put(Collection<PointValue> archivedValues)
Puts archived point values into the attic.
|
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.