| 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 © 2019. All rights reserved.