Package org.apache.lucene.tests.search

Class ShardSearchingTestBase.NodeState

java.lang.Object

org.apache.lucene.tests.search.ShardSearchingTestBase.NodeState

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

ShardSearchingTestBase

protected final class ShardSearchingTestBase.NodeState
extends Object
implements Closeable

Simulated shard node under test

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
final long[]	currentNodeVersions
final Directory	dir
final SearcherManager	mgr
final int	myNodeID
final SearcherLifetimeManager	searchers
final IndexWriter	writer

Constructor Summary

Constructors

Constructor	Description
NodeState(Random random, int nodeID, int numNodes)

Method Summary

Modifier and Type	Method	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 Details

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 Details

NodeState

public NodeState(Random random,
 int nodeID,
 int numNodes)
          throws IOException

Throws:

IOException

Method Details

initSearcher

public void initSearcher(long[] nodeVersions)
                  throws IOException

Throws:

IOException

updateNodeVersion

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

Throws:

IOException

acquire

public ShardSearchingTestBase.NodeState.ShardIndexSearcher acquire()

release

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

Throws:

IOException

acquire

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

reopen

public void reopen()
            throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException