Module org.apache.lucene.misc

Package org.apache.lucene.misc.index

Class BPIndexReorderer.IndexReorderingTask

java.lang.Object

java.util.concurrent.ForkJoinTask<Void>

java.util.concurrent.RecursiveAction

org.apache.lucene.misc.index.BPIndexReorderer.BaseRecursiveAction

org.apache.lucene.misc.index.BPIndexReorderer.IndexReorderingTask

All Implemented Interfaces:

Serializable, Future<Void>

Enclosing class:

BPIndexReorderer

private class BPIndexReorderer.IndexReorderingTask
extends BPIndexReorderer.BaseRecursiveAction

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
private final IntsRef	docIDs
private final float[]	gains
private final CloseableThreadLocal<BPIndexReorderer.PerThreadState>	threadLocal

Fields inherited from class org.apache.lucene.misc.index.BPIndexReorderer.BaseRecursiveAction

depth

Constructor Summary

Constructors

Constructor	Description
IndexReorderingTask(IntsRef docIDs, float[] gains, CloseableThreadLocal<BPIndexReorderer.PerThreadState> threadLocal, int depth)

Method Summary

Modifier and Type	Method	Description
protected void	compute()
private void	computeDocFreqs(IntsRef docs, BPIndexReorderer.ForwardIndex forwardIndex, int[] docFreqs)
private boolean	shuffle(BPIndexReorderer.ForwardIndex forwardIndex, IntsRef left, IntsRef right, int[] leftDocFreqs, int[] rightDocFreqs, float[] gains, int iter)	Shuffle doc IDs across both partitions so that each partition has lower gaps between consecutive postings.
private void	swap(int[] docs, int left, int right, BPIndexReorderer.ForwardIndex forwardIndex, int[] leftDocFreqs, int[] rightDocFreqs)

Methods inherited from class org.apache.lucene.misc.index.BPIndexReorderer.BaseRecursiveAction

shouldFork

Methods inherited from class java.util.concurrent.RecursiveAction

exec, getRawResult, setRawResult

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, adaptInterruptible, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, exceptionNow, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollSubmission, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, quietlyJoin, quietlyJoinUninterruptibly, reinitialize, resultNow, setForkJoinTaskTag, state, tryUnfork

Methods inherited from class java.lang.Object

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

Field Details

docIDs

private final IntsRef docIDs

gains

private final float[] gains

threadLocal

private final CloseableThreadLocal<BPIndexReorderer.PerThreadState> threadLocal

Constructor Details

IndexReorderingTask

IndexReorderingTask(IntsRef docIDs,
 float[] gains,
 CloseableThreadLocal<BPIndexReorderer.PerThreadState> threadLocal,
 int depth)

Method Details

computeDocFreqs

private void computeDocFreqs(IntsRef docs,
 BPIndexReorderer.ForwardIndex forwardIndex,
 int[] docFreqs)

compute

protected void compute()

Specified by:

compute in class RecursiveAction

shuffle

private boolean shuffle(BPIndexReorderer.ForwardIndex forwardIndex,
 IntsRef left,
 IntsRef right,
 int[] leftDocFreqs,
 int[] rightDocFreqs,
 float[] gains,
 int iter)
                 throws IOException

Shuffle doc IDs across both partitions so that each partition has lower gaps between consecutive postings.

Throws:

IOException

swap

private void swap(int[] docs,
 int left,
 int right,
 BPIndexReorderer.ForwardIndex forwardIndex,
 int[] leftDocFreqs,
 int[] rightDocFreqs)
           throws IOException

Throws:

IOException