org.apache.asterix.metadata.utils

Class ExternalDatasetsRegistry

java.lang.Object

org.apache.asterix.metadata.utils.ExternalDatasetsRegistry

public class ExternalDatasetsRegistry
extends Object

This is a singelton class used to maintain the version of each external dataset with indexes It should be consolidated once a better global dataset lock management is introduced.

Author:

alamouda

Field Summary

Fields

Modifier and Type	Field and Description
static ExternalDatasetsRegistry	INSTANCE

Method Summary

Methods

Modifier and Type	Method and Description
void	buildIndexBegin(Dataset dataset, boolean firstIndex)
void	buildIndexEnd(Dataset dataset, boolean firstIndex)
int	getAndLockDatasetVersion(Dataset dataset, AqlMetadataProvider metadataProvider)
int	getDatasetVersion(Dataset dataset) Get the current version of the dataset
void	refreshBegin(Dataset dataset)
void	refreshEnd(Dataset dataset, boolean success)
void	releaseAcquiredLocks(AqlMetadataProvider metadataProvider)
void	removeDatasetInfo(Dataset dataset)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static ExternalDatasetsRegistry INSTANCE

Method Detail

getDatasetVersion

public int getDatasetVersion(Dataset dataset)

Get the current version of the dataset

Parameters:

dataset -

Returns:

getAndLockDatasetVersion

public int getAndLockDatasetVersion(Dataset dataset,
                           AqlMetadataProvider metadataProvider)

refreshBegin

public void refreshBegin(Dataset dataset)

removeDatasetInfo

public void removeDatasetInfo(Dataset dataset)

refreshEnd

public void refreshEnd(Dataset dataset,
              boolean success)

buildIndexBegin

public void buildIndexBegin(Dataset dataset,
                   boolean firstIndex)

buildIndexEnd

public void buildIndexEnd(Dataset dataset,
                 boolean firstIndex)

releaseAcquiredLocks

public void releaseAcquiredLocks(AqlMetadataProvider metadataProvider)