@ThreadSafe public class CatalogCollectionManager extends MFileCollectionManager implements CatalogCrawler.Listener
CollectionManager.ChangeChecker, CollectionManager.Force, CollectionManager.TriggerEvent, CollectionManager.TriggerListener, CollectionManager.TriggerType
CATALOG, config, dateExtractor, startPartition
auxInfo, changeChecker, collectionName, logger, protoChoice, recheck
Constructor and Description |
---|
CatalogCollectionManager(String collection) |
Modifier and Type | Method and Description |
---|---|
boolean |
getCatalogRef(InvCatalogRef dd,
Object context)
Gets called for each catalogRef found
|
void |
getDataset(InvDataset ds,
Object context)
Gets called for each dataset found.
|
protected boolean |
hasScans() |
static void |
main(String[] arg) |
protected void |
reallyScan(Map<String,MFile> map) |
addDirectoryScan, extractRunDate, getController, getFiles, getLastScanned, getOlderThanFilterInMSecs, getRoot, getStartCollection, hasDateExtractor, isScanNeeded, open, openWithRecheck, scan, scanDebug, scanIfNeeded, setController, setDateExtractor, setFiles, toString
addEventListener, cleanName, close, createListenerManager, deleteOld, enableMetadataManager, getAuxInfo, getCollectionName, getFilenames, getLatestFile, getMetadata, getProtoIndex, getRecheck, isStatic, putAuxInfo, putMetadata, removeEventListener, resetProto, setChangeChecker, setStatic, updateNocheck
public CatalogCollectionManager(String collection)
protected boolean hasScans()
hasScans
in class MFileCollectionManager
protected void reallyScan(Map<String,MFile> map) throws IOException
reallyScan
in class MFileCollectionManager
IOException
public void getDataset(InvDataset ds, Object context)
CatalogCrawler.Listener
getDataset
in interface CatalogCrawler.Listener
ds
- the datasetcontext
- caller can pass this object in (used for thread safety)public boolean getCatalogRef(InvCatalogRef dd, Object context)
CatalogCrawler.Listener
getCatalogRef
in interface CatalogCrawler.Listener
dd
- the datasetcontext
- caller can pass this object in (used for thread safety)public static void main(String[] arg) throws IOException
IOException
Copyright © 1999–2014 UCAR/Unidata. All rights reserved.