Class QueueHandler.FloatQueueHandler
java.lang.Object
io.openems.backend.timedata.timescaledb.internal.write.QueueHandler<Point.FloatPoint>
io.openems.backend.timedata.timescaledb.internal.write.QueueHandler.FloatQueueHandler
- Enclosing class:
QueueHandler<T extends Point>
-
Nested Class Summary
Nested classes/interfaces inherited from class io.openems.backend.timedata.timescaledb.internal.write.QueueHandler
QueueHandler.FloatQueueHandler, QueueHandler.IntQueueHandler, QueueHandler.StringQueueHandler
-
Constructor Summary
ConstructorDescriptionFloatQueueHandler
(com.zaxxer.hikari.HikariDataSource dataSource, ExecutorService executor, Type type, Priority priority) -
Method Summary
Modifier and TypeMethodDescriptionprotected Point.FloatPoint
dataToPointConverter
(Schema.ChannelRecord channel, ZonedDateTime time, com.google.gson.JsonElement json) Methods inherited from class io.openems.backend.timedata.timescaledb.internal.write.QueueHandler
activate, debugLog, getMergePointsWorker, of, offer
-
Constructor Details
-
FloatQueueHandler
public FloatQueueHandler(com.zaxxer.hikari.HikariDataSource dataSource, ExecutorService executor, Type type, Priority priority)
-
-
Method Details
-
dataToPointConverter
protected Point.FloatPoint dataToPointConverter(Schema.ChannelRecord channel, ZonedDateTime time, com.google.gson.JsonElement json) throws OpenemsError.OpenemsNamedException - Specified by:
dataToPointConverter
in classQueueHandler<Point.FloatPoint>
- Throws:
OpenemsError.OpenemsNamedException
-