Package com.qfs.distribution

Interface IMultiVersionDataActivePivot

All Superinterfaces:

IAgent, IContinuouslyQueryable, IExtendedPluginValue, IHasId, IMemoryMonitored, IMultiVersion, IMultiVersionActivePivot, IMultiVersionOperations, IQueryable, IRebuildable<IActivePivotVersion>, ITransactionalMultiVersion

All Known Implementing Classes:

MultiVersionDataActivePivot

public interface IMultiVersionDataActivePivot
extends IMultiVersionActivePivot

This instance of IMultiVersionActivePivot is made for the distributed architecture. In addition to its parent's attributes, it holds a DataNodeManager that creates new data nodes when a transaction is started on a given branch, if the epoch dimension is enabled.

If it is not, only one DataNode is created for the master branch.

The data nodes are stopped when their associated branches are deleted from the history.

Each data node points toward the head of a given branch of this instance. They all hold a reference to this instance. A query node can then discover data nodes as they join the cluster, and can execute queries on several heads.

Author:

ActiveViam

Nested Class Summary

Nested classes/interfaces inherited from interface com.quartetfs.fwk.IAgent

IAgent.ITransition, IAgent.State

Field Summary

Fields inherited from interface com.quartetfs.biz.pivot.IMultiVersionActivePivot

AGGREGATE_PROVIDER, AGGREGATES_CACHE, CONTINUOUS_QUERY_ENGINE, DATA_TYPE, DEFAULT_TYPE, QUERY_MANAGER, QUERY_PLAN

Method Summary

Modifier and Type	Method	Description
Map<String,IDataCubeAdapter>	getDataCubeAdapterMap()	Returns this data cube's map that holds, for each query node in the cluster's address, the associated IDataCubeAdapter.
DataNodeManager	getDataNodeBranchManager()	Getter.
String	getUniqueIdentifierInCluster()	Returns the unique cube identifier of the cube withing the cluster.
default void	restartDistribution()	Deprecated, for removal: This API element is subject to removal in a future version.
void	startDistribution()	Start the distribution infrastructure.

Methods inherited from interface com.quartetfs.fwk.IAgent

getProperties, getStatus, init, pause, resume, start, stop

Methods inherited from interface com.quartetfs.fwk.query.IContinuouslyQueryable

getContinuousQuery, registerContinuousQuery, registerContinuousQuery, registeredContinuousQueryNames, unregisterAllContinuousQueries, unregisterContinuousQuery

Methods inherited from interface com.quartetfs.fwk.types.IExtendedPluginValue

getType

Methods inherited from interface com.qfs.monitoring.memory.IMemoryMonitored

getMemoryStatistic

Methods inherited from interface com.quartetfs.biz.pivot.IMultiVersionActivePivot

awaitNotifications, awaitNotifications, awaitNotifications, cancelUserQueries, commit, createCompositeTransactionInfo, getAggregatesContinuousQueryEngine, getBranches, getBranchPermissionsManager, getContext, getDescription, getDrillthroughContinuousQueryEngine, getHead, getHead, getHeads, getHierarchies, getId, getLastActivityTime, getListeners, getMissingLocationsSolver, getMostRecentVersion, getOrCreateTransaction, getReadableBranches, getTransaction, getVersionHistory, isDistributed, setTransactionProperties

Methods inherited from interface com.quartetfs.fwk.query.IQueryable

execute, getSupportedQueries

Methods inherited from interface com.quartetfs.biz.pivot.IRebuildable

rebuild

Methods inherited from interface com.qfs.multiversion.ITransactionalMultiVersion

rollback

Method Detail

getDataCubeAdapterMap

Map<String,IDataCubeAdapter> getDataCubeAdapterMap()

Returns this data cube's map that holds, for each query node in the cluster's address, the associated IDataCubeAdapter.

Returns:

the map

startDistribution

void startDistribution()
                throws AgentException

Start the distribution infrastructure. If the node manager contain several DataNode, all data nodes will be started one by one.

Throws:

AgentException - if an issue is raised when starting the DataNodeManager.

restartDistribution

@Deprecated(since="6.0.8",
            forRemoval=true)
default void restartDistribution()

Deprecated, for removal: This API element is subject to removal in a future version.

Disconnects the data cube from current cluster and restarts distribution according to the cluster definition.

getDataNodeBranchManager

DataNodeManager getDataNodeBranchManager()

Getter.

Returns:

the DataNodeManager that handle creation and deletion of data nodes

getUniqueIdentifierInCluster

String getUniqueIdentifierInCluster()

Returns the unique cube identifier of the cube withing the cluster.