public interface DataStore extends DataSink
LOG_NAME_TEMPLATE
Modifier and Type | Method and Description |
---|---|
void |
addDataCountChangeListener(java.beans.PropertyChangeListener listener)
Listener will be notified when new data is available for storage.
|
int |
getDataCount()
Amount of data in the cache available to be forwarded.
|
long |
getOldestTimestamp()
Gets the timestamp of the oldest data, in order to calculate how long
data has been present.
|
void |
removeDataCountChangeListener(java.beans.PropertyChangeListener listener) |
TransactionSet |
takeNext(boolean wait,
int desiredTransactionSize,
java.util.Date olderThan)
Gets the next set of transactions to run.
|
getInfo, getLogName, getPipelineName, getQuarantineManager, isAccepting, shutdown, startup
acceptsData, isLicensedFor, storeData
void addDataCountChangeListener(java.beans.PropertyChangeListener listener)
listener
- void removeDataCountChangeListener(java.beans.PropertyChangeListener listener)
int getDataCount()
long getOldestTimestamp()
TransactionSet takeNext(boolean wait, int desiredTransactionSize, java.util.Date olderThan) throws java.lang.InterruptedException
wait
- whether to block until data is available. If false, or if an
olderThan parameter is provided, will return null if
no data is present.desiredTransactionSize
- the desired size of data in the transactions. ONLY A HINT!
Stores are free to return whatever they think is best. If -1,
it's left to the store's discretion (usually will return 1 at
a time)olderThan
- If null, not used. Otherwise only returns data older than the
given value. Returns null if there is no old data available.java.lang.InterruptedException