Package | Description |
---|---|
org.apache.lucene.replicator.nrt |
Near-real-time replication framework
|
Modifier and Type | Field and Description |
---|---|
FileMetaData |
CopyOneFile.metaData |
Modifier and Type | Field and Description |
---|---|
Map<String,FileMetaData> |
CopyState.files |
protected Map<String,FileMetaData> |
CopyJob.files |
protected Map<String,FileMetaData> |
Node.lastFileMetaData
File metadata for last sync that succeeded; we use this as a cache
|
protected List<Map.Entry<String,FileMetaData>> |
CopyJob.toCopy |
Modifier and Type | Method and Description |
---|---|
FileMetaData |
Node.readLocalFileMetaData(String fileName)
Opens the specified file, reads its identifying information, including file length, full index header (includes the unique segment
ID) and the full footer (includes checksum), and returns the resulting
FileMetaData . |
Modifier and Type | Method and Description |
---|---|
List<Map.Entry<String,FileMetaData>> |
ReplicaNode.getFilesToCopy(Map<String,FileMetaData> files)
Compares incoming per-file identity (id, checksum, header, footer) versus what we have locally and returns the subset of the incoming
files that need copying
|
Modifier and Type | Method and Description |
---|---|
List<Map.Entry<String,FileMetaData>> |
ReplicaNode.getFilesToCopy(Map<String,FileMetaData> files)
Compares incoming per-file identity (id, checksum, header, footer) versus what we have locally and returns the subset of the incoming
files that need copying
|
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.
|
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.
|
protected abstract void |
PrimaryNode.preCopyMergedSegmentFiles(SegmentCommitInfo info,
Map<String,FileMetaData> files)
Called when a merge has finished, but before IW switches to the merged segment
|
Constructor and Description |
---|
CopyOneFile(DataInput in,
ReplicaNode dest,
String name,
FileMetaData metaData,
byte[] buffer) |
Constructor and Description |
---|
CopyJob(String reason,
Map<String,FileMetaData> files,
ReplicaNode dest,
boolean highPriority,
CopyJob.OnceDone onceDone) |
CopyState(Map<String,FileMetaData> files,
long version,
long gen,
byte[] infosBytes,
Set<String> completedMergeFiles,
long primaryGen,
SegmentInfos infos) |
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.