public class OptimizedTableEngine extends java.lang.Object implements DataHandler
Modifier and Type | Class and Description |
---|---|
protected class |
OptimizedTableEngine.PartitionManagingWriter |
Constructor and Description |
---|
OptimizedTableEngine(GatewayContext context,
java.lang.String dsName,
long windowSizeMS,
PartitionManager pMgr) |
Modifier and Type | Method and 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 org.apache.log4j.Logger |
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() |
public OptimizedTableEngine(GatewayContext context, java.lang.String dsName, long windowSizeMS, PartitionManager pMgr)
protected org.apache.log4j.Logger getLogger()
protected PartitionManager getPartitionManager()
protected long getWindowSize()
public SRConnection getConnection() throws java.sql.SQLException
java.sql.SQLException
protected java.lang.String getDSQuoteChar()
public boolean isAccepting()
public void startup()
public void shutdown()
protected void asyncStart()
protected void catchup() throws java.lang.Exception
java.lang.Exception
protected long getMaxTimestamp(java.lang.String partitionName) throws java.lang.Exception
java.lang.Exception
public void putValue(RawTagValue inValue) throws java.lang.Exception
DataHandler
putValue
in interface DataHandler
java.lang.Exception
public void flush() throws java.lang.Exception
DataHandler
flush
in interface DataHandler
java.lang.Exception