Package | Description |
---|---|
org.dataone.cn.batch.synchronization | |
org.dataone.cn.batch.synchronization.tasks |
Modifier and Type | Method and Description |
---|---|
NodeComm |
NodeCommFactory.getNodeComm(org.dataone.service.types.v1.NodeReference mnNode) |
NodeComm |
NodeCommObjectListHarvestFactory.getNodeComm(org.dataone.service.types.v1.NodeReference mnNodeId) |
NodeComm |
NodeCommSyncObjectFactory.getNodeComm(org.dataone.service.types.v1.NodeReference mnNodeId)
returns a NodeComm set to the RUNNING state.
|
Modifier and Type | Method and Description |
---|---|
protected Date |
ObjectListHarvestTask.adjustFilterWindow(NodeComm nc,
int total,
int max,
Date fromDate,
Date toDate)
This method should optimize the time window size so that the total within group is not
more than the maximum synchronization will take.
|
protected SortedHarvestTimepointMap |
ObjectListHarvestTask.getFullObjectList(NodeComm nodeComm,
Integer maxToHarvest)
get the set of timepoints and associated pids to put on the sync queue
|
Constructor and Description |
---|
SyncFailedTask(NodeComm nodeCommunications,
org.dataone.cn.synchronization.types.SyncObject task) |
TransferObjectTask(NodeComm nodeCommunications,
org.dataone.cn.synchronization.types.SyncObject task) |
V2TransferObjectTask(NodeComm nodeCommunications,
org.dataone.cn.synchronization.types.SyncObject task) |
Copyright © 2019. All rights reserved.