com.bigdata.resources

Class ResourceManager

java.lang.Object

com.bigdata.resources.ResourceEvents

com.bigdata.resources.StoreManager

com.bigdata.resources.IndexManager

com.bigdata.resources.OverflowManager

com.bigdata.resources.ResourceManager

All Implemented Interfaces:

IResourceManager, IPartitionIdFactory, IServiceShutdown

Direct Known Subclasses:

TestResourceManagerBootstrap.MyResourceManager

public abstract class ResourceManager
extends OverflowManager
implements IPartitionIdFactory

The ResourceManager has broad responsibility for journal files, index segment files, maintaining index views during overflow processing, and managing the transparent decomposition of scale-out indices and the distribution of the key-range index partitions for those scale-out indices.

This class is implemented in several layers:

ResourceManager

Concrete implementation.

OverflowManager

Overflow processing.

IndexManager

Manages indices

StoreManager

Manages the journal and index segment files, including the release of old resources.

ResourceEvents

Event reporting API

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ResourceManager.IResourceManagerCounters Interface defines and documents the counters and counter namespaces for the ResourceManager.
static interface	ResourceManager.Options ResourceManager options.

Nested classes/interfaces inherited from class com.bigdata.resources.OverflowManager

OverflowManager.IIndexPartitionTaskCounters, OverflowManager.IOverflowManagerCounters, OverflowManager.ResourceScores

Nested classes/interfaces inherited from class com.bigdata.resources.IndexManager

IndexManager.IIndexManagerCounters, IndexManager.IndexSegmentStats

Nested classes/interfaces inherited from class com.bigdata.resources.StoreManager

StoreManager.IStoreManagerCounters, StoreManager.ManagedJournal

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log Logger.

Fields inherited from class com.bigdata.resources.OverflowManager

accelerateSplitThreshold, asyncOverflowEnabled, buildServiceCorePoolSize, compactingMerge, compactingMergeWithAfterAction, copyIndexThreshold, forceOverflow, joinsEnabled, maximumBuildSegmentBytes, maximumJournalsPerView, maximumMovePercentOfSplit, maximumMoves, maximumMovesPerTarget, maximumOptionalMergesPerOverflow, maximumSegmentsPerView, mergeServiceCorePoolSize, minimumActiveIndexPartitions, movePercentCpuTimeThreshold, nominalShardSize, overflowAllowed, overflowCancelledWhenJournalFull, overflowCounters, overflowTasksConcurrent, overflowThreshold, overflowTimeout, percentOfJoinThreshold, percentOfSplitThreshold, scatterSplitEnabled, serviceName, shardOverextensionLimit, tailSplitThreshold

Fields inherited from class com.bigdata.resources.IndexManager

buildTasks, concurrentBuildTaskCount, concurrentMergeTaskCount, staleLocatorCache

Fields inherited from class com.bigdata.resources.StoreManager

accelerateOverflowThreshold, bytesDeleted, bytesUnderManagement, dataDir, indexCacheLock, journalBytesUnderManagement, journalDeleteCount, journalReopenCount, journalsDir, lastCommitTimePreserved, lastOverflowTime, liveJournalRef, maximumJournalSizeAtOverflow, purgeResourcesMillis, segmentBytesUnderManagement, segmentsDir, segmentStoreDeleteCount, segmentStoreReopenCount, storeCache, tmpDir

Constructor Summary

Constructors

Constructor and Description
ResourceManager(Properties properties) (Re-)open the ResourceManager.

Method Summary

Methods

Modifier and Type	Method and Description
IConcurrencyManager	getConcurrencyManager() The object used to control access to the index resources.
CounterSet	getCounters() Statistics about the IResourceManager.
int	nextPartitionId(String scaleOutIndexName) Requests a new index partition identifier from the MetadataService for the specified scale-out index (RMI).
void	setConcurrencyManager(IConcurrencyManager concurrencyManager)

Methods inherited from class com.bigdata.resources.OverflowManager

doSynchronousOverflow, getAsynchronousOverflowCount, getHostCounter, getOverflowCounters, getServiceCounter, getSynchronousOverflowCount, isOverflowAllowed, isOverflowEnabled, overflow, shouldOverflow, shutdown, shutdownNow

Methods inherited from class com.bigdata.resources.IndexManager

buildIndexSegment, disableWrites, enableWrites, getIndex, getIndexCacheCapacity, getIndexCacheSize, getIndexCounters, getIndexCounters, getIndexOnStore, getIndexPartitionGone, getIndexRetentionTime, getIndexSegmentCacheCapacity, getIndexSegmentCacheSize, getIndexSources, getIndexSources, getStaleLocatorCount, isDisabledWrites, listIndexPartitions, markAndGetDelta, setIndexPartitionGone

Methods inherited from class com.bigdata.resources.StoreManager

addResource, assertNotOpen, assertOpen, assertRunning, awaitRunning, deleteResource, deleteResources, getBytesUnderManagement, getCommitTimeStrictlyGreaterThan, getDataDir, getDataDirFreeSpace, getIndexSegmentFile, getIndexSegmentFile, getJournal, getJournalBytesUnderManagement, getLiveJournal, getManagedJournalCount, getManagedSegmentCount, getProperties, getReleaseTime, getResourceService, getResourcesForTimestamp, getSegmentBytesUnderManagement, getStoreCacheSize, getStoreCounters, getTempDirFreeSpace, getTmpDir, isOpen, isRunning, isStarting, isTransient, munge, newFileFilter, nextTimestamp, openStore, overrideJournalExtent, purgeOldResources, purgeOldResources, retentionSetAdd, retentionSetRemove, setReleaseTime

Methods inherited from class com.bigdata.resources.ResourceEvents

closeJournal, closeTx, closeUnisolatedIndex, deleteJournal, dropUnisolatedIndex, extendJournal, isolateIndex, openJournal, openTx, openUnisolatedIndex

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.journal.IResourceManager

getDataService, getDataServiceUUID, getFederation

Field Detail

log

protected static final org.apache.log4j.Logger log

Logger.

Constructor Detail

ResourceManager

public ResourceManager(Properties properties)

(Re-)open the ResourceManager.

Note: You MUST use setConcurrencyManager(IConcurrencyManager) after calling this constructor (the parameter can not be passed in since there is a circular dependency between the IConcurrencyManager and ManagedJournal#getLocalTransactionManager().

Parameters:

properties - See ResourceManager.Options.

See Also:

DataService.start()

Method Detail

getCounters

public CounterSet getCounters()

Description copied from interface: IResourceManager

Statistics about the IResourceManager.

Specified by:

getCounters in interface IResourceManager

getConcurrencyManager

public IConcurrencyManager getConcurrencyManager()

Description copied from class: StoreManager

The object used to control access to the index resources.

Specified by:

getConcurrencyManager in class StoreManager

setConcurrencyManager

public void setConcurrencyManager(IConcurrencyManager concurrencyManager)

Specified by:

setConcurrencyManager in class StoreManager

nextPartitionId

public int nextPartitionId(String scaleOutIndexName)

Requests a new index partition identifier from the MetadataService for the specified scale-out index (RMI).

Specified by:

nextPartitionId in interface IPartitionIdFactory

Parameters:

scaleOutIndexName - The name of the scale-out index.

Returns:

The new index partition identifier.

Throws:

RuntimeException - if something goes wrong.