public abstract class BaseShardedDocumentSession<TDatabaseCommands> extends InMemoryDocumentSessionOperations implements IDocumentQueryGenerator, ITransactionalDocumentSession
Modifier and Type | Class and Description |
---|---|
static class |
BaseShardedDocumentSession.DbCmdsListComparer<TDatabaseCommands> |
protected static class |
BaseShardedDocumentSession.IdToLoad<TDatabaseCommands> |
Modifier and Type | Field and Description |
---|---|
protected Map<String,List<ICommandData>> |
deferredCommandsByShard |
protected Map<ILazyOperation,Action1<Object>> |
onEvaluateLazy |
protected List<Tuple<ILazyOperation,List<TDatabaseCommands>>> |
pendingLazyOperations |
protected Map<String,TDatabaseCommands> |
shardDbCommands |
_databaseName, dbName, deletedEntities, entitiesAndMetadata, entitiesByKey, entityToJson, generateDocumentKeysOnStore, includedDocumentsByKey, knownMissingIds, log, theListeners
Modifier | Constructor and Description |
---|---|
protected |
BaseShardedDocumentSession(String dbName,
ShardedDocumentStore documentStore,
DocumentSessionListeners listeners,
UUID id,
ShardStrategy shardStrategy,
Map<String,TDatabaseCommands> shardDbCommands) |
assertNoNonUniqueInstance, checkIfIdAlreadyIncluded, clear, close, convertToEntity, createDynamicIndexName, createPutEntityCommand, delete, delete, delete, delete, ensureNotReadVetoed, entityChanged, entityChanged, evict, explicitlyVersion, generateKey, getConventions, getDocumentId, getDocumentMetadataValue, getDocumentStore, getEntityToJson, getEtagFor, getExternalState, getGenerateEntityIdOnTheClient, getId, getJsonDocument, getListeners, getMaxNumberOfRequestsPerSession, getMetadataFor, getNonAuthoritativeInformationTimeout, getNumberOfEntitiesInUnitOfWork, getNumberOfRequests, getStoreIdentifier, handleInternalMetadata, hasChanged, hasChanges, hashCode, ignoreChangesFor, incrementRequestCount, isAllowNonAuthoritativeInformation, isDeleted, isLoaded, isUseOptimisticConcurrency, logBatch, markReadOnly, prepareForSaveChanges, projectionToInstance, refreshInternal, registerMissing, registerMissingIncludes, rememberEntityForDocumentKeyGeneration, setAllowNonAuthoritativeInformation, setDatabaseName, setMaxNumberOfRequestsPerSession, setNonAuthoritativeInformationTimeout, setUseOptimisticConcurrency, store, store, store, store, trackEntity, trackEntity, trackIncludedDocument, unregisterMissing, updateBatchResults, whatChanged
clone, equals, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
createRavenQueryInspector, documentQuery, getConventions
protected List<Tuple<ILazyOperation,List<TDatabaseCommands>>> pendingLazyOperations
protected final Map<ILazyOperation,Action1<Object>> onEvaluateLazy
protected final Map<String,List<ICommandData>> deferredCommandsByShard
protected final Map<String,TDatabaseCommands> shardDbCommands
protected BaseShardedDocumentSession(String dbName, ShardedDocumentStore documentStore, DocumentSessionListeners listeners, UUID id, ShardStrategy shardStrategy, Map<String,TDatabaseCommands> shardDbCommands)
public ShardStrategy getShardStrategy()
public String getDatabaseName()
getDatabaseName
in interface ITransactionalDocumentSession
getDatabaseName
in class InMemoryDocumentSessionOperations
protected List<Tuple<String,TDatabaseCommands>> getShardsToOperateOn(ShardRequestData resultionData)
public List<TDatabaseCommands> getCommandsToOperateOn(ShardRequestData resultionData)
protected <T> Map<List<TDatabaseCommands>,List<BaseShardedDocumentSession.IdToLoad<TDatabaseCommands>>> getIdsThatNeedLoading(Class<T> clazz, String[] ids, String[] includes, String transformer)
protected Map<String,SaveChangesData> createSaveChangesBatchPerShardFromDeferredCommands()
public void defer(ICommandData... commands)
InMemoryDocumentSessionOperations
defer
in class InMemoryDocumentSessionOperations
protected void storeEntityInUnitOfWork(String id, Object entity, Etag etag, RavenJObject metadata, boolean forceConcurrencyCheck)
storeEntityInUnitOfWork
in class InMemoryDocumentSessionOperations
protected String modifyObjectId(String id, Object entity, RavenJObject metadata)
public <T> IRavenQueryable<T> query(Class<T> clazz, String indexName)
public <T> IRavenQueryable<T> query(Class<T> clazz, String indexName, boolean isMapReduce)
public <T> IRavenQueryable<T> query(Class<T> clazz)
public <T> IRavenQueryable<T> query(Class<T> clazz, Class<? extends AbstractIndexCreationTask> tIndexCreator)
public <T> IRavenQueryable<T> query(Class<T> clazz, Class<? extends AbstractIndexCreationTask> tIndexCreator, ShardReduceFunction reduceFunction)
Copyright © 2016. All Rights Reserved.