Class OptimizedTableEngine
- java.lang.Object
-
- com.inductiveautomation.gateway.tags.history.storage.OptimizedTableEngine
-
- All Implemented Interfaces:
DataHandler
public class OptimizedTableEngine extends java.lang.Object implements DataHandler
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected class
OptimizedTableEngine.PartitionManagingWriter
-
Constructor Summary
Constructors Constructor Description OptimizedTableEngine(GatewayContext context, java.lang.String dsName, long windowSizeMS, PartitionManager pMgr)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
asyncStart()
protected void
catchup()
void
flush()
Indicate that the handler won't get any more data, at least for a while.SRConnection
getConnection()
protected java.lang.String
getDSQuoteChar()
protected LoggerEx
getLogger()
protected long
getMaxTimestamp(java.lang.String partitionName)
protected PartitionManager
getPartitionManager()
protected long
getWindowSize()
boolean
isAccepting()
We only accept new data when we're up to date.void
putValue(RawTagValue inValue)
Insert a value into the handler.void
shutdown()
void
startup()
-
-
-
Constructor Detail
-
OptimizedTableEngine
public OptimizedTableEngine(GatewayContext context, java.lang.String dsName, long windowSizeMS, PartitionManager pMgr)
-
-
Method Detail
-
getLogger
protected LoggerEx getLogger()
-
getPartitionManager
protected PartitionManager getPartitionManager()
-
getWindowSize
protected long getWindowSize()
-
getConnection
public SRConnection getConnection() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getDSQuoteChar
protected java.lang.String getDSQuoteChar()
-
isAccepting
public boolean isAccepting()
We only accept new data when we're up to date.
-
startup
public void startup()
-
shutdown
public void shutdown()
-
asyncStart
protected void asyncStart()
-
catchup
protected void catchup() throws java.lang.Exception
- Throws:
java.lang.Exception
-
getMaxTimestamp
protected long getMaxTimestamp(java.lang.String partitionName) throws java.lang.Exception
- Throws:
java.lang.Exception
-
putValue
public void putValue(RawTagValue inValue) throws java.lang.Exception
Description copied from interface:DataHandler
Insert a value into the handler.- Specified by:
putValue
in interfaceDataHandler
- Throws:
java.lang.Exception
-
flush
public void flush() throws java.lang.Exception
Description copied from interface:DataHandler
Indicate that the handler won't get any more data, at least for a while.- Specified by:
flush
in interfaceDataHandler
- Throws:
java.lang.Exception
-
-