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 Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TimescaledbWriteHandler(Config config, Consumer<Schema> onInitializedSchema)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

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 Details

TimescaledbWriteHandler

public TimescaledbWriteHandler(Config config,
 Consumer<Schema> onInitializedSchema)
                        throws SQLException

Throws:

SQLException

Method Details

deactivate

public void deactivate()

Called by TimescaledbImpl deactivate().

write

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

See

invalid reference

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 StringBuilder debugLog()

Returns a DebugLog String.

Returns:

debug log

debugMetrics

public Map<String,Long> debugMetrics()

Returns a DebugMetrics map.

Returns:

metrics