public abstract class AbstractDatasourceSink extends AbstractSink
faulted, faultError, faultTime
LOG_NAME_TEMPLATE
Constructor and Description |
---|
AbstractDatasourceSink(GatewayContext context,
java.lang.String dataSource) |
Modifier and Type | Method and Description |
---|---|
GatewayContext |
getContext() |
protected Datasource |
getDatasource() |
java.lang.String |
getDatasourceName() |
protected abstract java.lang.String |
getDescriptionKey() |
java.util.List<DataSinkInformation> |
getInfo()
Gets the information for this sink, as well as any below it.
|
protected QueryCache |
getQueryCache() |
boolean |
isAccepting()
Returns whether the data store is accepting data.
|
protected void |
runFirstTimeChecks(SRConnection conn) |
void |
setDatasourceName(java.lang.String dataSource) |
void |
storeData(HistoricalData data) |
protected abstract void |
storeDataToDatasource(SRConnection conn,
HistoricalData data) |
protected void |
storeToDatasource(Datasource ds,
HistoricalData data) |
protected boolean |
useBatching() |
protected boolean |
useGeneratedKeys() |
createLogger, getFaultReason, getLogger, getPipelineName, getQuarantineManager, initialize, isFaulted, isInitialized, isStarted, setFaulted, setInitialized, shutdown, startup, tryToInit, uninitialize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getLogName
acceptsData, isLicensedFor
public AbstractDatasourceSink(GatewayContext context, java.lang.String dataSource)
public GatewayContext getContext()
public void setDatasourceName(java.lang.String dataSource)
public java.lang.String getDatasourceName()
protected Datasource getDatasource()
protected boolean useBatching()
protected boolean useGeneratedKeys()
protected QueryCache getQueryCache()
protected abstract java.lang.String getDescriptionKey()
public java.util.List<DataSinkInformation> getInfo()
DataSink
public boolean isAccepting()
DataSink
isAccepting
in interface DataSink
isAccepting
in class AbstractSink
public void storeData(HistoricalData data) throws java.lang.Exception
java.lang.Exception
protected void storeToDatasource(Datasource ds, HistoricalData data) throws java.lang.Exception
java.lang.Exception
protected abstract void storeDataToDatasource(SRConnection conn, HistoricalData data) throws java.lang.Exception
java.lang.Exception
protected void runFirstTimeChecks(SRConnection conn) throws java.lang.Exception
java.lang.Exception