|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectuk.ac.starlink.table.StoragePolicy
uk.ac.starlink.table.storage.MonitorStoragePolicy
public class MonitorStoragePolicy
Wrapper storage policy which derives its functionality from an existing ("base") policy, but additionally passes row storage events to a supplied TableSink.
ProgressBarTableSink
Field Summary |
---|
Fields inherited from class uk.ac.starlink.table.StoragePolicy |
---|
ADAPTIVE, DISCARD, PREF_PROPERTY, PREFER_DISK, PREFER_MEMORY, SIDEWAYS |
Constructor Summary | |
---|---|
MonitorStoragePolicy(StoragePolicy base,
TableSink sink)
Constructor. |
Method Summary | |
---|---|
StoragePolicy |
getBasePolicy()
Returns the base storage policy. |
void |
interrupt()
Cancels this storage policy for table row writes. |
boolean |
isInterrupted()
Indicates whether interrupt() has been called on this object. |
ByteStore |
makeByteStore()
Returns a new ByteStore object which can be used to provide a destination for general purpose data storage. |
RowStore |
makeConfiguredRowStore(StarTable meta)
Creates a new RowStore and primes it by calling TableSink.acceptMetadata(uk.ac.starlink.table.StarTable) on it. |
RowStore |
makeRowStore()
Returns a new RowStore object which can be used to provide a destination for random-access table storage. |
Methods inherited from class uk.ac.starlink.table.StoragePolicy |
---|
copyTable, getDefaultPolicy, randomTable, setDefaultPolicy |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public MonitorStoragePolicy(StoragePolicy base, TableSink sink)
base
- base policysink
- recipient for row storage events associated with this
policyMethod Detail |
---|
public void interrupt()
acceptRow
on a RowStore obtained
from this policy after calling this will result in an
InterruptedIOException
.
public boolean isInterrupted()
interrupt()
has been called on this object.
public StoragePolicy getBasePolicy()
public RowStore makeRowStore()
StoragePolicy
makeRowStore
in class StoragePolicy
public RowStore makeConfiguredRowStore(StarTable meta)
StoragePolicy
TableSink.acceptMetadata(uk.ac.starlink.table.StarTable)
on it.
makeConfiguredRowStore
in class StoragePolicy
meta
- template giving the metadata which describes the rows
that will have to be stored
public ByteStore makeByteStore()
StoragePolicy
makeByteStore
in class StoragePolicy
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |