public class JoinIndexPartitionTask extends AbstractPrepareTask<JoinResult>
The task reads from the lastCommitTime of the old journal and builds a single
BTree from the merged read of the source index partitions as of that
timestamp and returns a
JoinResult. The task automatically submits,
and awaits the completion of, an
which performs the atomic update of the view definitions on the live journal
|Modifier and Type||Class and Description|
|Modifier and Type||Field and Description|
DEBUG, INFO, log, resourceManager
|Modifier||Constructor and Description|
|Modifier and Type||Method and Description|
Method is responsible for clearing the
FIXME Improve error handling for this task.
assertResource, assertRunning, assertUnisolated, call, clearLoggingContext, dropIndex, getCommitTime, getIndex, getJournal, getOnlyResource, getResource, getResourceManager, getTaskCounters, getTaskName, getTimestamp, isResource, registerIndex, setupLoggingContext, toString
protected JoinIndexPartitionTask(ResourceManager resourceManager, long lastCommitTime, String resources, com.bigdata.resources.ViewMetadata vmd)
resource- The names of the index partitions to be joined. These names MUST be given in natural ordering of the left separator keys for those index partitions.
protected void clearRefs()
SoftReferences held by
ViewMetadatafor the source view(s) on the old journal.
Note: This method MUST be invoked in order to permit those references to be cleared more eagerly than the end of the entire asynchronous overflow operation (which is when the task references would themselves go out of scope and become available for GC).
protected JoinResult doTask() throws Exception
AbstractTask.call()iff the operation succeeds.
Exception- The exception that will be thrown by
AbstractTask.call()iff the operation fails.
InterruptedException- This exception SHOULD be thrown if
Thread.interrupted()becomes true during execution.
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.