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

Class SplitDataWorker

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.common.worker.AbstractImmediateWorker

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

public class SplitDataWorker
extends AbstractImmediateWorker

SplitDataWorker manages an internal Queue which can be filled via addData(String, TreeBasedTable). The worker then splits the data into typed queues for integer, float and string.

Field Summary

Fields inherited from class io.openems.common.worker.AbstractWorker

ALWAYS_WAIT_FOR_TRIGGER_NEXT_RUN, DO_NOT_WAIT, thread

Constructor Summary

Constructors

Constructor	Description
SplitDataWorker(com.zaxxer.hikari.HikariDataSource dataSource, ExecutorService executor, DoubleKeyMap<Type,Priority,QueueHandler<?>> queueHandler, Consumer<Schema> onInitializedSchema)

Method Summary

Modifier and Type	Method	Description
void	addData(String edgeId, com.google.common.collect.TreeBasedTable<Long,String,com.google.gson.JsonElement> table)	Adds new 'write' data to the Queue.
String	debugLog()	Returns a DebugLog String.
protected void	forever()	This method is called in a loop forever until the Thread gets interrupted.

Methods inherited from class io.openems.common.worker.AbstractImmediateWorker

activate, deactivate, getCycleTime

Methods inherited from class io.openems.common.worker.AbstractWorker

activate, modified, modified, setPriority, triggerNextRun

Methods inherited from class java.lang.Object

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

Constructor Details

SplitDataWorker

public SplitDataWorker(com.zaxxer.hikari.HikariDataSource dataSource,
 ExecutorService executor,
 DoubleKeyMap<Type,Priority,QueueHandler<?>> queueHandler,
 Consumer<Schema> onInitializedSchema)

Method Details

addData

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

Adds new 'write' data to the Queue.

Parameters:

edgeId - the Edge-ID

table - the data table

forever

protected void forever()
                throws SQLException,
InterruptedException

Description copied from class: AbstractWorker

This method is called in a loop forever until the Thread gets interrupted.

Specified by:

forever in class AbstractImmediateWorker

Throws:

SQLException

InterruptedException

debugLog

public String debugLog()

Returns a DebugLog String.

Returns:

debug log