public abstract class Node extends Object implements Closeable
PrimaryNode
and ReplicaNode
.Modifier and Type | Field and Description |
---|---|
protected Directory |
dir |
static long |
globalStartNS
Startup time of original test, carefully propogated to all nodes to produce consistent "seconds since start time" in messages
|
protected int |
id
Compact ordinal for this node
|
protected Map<String,FileMetaData> |
lastFileMetaData
File metadata for last sync that succeeded; we use this as a cache
|
static long |
localStartNS
When this node was started
|
protected ReferenceManager<IndexSearcher> |
mgr |
static String |
PRIMARY_GEN_KEY
Key to store the primary gen in the commit data, which increments every time we promote a new primary, so replicas can detect when the
primary they were talking to is changed
|
protected PrintStream |
printStream
For debug logging
|
protected SearcherFactory |
searcherFactory |
static boolean |
VERBOSE_CONNECTIONS |
static boolean |
VERBOSE_FILES |
static String |
VERSION_KEY
Key to store the version in the commit data, which increments every time we open a new NRT reader
|
Constructor and Description |
---|
Node(int id,
Directory dir,
SearcherFactory searcherFactory,
PrintStream printStream) |
Modifier and Type | Method and Description |
---|---|
static String |
bytesToString(long bytes) |
abstract void |
commit() |
long |
getCurrentSearchingVersion() |
Directory |
getDirectory()
Returns the
Directory this node is writing to |
ReferenceManager<IndexSearcher> |
getSearcherManager()
Returns the
ReferenceManager to use for acquiring and releasing searchers |
abstract boolean |
isClosed() |
void |
message(String message) |
String |
name() |
static void |
nodeMessage(PrintStream printStream,
int id,
String message) |
static void |
nodeMessage(PrintStream printStream,
String message) |
FileMetaData |
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 . |
String |
toString() |
public static boolean VERBOSE_FILES
public static boolean VERBOSE_CONNECTIONS
public static String PRIMARY_GEN_KEY
public static String VERSION_KEY
protected final int id
protected final Directory dir
protected final SearcherFactory searcherFactory
protected ReferenceManager<IndexSearcher> mgr
public static long globalStartNS
public static final long localStartNS
protected final PrintStream printStream
protected volatile Map<String,FileMetaData> lastFileMetaData
public Node(int id, Directory dir, SearcherFactory searcherFactory, PrintStream printStream)
public ReferenceManager<IndexSearcher> getSearcherManager()
ReferenceManager
to use for acquiring and releasing searcherspublic abstract void commit() throws IOException
IOException
public static void nodeMessage(PrintStream printStream, String message)
public static void nodeMessage(PrintStream printStream, int id, String message)
public void message(String message)
public String name()
public abstract boolean isClosed()
public long getCurrentSearchingVersion() throws IOException
IOException
public static String bytesToString(long bytes)
public FileMetaData readLocalFileMetaData(String fileName) throws IOException
FileMetaData
.
This returns null, logging a message, if there are any problems (the file does not exist, is corrupt, truncated, etc.).
IOException
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.