protected static class JoinIndexPartitionTask.AtomicUpdateJoinIndexPartition extends AbstractAtomicUpdateTask<Void>
MetadataIndex, thereby putting into effect the changes made by a
This task obtains an exclusive lock on the new index partition and on all of the index partitons on the live journal that are being joined. It then copies all writes absorbed by the index partitions that are being since the overflow onto the new index partition and atomically (a) drops the old index partitions; (b) registers the new index partition; and (c) updates the metadata index to reflect the join.
DEBUG, INFO, log, resourceManager
|Constructor and Description|
|Modifier and Type||Method and Description|
Implement the task behavior here.
assertResource, assertRunning, assertUnisolated, call, clearLoggingContext, dropIndex, getCommitTime, getIndex, getJournal, getOnlyResource, getResource, getResourceManager, getTaskCounters, getTaskName, getTimestamp, isResource, registerIndex, setupLoggingContext, toString
public JoinIndexPartitionTask.AtomicUpdateJoinIndexPartition(ResourceManager resourceManager, String resource, JoinResult result, Event updateEvent)
resource- All resources (both the new index partition arising from the join and the old index partitions which have continued to receive writes that need to be copied into the new index partition and then dropped).
Note: Long-running implementations MUST periodically test
Thread.interrupted() and MUST throw an exception, such as
InterruptedException, if they are interrupted. This behavior
allows tasks to be canceled in a timely manner.
If you ignore or fail to test
Thread.interrupted() then your task
CAN NOT be aborted. If it is
false then the task will run to completion even though it
has been cancelled (but the
Future will appear to have been
If you simply
return rather than throwing an exception
WriteExecutorService will assume that your task
completed and your (partial) results will be made restart-safe at the
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.