Package io.openems.backend.timedata.timescaledb.internal.write

Class TimescaledbWriteHandler

java.lang.Object

io.openems.backend.timedata.timescaledb.internal.write.TimescaledbWriteHandler

public class TimescaledbWriteHandler
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_AGGREGATE_WAIT
static int	MAX_POINTS_PER_WRITE
static int	POINTS_QUEUE_SIZE

Constructor Summary

Constructors

Constructor	Description
TimescaledbWriteHandler(Config config, java.util.function.Consumer<Schema> onInitializedSchema)

Method Summary

Modifier and Type	Method	Description
void	deactivate()	Called by TimescaledbImpl deactivate().
java.lang.StringBuilder	debugLog()	Returns a DebugLog String.
java.util.Map<java.lang.String,java.lang.Number>	debugMetrics()	Returns a DebugMetrics map.
void	write(java.lang.String edgeId, com.google.common.collect.TreeBasedTable<java.lang.Long,java.lang.String,com.google.gson.JsonElement> data)	See Timedata.write(String, TreeBasedTable).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

POINTS_QUEUE_SIZE

public static final int POINTS_QUEUE_SIZE

See Also:

Constant Field Values

MAX_POINTS_PER_WRITE

public static final int MAX_POINTS_PER_WRITE

See Also:

Constant Field Values

MAX_AGGREGATE_WAIT

public static final int MAX_AGGREGATE_WAIT

See Also:

Constant Field Values

Constructor Detail

TimescaledbWriteHandler

public TimescaledbWriteHandler(Config config,
                               java.util.function.Consumer<Schema> onInitializedSchema)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

Method Detail

deactivate

public void deactivate()

Called by TimescaledbImpl deactivate().

write

public void write(java.lang.String edgeId,
                  com.google.common.collect.TreeBasedTable<java.lang.Long,java.lang.String,com.google.gson.JsonElement> data)

See Timedata.write(String, TreeBasedTable).

Parameters:

edgeId - The unique Edge-ID

data - Table of timestamp (epoch in milliseconds), Channel-Address and the Channel value as JsonElement. Sorted by timestamp.

Throws:

OpenemsException - on error

debugLog

public java.lang.StringBuilder debugLog()

Returns a DebugLog String.

Returns:

debug log

debugMetrics

public java.util.Map<java.lang.String,java.lang.Number> debugMetrics()

Returns a DebugMetrics map.

Returns:

metrics