lucene-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sar...@apache.org
Subject [12/40] lucene-solr:apiv2: LUCENE-5438: make some APIs public so servers can actually use this feature
Date Tue, 02 Aug 2016 01:07:32 GMT
LUCENE-5438: make some APIs public so servers can actually use this feature


Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/2d07ffd9
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/2d07ffd9
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/2d07ffd9

Branch: refs/heads/apiv2
Commit: 2d07ffd97fb4aec2a11aeddab40490044f3c2b49
Parents: 4c61d5a
Author: Mike McCandless <mikemccand@apache.org>
Authored: Mon Jul 25 06:00:11 2016 -0400
Committer: Mike McCandless <mikemccand@apache.org>
Committed: Mon Jul 25 06:00:37 2016 -0400

----------------------------------------------------------------------
 .../org/apache/lucene/replicator/nrt/Node.java   | 19 +++++++++++++++----
 .../lucene/replicator/nrt/PrimaryNode.java       |  5 +++++
 2 files changed, 20 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/2d07ffd9/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/Node.java
----------------------------------------------------------------------
diff --git a/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/Node.java b/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/Node.java
index 759497a..aa66d9f 100644
--- a/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/Node.java
+++ b/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/Node.java
@@ -25,6 +25,7 @@ import java.io.PrintStream;
 import java.nio.file.NoSuchFileException;
 import java.util.Locale;
 import java.util.Map;
+
 import org.apache.lucene.codecs.CodecUtil;
 import org.apache.lucene.index.CorruptIndexException;
 import org.apache.lucene.index.DirectoryReader;
@@ -39,10 +40,10 @@ import org.apache.lucene.store.IndexInput;
  *
  * @lucene.experimental */
 
-abstract class Node implements Closeable {
+public abstract class Node implements Closeable {
 
-  static boolean VERBOSE_FILES = true;
-  static boolean VERBOSE_CONNECTIONS = false;
+  public static boolean VERBOSE_FILES = true;
+  public static boolean VERBOSE_CONNECTIONS = false;
 
   // Keys we store into IndexWriter's commit user data:
 
@@ -87,6 +88,16 @@ abstract class Node implements Closeable {
     this.printStream = printStream;
   }
 
+  /** Returns the {@link ReferenceManager} to use for acquiring and releasing searchers */
+  public ReferenceManager<IndexSearcher> getSearcherManager() {
+    return mgr;
+  }
+
+  /** Returns the {@link Directory} this node is writing to */
+  public Directory getDirectory() {
+    return dir;
+  }
+
   @Override
   public String toString() {
     return getClass().getSimpleName() + "(id=" + id + ")";
@@ -119,7 +130,7 @@ abstract class Node implements Closeable {
     }
   }
 
-  protected void message(String message) {
+  public void message(String message) {
     if (printStream != null) {
       long now = System.nanoTime();
       printStream.println(String.format(Locale.ROOT,

http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/2d07ffd9/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/PrimaryNode.java
----------------------------------------------------------------------
diff --git a/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/PrimaryNode.java
b/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/PrimaryNode.java
index 1d04d08..8a3f07e 100644
--- a/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/PrimaryNode.java
+++ b/lucene/replicator/src/java/org/apache/lucene/replicator/nrt/PrimaryNode.java
@@ -128,6 +128,11 @@ public abstract class PrimaryNode extends Node {
     }
   }
 
+  /** Returns the current primary generation, which is incremented each time a new primary
is started for this index */
+  public long getPrimaryGen() {
+    return primaryGen;
+  }
+
   // TODO: in the future, we should separate "flush" (returns an incRef'd SegmentInfos) from
"refresh" (open new NRT reader from
   // IndexWriter) so that the latter can be done concurrently while copying files out to
replicas, minimizing the refresh time from the
   // replicas.  But fixing this is tricky because e.g. IndexWriter may complete a big merge
just after returning the incRef'd SegmentInfos


Mime
View raw message