Uses of Class
neqsim.process.streaming.TimestampedValue
Packages that use TimestampedValue
-
Uses of TimestampedValue in neqsim.process.streaming
Fields in neqsim.process.streaming with type parameters of type TimestampedValueModifier and TypeFieldDescriptionprivate final Map<String, TimestampedValue> ProcessDataPublisher.currentValuesprivate final Map<String, LinkedList<TimestampedValue>> ProcessDataPublisher.historyprivate final Map<String, List<Consumer<TimestampedValue>>> ProcessDataPublisher.subscribersMethods in neqsim.process.streaming that return TimestampedValueModifier and TypeMethodDescriptionProcessDataPublisher.getCurrentValue(String tagId) StreamingDataInterface.getCurrentValue(String tagId) Get the current value for a tag.static TimestampedValueCreates a new TimestampedValue marked as simulated.Methods in neqsim.process.streaming that return types with arguments of type TimestampedValueModifier and TypeMethodDescriptionProcessDataPublisher.getHistory(String tagId, Duration lookback) StreamingDataInterface.getHistory(String tagId, Duration lookback) Get historical values for a tag.ProcessDataPublisher.getHistoryBatch(List<String> tagIds, Duration lookback) StreamingDataInterface.getHistoryBatch(List<String> tagIds, Duration lookback) Get historical values for multiple tags aligned by timestamp.Methods in neqsim.process.streaming with parameters of type TimestampedValueModifier and TypeMethodDescriptiondefault voidStreamingDataInterface.publish(String tagId, TimestampedValue value) Publish a single value for a tag.Method parameters in neqsim.process.streaming with type arguments of type TimestampedValueModifier and TypeMethodDescriptionvoidProcessDataPublisher.publishBatch(Map<String, TimestampedValue> values) voidStreamingDataInterface.publishBatch(Map<String, TimestampedValue> values) Publish a batch of values for multiple tags efficiently.voidProcessDataPublisher.subscribeToUpdates(String tagId, Consumer<TimestampedValue> callback) voidStreamingDataInterface.subscribeToUpdates(String tagId, Consumer<TimestampedValue> callback) Subscribe to real-time updates for a specific tag.