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 long[]
currentNodeVersions
Directory
dir
SearcherManager
mgr
int
myNodeID
SearcherLifetimeManager
searchers
IndexWriter
writer
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
-
-
-
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(Random random, int nodeID, int numNodes) throws IOException
- Throws:
IOException
-
-
Method Detail
-
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 interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
-