com.orientechnologies.orient.server.distributed.impl

Class ODatabaseDocumentDistributed

java.lang.Object

com.orientechnologies.common.listener.OListenerManger<ODatabaseListener>

com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract

com.orientechnologies.orient.core.db.document.ODatabaseDocumentEmbedded

com.orientechnologies.orient.server.distributed.impl.ODatabaseDocumentDistributed

All Implemented Interfaces:

ODatabaseDocument, OQueryLifecycleListener, ODatabase<ORecord>, ODatabaseDocumentInternal, ODatabaseInternal<ORecord>, ODatabaseSession, OBackupable, Closeable, AutoCloseable

Direct Known Subclasses:

ODatabaseDocumentDistributedPooled

public class ODatabaseDocumentDistributed
extends ODatabaseDocumentEmbedded

Created by tglman on 30/03/17.

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentEmbedded

ODatabaseDocumentEmbedded.InterruptTimerTask

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabase

ODatabase.ATTRIBUTES, ODatabase.OPERATION_MODE, ODatabase.STATUS

Field Summary

Fields inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract

activeQueries, componentsFactory, currentIntent, currentTx, databaseOwner, hooks, hooksByScope, inHook, initialized, loadedRecordsCount, localCache, maxRecordLoadMs, maxRidbagPrefetchMs, metadata, microTransaction, minRecordLoadMs, minRidbagPrefetchMs, properties, recordType, retainRecords, ridbagPrefetchCount, serializer, sharedContext, status, totalRecordLoadMs, totalRidbagPrefetchMs, unmodifiableHooks, url, user

Fields inherited from interface com.orientechnologies.orient.core.db.document.ODatabaseDocument

TYPE

Constructor Summary

Constructors

Constructor and Description
ODatabaseDocumentDistributed(OStorage storage, OHazelcastPlugin hazelcastPlugin)

Method Summary

Modifier and Type	Method and Description
void	acquireLocksForTx(OTransactionInternal tx, ODistributedTxContext txContext)
int	assignAndCheckCluster(ORecord record, String iClusterName)
boolean	beginDistributedTx(ODistributedRequestId requestId, OTransactionInternal tx, boolean local, int retryCount)
boolean	commit2pc(ODistributedRequestId transactionId, boolean local, ODistributedRequestId requestId)
void	commit2pcLocal(ODistributedRequestId transactionId) The Local commit is different from a remote commit due to local rid pre-allocation
ODatabaseDocumentInternal	copy() Returns a copy of current database if it's open.
protected void	createMetadata()
ODistributedResponse	executeTaskOnNode(ORemoteTask task, String nodeName)
Map<String,Set<String>>	getActiveClusterMap() returns the cluster map for current deploy.
Map<String,Set<String>>	getActiveDataCenterMap() returns the data center map for current deploy.
Set<String>	getClustersOnServer(ODistributedConfiguration cfg, String server)
OEnterpriseEndpoint	getEnterpriseEndpoint()
Map<String,Object>	getHaStatus(boolean servers, boolean db, boolean latency, boolean messages)
String	getLocalNodeName() return the name of local node in the cluster
ODistributedStorage	getStorageDistributed()
void	init(OrientDBConfig config)
void	internalBegin2pc(ONewDistributedTxContextImpl txContext, boolean local)
void	internalCommit(OTransactionInternal iTx) Executed the commit on the storage hiding away storage concepts from the transaction
void	internalCommit2pc(ONewDistributedTxContextImpl txContext)
boolean	isSharded() checks the cluster map and tells whether this is a sharded database (ie.
protected void	loadMetadata()
OResultSet	queryOnNode(String nodeName, OExecutionPlan executionPlan, Map<Object,Object> inputParameters) sends an execution plan to a remote node for a remote query execution
boolean	removeHaServer(String serverName)
boolean	rollback2pc(ODistributedRequestId transactionId)

Methods inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentEmbedded

addBlobCluster, afterCommitOperations, afterCreateOperations, afterDeleteOperations, afterReadOperations, afterRollbackOperations, afterUpdateOperations, beforeCreateOperations, beforeDeleteOperations, beforeReadOperations, beforeUpdateOperations, beginMicroTransaction, callOnCreateListeners, command, command, create, create, create, createInterruptTimerTask, deInit, delete, drop, execute, execute, executeDeleteRecord, executeSaveRecord, exists, getCommandInterruptionDepth, getConfig, getStorage, installHooksEmbedded, internalCreate, internalOpen, internalOpen, interruptExecution, isClosed, isCommandInterrupted, isStorageCommitHappening, live, live, open, open, query, query, query, rebuildIndexes, recycle, replaceStorage, set, setCommandInterrupted, setCommandInterruptionDepth, setCustom, setStorageCommitHappening

Methods inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract

activateOnCurrentThread, addCluster, addCluster, addRidbagPrefetchStats, backup, beforeCommitOperations, beforeRollbackOperations, begin, begin, begin, browseClass, browseClass, browseCluster, browseCluster, browseCluster, browseCluster, browseCluster, callbackHookFailure, callbackHookFinalize, callbackHooks, callbackHookSuccess, callOnCloseListeners, callOnDropListeners, callOnOpenListeners, checkForClusterPermissions, checkIfActive, checkOpenness, checkRecordClass, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, cleanOutRecord, clearDocumentTracking, close, closeActiveQueries, command, commit, commit, countClass, countClass, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countClusterElements, declareIntent, delete, delete, delete, delete, dropCluster, dropCluster, executeHideRecord, executeReadRecord, executeSaveEmptyRecord, executeWithRetries, executeWithRetries, executeWithRetries, existsCluster, freeze, freeze, get, getActiveIntent, getActiveQueries, getActiveQuery, getBlobClusterIds, getClusterIdByName, getClusterNameById, getClusterNames, getClusterRecordSizeById, getClusterRecordSizeByName, getClusters, getCollectionsChanges, getConfiguration, getConflictStrategy, getDatabaseOwner, getDefaultClusterId, getDefaultSerializer, getDictionary, getHooks, getListeners, getLocalCache, getMetadata, getMicroOrRegularTransaction, getName, getProperties, getProperty, getRecord, getRecordMetadata, getRecordType, getSbTreeCollectionManager, getSerializer, getSerializerFactory, getSharedContext, getSize, getStats, getStatus, getStorageVersions, getTransaction, getType, getUnderlying, getURL, getUser, hide, incrementalBackup, init, internalClose, isActiveOnCurrentThread, isClusterEdge, isClusterVertex, isMVCC, isPooled, isPrefetchRecords, isRetainRecords, isUseLightweightEdges, isValidationEnabled, load, load, load, load, load, load, load, load, load, load, loadIfVersionIsNotLatest, newBlob, newBlob, newEdge, newEdge, newElement, newElement, newElement, newInstance, newInstance, newLightweightEdge, newRegularEdge, newVertex, newVertex, query, queryClosed, queryStarted, rawBegin, registerHook, registerHook, release, reload, reload, reload, reload, reload, reloadUser, resetInitialization, resetRecordLoadStats, restore, rollback, rollback, save, save, save, save, setConflictStrategy, setConflictStrategy, setCurrentDatabaseInThreadLocal, setDatabaseOwner, setDefaultClusterIdInternal, setDefaultSerializer, setDefaultTransactionMode, setInternal, setMVCC, setPrefetchRecords, setProperty, setRetainRecords, setSerializer, setStatus, setStatusInternal, setUseLightweightEdges, setUser, setValidationEnabled, swapTx, truncateCluster, unregisterHook

Methods inherited from class com.orientechnologies.common.listener.OListenerManger

browseListeners, getListenersCopy, registerListener, resetListeners, unregisterListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.db.document.OQueryLifecycleListener

queryClosed, queryStarted

Methods inherited from interface com.orientechnologies.orient.core.db.ODatabaseDocumentInternal

indexQuery, realClose, reuse

Methods inherited from interface com.orientechnologies.orient.core.db.document.ODatabaseDocument

createClassIfNotExist, createEdgeClass, createVertexClass, newEdge, newVertex

Methods inherited from interface com.orientechnologies.orient.core.db.ODatabase

createClass, executeWithRetry, getClass, registerListener, unregisterListener

Constructor Detail

ODatabaseDocumentDistributed

public ODatabaseDocumentDistributed(OStorage storage,
                                    OHazelcastPlugin hazelcastPlugin)

Method Detail

getStorageDistributed

public ODistributedStorage getStorageDistributed()

getLocalNodeName

public String getLocalNodeName()

return the name of local node in the cluster

Returns:

the name of local node in the cluster

getActiveClusterMap

public Map<String,Set<String>> getActiveClusterMap()

returns the cluster map for current deploy. The keys of the map are node names, the values contain names of clusters (data files) available on the single node.

Returns:

the cluster map for current deploy

getClustersOnServer

public Set<String> getClustersOnServer(ODistributedConfiguration cfg,
                                       String server)

loadMetadata

protected void loadMetadata()

Overrides:

loadMetadata in class ODatabaseDocumentEmbedded

getActiveDataCenterMap

public Map<String,Set<String>> getActiveDataCenterMap()

returns the data center map for current deploy. The keys are data center names, the values are node names per data center

Returns:

data center map for current deploy

isSharded

public boolean isSharded()

Description copied from interface: ODatabaseInternal

checks the cluster map and tells whether this is a sharded database (ie. a distributed DB where at least two nodes contain distinct subsets of data) or not

Returns:

true if the database is sharded, false otherwise

copy

public ODatabaseDocumentInternal copy()

Description copied from class: ODatabaseDocumentEmbedded

Returns a copy of current database if it's open. The returned instance can be used by another thread without affecting current instance. The database copy is not set in thread local.

Specified by:

copy in interface ODatabaseDocumentInternal

Overrides:

copy in class ODatabaseDocumentEmbedded

getHaStatus

public Map<String,Object> getHaStatus(boolean servers,
                                      boolean db,
                                      boolean latency,
                                      boolean messages)

removeHaServer

public boolean removeHaServer(String serverName)

queryOnNode

public OResultSet queryOnNode(String nodeName,
                              OExecutionPlan executionPlan,
                              Map<Object,Object> inputParameters)

Description copied from interface: ODatabaseDocumentInternal

sends an execution plan to a remote node for a remote query execution

Parameters:

nodeName - the node name

executionPlan - the execution plan

inputParameters - the input parameters for execution

Returns:

an OResultSet to fetch the results of the query execution

executeTaskOnNode

public ODistributedResponse executeTaskOnNode(ORemoteTask task,
                                              String nodeName)

init

public void init(OrientDBConfig config)

Overrides:

init in class ODatabaseDocumentEmbedded

createMetadata

protected void createMetadata()

Overrides:

createMetadata in class ODatabaseDocumentEmbedded

assignAndCheckCluster

public int assignAndCheckCluster(ORecord record,
                                 String iClusterName)

Specified by:

assignAndCheckCluster in interface ODatabaseDocumentInternal

Overrides:

assignAndCheckCluster in class ODatabaseDocumentAbstract

internalCommit

public void internalCommit(OTransactionInternal iTx)

Description copied from interface: ODatabaseDocumentInternal

Executed the commit on the storage hiding away storage concepts from the transaction

Specified by:

internalCommit in interface ODatabaseDocumentInternal

Overrides:

internalCommit in class ODatabaseDocumentAbstract

acquireLocksForTx

public void acquireLocksForTx(OTransactionInternal tx,
                              ODistributedTxContext txContext)

beginDistributedTx

public boolean beginDistributedTx(ODistributedRequestId requestId,
                                  OTransactionInternal tx,
                                  boolean local,
                                  int retryCount)

commit2pcLocal

public void commit2pcLocal(ODistributedRequestId transactionId)

The Local commit is different from a remote commit due to local rid pre-allocation

Parameters:

transactionId -

commit2pc

public boolean commit2pc(ODistributedRequestId transactionId,
                         boolean local,
                         ODistributedRequestId requestId)

rollback2pc

public boolean rollback2pc(ODistributedRequestId transactionId)

internalCommit2pc

public void internalCommit2pc(ONewDistributedTxContextImpl txContext)

internalBegin2pc

public void internalBegin2pc(ONewDistributedTxContextImpl txContext,
                             boolean local)

getEnterpriseEndpoint

public OEnterpriseEndpoint getEnterpriseEndpoint()

Returns:

an endpoint for Enterprise features. Null in Community Edition