org.apache.lucene.search

Class ShardSearchingTestBase.NodeState

java.lang.Object

org.apache.lucene.search.ShardSearchingTestBase.NodeState

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

ShardSearchingTestBase

protected final class ShardSearchingTestBase.NodeState
extends java.lang.Object
implements java.io.Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ShardSearchingTestBase.NodeState.ShardIndexSearcher Matches docs in the local shard but scores based on aggregated stats ("mock distributed scoring") from all nodes.

Field Summary

Fields

Modifier and Type	Field and Description
long[]	currentNodeVersions
Directory	dir
SearcherManager	mgr
int	myNodeID
SearcherLifetimeManager	searchers
IndexWriter	writer

Constructor Summary

Constructors

Constructor and Description
NodeState(java.util.Random random, int nodeID, int numNodes)

Method Summary

Modifier and Type	Method and Description
ShardSearchingTestBase.NodeState.ShardIndexSearcher	acquire()
ShardSearchingTestBase.NodeState.ShardIndexSearcher	acquire(long[] nodeVersions)
void	close()
void	initSearcher(long[] nodeVersions)
void	release(ShardSearchingTestBase.NodeState.ShardIndexSearcher s)
void	reopen()
void	updateNodeVersion(int nodeID, long version)

Methods inherited from class java.lang.Object

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

Field Detail

dir

public final Directory dir

writer

public final IndexWriter writer

searchers

public final SearcherLifetimeManager searchers

mgr

public final SearcherManager mgr

myNodeID

public final int myNodeID

currentNodeVersions

public final long[] currentNodeVersions

Constructor Detail

NodeState

public NodeState(java.util.Random random,
                 int nodeID,
                 int numNodes)
          throws java.io.IOException

Throws:

java.io.IOException

Method Detail

initSearcher

public void initSearcher(long[] nodeVersions)
                  throws java.io.IOException

Throws:

java.io.IOException

updateNodeVersion

public void updateNodeVersion(int nodeID,
                              long version)
                       throws java.io.IOException

Throws:

java.io.IOException

acquire

public ShardSearchingTestBase.NodeState.ShardIndexSearcher acquire()

release

public void release(ShardSearchingTestBase.NodeState.ShardIndexSearcher s)
             throws java.io.IOException

Throws:

java.io.IOException

acquire

public ShardSearchingTestBase.NodeState.ShardIndexSearcher acquire(long[] nodeVersions)

reopen

public void reopen()
            throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException