public class AggregateSink extends java.lang.Object implements DataSink
LOG_NAME_TEMPLATE
Constructor and Description |
---|
AggregateSink(java.lang.String pipelineName,
DataSink... dataSinks) |
Modifier and Type | Method and Description |
---|---|
boolean |
acceptsData(HistoryFlavor dataType)
Returns whether or not the storer can accept the specified type of data.
|
void |
addSink(DataSink sink)
Adds a sink to the list.
|
java.util.List<DataSinkInformation> |
getInfo()
Gets the information for this sink, as well as any below it.
|
java.lang.String |
getPipelineName()
Returns the name of the store and forward pipeline that this sink belongs to.
|
QuarantineManager |
getQuarantineManager()
Returns the quarantine interface for the sink.
|
protected java.util.List<DataSink> |
getSinks() |
boolean |
isAccepting()
Only true if ALL data sinks are accepting.
|
boolean |
isLicensedFor(HistoryFlavor dataType)
Assuming the storer accepts the flavor, is it currently licensed for it? If not, the data will not be stored.
|
void |
removeSink(DataSink sink) |
void |
shutdown() |
void |
startup() |
void |
storeData(HistoricalData data) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getLogName
public AggregateSink(java.lang.String pipelineName, DataSink... dataSinks)
public java.lang.String getPipelineName()
DataSink
getPipelineName
in interface DataSink
protected java.util.List<DataSink> getSinks()
public void addSink(DataSink sink)
public void removeSink(DataSink sink)
public java.util.List<DataSinkInformation> getInfo()
DataSink
public QuarantineManager getQuarantineManager()
DataSink
getQuarantineManager
in interface DataSink
public boolean isAccepting()
isAccepting
in interface DataSink
public boolean acceptsData(HistoryFlavor dataType)
HistoryStorer
acceptsData
in interface HistoryStorer
public boolean isLicensedFor(HistoryFlavor dataType)
HistoryStorer
isLicensedFor
in interface HistoryStorer
public void storeData(HistoricalData data) throws java.lang.Exception
storeData
in interface HistoryStorer
java.lang.Exception