org.apache.lucene.replicator.nrt

Class ReplicaNode

java.lang.Object

org.apache.lucene.replicator.nrt.Node

org.apache.lucene.replicator.nrt.ReplicaNode

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public abstract class ReplicaNode
extends Node

Replica node, that pulls index changes from the primary node by copying newly flushed or merged index files.

Field Summary

Fields

Modifier and Type	Field and Description
protected CopyJob	curNRTCopy Non-null when we are currently copying files from a new NRT point:
protected java.util.Collection<java.lang.String>	lastNRTFiles IncRef'd files in the current NRT point:
protected long	lastPrimaryGen Primary gen last time we successfully replicated:
protected java.util.Set<CopyJob>	mergeCopyJobs Currently running merge pre-copy jobs

Fields inherited from class org.apache.lucene.replicator.nrt.Node

dir, globalStartNS, id, lastFileMetaData, localStartNS, mgr, PRIMARY_GEN_KEY, printStream, searcherFactory, VERBOSE_CONNECTIONS, VERBOSE_FILES, VERSION_KEY

Constructor Summary

Constructors

Constructor and Description
ReplicaNode(int id, Directory dir, SearcherFactory searcherFactory, java.io.PrintStream printStream)

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit()
IndexOutput	createTempOutput(java.lang.String prefix, java.lang.String suffix, IOContext ioContext)
void	finishCopyFile(java.lang.String name)
protected void	finishNRTCopy(CopyJob job, long startNS)
java.util.List<java.util.Map.Entry<java.lang.String,FileMetaData>>	getFilesToCopy(java.util.Map<java.lang.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
boolean	isClosed()
boolean	isCopying()
protected abstract void	launch(CopyJob job) Runs this job async'd
protected CopyJob	launchPreCopyMerge(java.util.concurrent.atomic.AtomicBoolean finished, long newPrimaryGen, java.util.Map<java.lang.String,FileMetaData> files)
protected void	maybeNewPrimary(long newPrimaryGen) Called when the primary changed
protected abstract CopyJob	newCopyJob(java.lang.String reason, java.util.Map<java.lang.String,FileMetaData> files, java.util.Map<java.lang.String,FileMetaData> prevFiles, boolean highPriority, CopyJob.OnceDone onceDone) Start a background copying job, to copy the specified files from the current primary node.
CopyJob	newNRTPoint(long newPrimaryGen, long version) Call this to notify this replica node that a new NRT infos is available on the primary.
protected abstract void	sendNewReplica() Tell primary we (replica) just started, so primary can tell us to warm any already warming merges.
protected void	start(long curPrimaryGen) Start up this replica, which possibly requires heavy copying of files from the primary node, if we were down for a long time
void	startCopyFile(java.lang.String name)

Methods inherited from class org.apache.lucene.replicator.nrt.Node

bytesToString, getCurrentSearchingVersion, getDirectory, getSearcherManager, message, name, nodeMessage, nodeMessage, readLocalFileMetaData, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

lastNRTFiles

protected final java.util.Collection<java.lang.String> lastNRTFiles

IncRef'd files in the current NRT point:

mergeCopyJobs

protected final java.util.Set<CopyJob> mergeCopyJobs

Currently running merge pre-copy jobs

curNRTCopy

protected CopyJob curNRTCopy

Non-null when we are currently copying files from a new NRT point:

lastPrimaryGen

protected long lastPrimaryGen

Primary gen last time we successfully replicated:

Constructor Detail

ReplicaNode

public ReplicaNode(int id,
                   Directory dir,
                   SearcherFactory searcherFactory,
                   java.io.PrintStream printStream)
            throws java.io.IOException

Throws:

java.io.IOException

Method Detail

start

protected void start(long curPrimaryGen)
              throws java.io.IOException

Start up this replica, which possibly requires heavy copying of files from the primary node, if we were down for a long time

Throws:

java.io.IOException

commit

public void commit()
            throws java.io.IOException

Specified by:

commit in class Node

Throws:

java.io.IOException

finishNRTCopy

protected void finishNRTCopy(CopyJob job,
                             long startNS)
                      throws java.io.IOException

Throws:

java.io.IOException

newCopyJob

protected abstract CopyJob newCopyJob(java.lang.String reason,
                                      java.util.Map<java.lang.String,FileMetaData> files,
                                      java.util.Map<java.lang.String,FileMetaData> prevFiles,
                                      boolean highPriority,
                                      CopyJob.OnceDone onceDone)
                               throws java.io.IOException

Start a background copying job, to copy the specified files from the current primary node. If files is null then the latest copy state should be copied. If prevJob is not null, then the new copy job is replacing it and should 1) cancel the previous one, and 2) optionally salvage e.g. partially copied and, shared with the new copy job, files.

Throws:

java.io.IOException

launch

protected abstract void launch(CopyJob job)

Runs this job async'd

sendNewReplica

protected abstract void sendNewReplica()
                                throws java.io.IOException

Tell primary we (replica) just started, so primary can tell us to warm any already warming merges. This lets us keep low nrt refresh time for the first nrt sync after we started.

Throws:

java.io.IOException

newNRTPoint

public CopyJob newNRTPoint(long newPrimaryGen,
                           long version)
                    throws java.io.IOException

Call this to notify this replica node that a new NRT infos is available on the primary. We kick off a job (runs in the background) to copy files across, and open a new reader once that's done.

Throws:

java.io.IOException

isCopying

public boolean isCopying()

isClosed

public boolean isClosed()

Specified by:

isClosed in class Node

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

maybeNewPrimary

protected void maybeNewPrimary(long newPrimaryGen)
                        throws java.io.IOException

Called when the primary changed

Throws:

java.io.IOException

launchPreCopyMerge

protected CopyJob launchPreCopyMerge(java.util.concurrent.atomic.AtomicBoolean finished,
                                     long newPrimaryGen,
                                     java.util.Map<java.lang.String,FileMetaData> files)
                              throws java.io.IOException

Throws:

java.io.IOException

createTempOutput

public IndexOutput createTempOutput(java.lang.String prefix,
                                    java.lang.String suffix,
                                    IOContext ioContext)
                             throws java.io.IOException

Throws:

java.io.IOException

getFilesToCopy

public java.util.List<java.util.Map.Entry<java.lang.String,FileMetaData>> getFilesToCopy(java.util.Map<java.lang.String,FileMetaData> files)
                                                                                  throws java.io.IOException

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

Throws:

java.io.IOException

startCopyFile

public void startCopyFile(java.lang.String name)

finishCopyFile

public void finishCopyFile(java.lang.String name)