Package | Description |
---|---|
org.dataone.cn.batch.synchronization.tasks |
Modifier and Type | Method and Description |
---|---|
protected SortedHarvestTimepointMap |
ObjectListHarvestTask.getFullObjectList(NodeComm nodeComm,
Integer maxToHarvest)
get the set of timepoints and associated pids to put on the sync queue
|
Modifier and Type | Method and Description |
---|---|
protected void |
ObjectListHarvestTask.spoolToSynchronizationQueue(SortedHarvestTimepointMap harvest,
SyncQueueFacade hzSyncObjectQueue,
NodeRegistrySyncService nodeRegistryService,
Integer requeueTolerance)
Submit the harvest to the sync queue, periodically updating the node's lastHarvestedDate
(able to do this since the pids are already sorted)
|
Copyright © 2021. All rights reserved.