Package | Description |
---|---|
org.apache.lucene.replicator.nrt |
Near-real-time replication framework
|
Modifier and Type | Field and Description |
---|---|
protected CopyJob |
ReplicaNode.curNRTCopy
Non-null when we are currently copying files from a new NRT point:
|
Modifier and Type | Field and Description |
---|---|
protected Set<CopyJob> |
ReplicaNode.mergeCopyJobs
Currently running merge pre-copy jobs
|
Modifier and Type | Method and Description |
---|---|
protected CopyJob |
ReplicaNode.launchPreCopyMerge(AtomicBoolean finished,
long newPrimaryGen,
Map<String,FileMetaData> files) |
protected abstract CopyJob |
ReplicaNode.newCopyJob(String reason,
Map<String,FileMetaData> files,
Map<String,FileMetaData> prevFiles,
boolean highPriority,
CopyJob.OnceDone onceDone)
Start a background copying job, to copy the specified files from the current primary node.
|
CopyJob |
ReplicaNode.newNRTPoint(long newPrimaryGen,
long version)
Call this to notify this replica node that a new NRT infos is available on the primary.
|
Modifier and Type | Method and Description |
---|---|
abstract boolean |
CopyJob.conflicts(CopyJob other)
Return true if this job is trying to copy any of the same files as the other job
|
protected void |
ReplicaNode.finishNRTCopy(CopyJob job,
long startNS) |
protected abstract void |
ReplicaNode.launch(CopyJob job)
Runs this job async'd
|
void |
CopyJob.OnceDone.run(CopyJob job) |
void |
CopyJob.transferAndCancel(CopyJob prevJob)
Transfers whatever tmp files were already copied in this previous job and cancels the previous job
|
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.