test_class.declarator: store
test_class.modifier: private
test_class.original_string: private TestStore store;
test_class.type: TestStore
test_class.var_name: store
test_class.file: oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStoreTest.java
test_class.identifier: MongoDocumentStoreTest
test_class.superclass: extends AbstractMongoConnectionTest
test_case.body: @Test
      public void defaultIndexes() {
          assertTrue(hasIndex(store.getDBCollection(Collection.NODES), Document.ID));
          assertFalse(hasIndex(store.getDBCollection(Collection.NODES), NodeDocument.SD_TYPE));
          assertTrue(hasIndex(store.getDBCollection(Collection.NODES), NodeDocument.SD_TYPE, NodeDocument.SD_MAX_REV_TIME_IN_SECS));
          if (new MongoStatus(mongoConnection.getMongoClient(), mongoConnection.getDBName()).isVersion(3, 2)) {
              assertTrue(hasIndex(store.getDBCollection(Collection.NODES), NodeDocument.DELETED_ONCE, NodeDocument.MODIFIED_IN_SECS));
          } else {
              assertTrue(hasIndex(store.getDBCollection(Collection.NODES), NodeDocument.DELETED_ONCE));
          }
          assertTrue(hasIndex(store.getDBCollection(Collection.NODES), NodeDocument.HAS_BINARY_FLAG));
          assertTrue(hasIndex(store.getDBCollection(Collection.NODES), NodeDocument.MODIFIED_IN_SECS, Document.ID));
          assertFalse(hasIndex(store.getDBCollection(Collection.NODES), NodeDocument.MODIFIED_IN_SECS));
          assertTrue(hasIndex(store.getDBCollection(Collection.JOURNAL), JournalEntry.MODIFIED));
      }
test_case.class_method_signature: MongoDocumentStoreTest.defaultIndexes()
test_case.full_signature: @Test public void defaultIndexes()
test_case.identifier: defaultIndexes
test_case.invocations: assertTrue hasIndex getDBCollection assertFalse hasIndex getDBCollection assertTrue hasIndex getDBCollection isVersion getMongoClient getDBName assertTrue hasIndex getDBCollection assertTrue hasIndex getDBCollection assertTrue hasIndex getDBCollection assertTrue hasIndex getDBCollection assertFalse hasIndex getDBCollection assertTrue hasIndex getDBCollection
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void defaultIndexes()
focal_class.declarator: LOG = LoggerFactory.getLogger(MongoDocumentStore.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(MongoDocumentStore.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: PERFLOG = new PerfLogger(
              LoggerFactory.getLogger(MongoDocumentStore.class.getName()
                      + ".perf"))
focal_class.modifier: private static final
focal_class.original_string: private static final PerfLogger PERFLOG = new PerfLogger(
              LoggerFactory.getLogger(MongoDocumentStore.class.getName()
                      + ".perf"));
focal_class.type: PerfLogger
focal_class.var_name: PERFLOG
focal_class.declarator: BY_ID_ASC = new BasicDBObject(Document.ID, 1)
focal_class.modifier: private static final
focal_class.original_string: private static final Bson BY_ID_ASC = new BasicDBObject(Document.ID, 1);
focal_class.type: Bson
focal_class.var_name: BY_ID_ASC
focal_class.declarator: IN_CLAUSE_BATCH_SIZE = 500
focal_class.modifier: public static final
focal_class.original_string: public static final int IN_CLAUSE_BATCH_SIZE = 500;
focal_class.type: int
focal_class.var_name: IN_CLAUSE_BATCH_SIZE
focal_class.declarator: CONFLICT_ON_INSERT = new BasicDBObject(
              "$setOnInsert",
              new BasicDBObject(Document.ID, "a").append(Document.ID, "b")
      ).toMap()
focal_class.modifier: private static final
focal_class.original_string: private static final Map CONFLICT_ON_INSERT = new BasicDBObject(
              "$setOnInsert",
              new BasicDBObject(Document.ID, "a").append(Document.ID, "b")
      ).toMap();
focal_class.type: Map
focal_class.var_name: CONFLICT_ON_INSERT
focal_class.declarator: nodes
focal_class.modifier: private
focal_class.original_string: private MongoCollection<BasicDBObject> nodes;
focal_class.type: MongoCollection<BasicDBObject>
focal_class.var_name: nodes
focal_class.declarator: clusterNodes
focal_class.modifier: private final
focal_class.original_string: private final MongoCollection<BasicDBObject> clusterNodes;
focal_class.type: MongoCollection<BasicDBObject>
focal_class.var_name: clusterNodes
focal_class.declarator: settings
focal_class.modifier: private final
focal_class.original_string: private final MongoCollection<BasicDBObject> settings;
focal_class.type: MongoCollection<BasicDBObject>
focal_class.var_name: settings
focal_class.declarator: journal
focal_class.modifier: private final
focal_class.original_string: private final MongoCollection<BasicDBObject> journal;
focal_class.type: MongoCollection<BasicDBObject>
focal_class.var_name: journal
focal_class.declarator: client
focal_class.modifier: private final
focal_class.original_string: private final MongoClient client;
focal_class.type: MongoClient
focal_class.var_name: client
focal_class.declarator: status
focal_class.modifier: private final
focal_class.original_string: private final MongoStatus status;
focal_class.type: MongoStatus
focal_class.var_name: status
focal_class.declarator: sessionFactory
focal_class.modifier: private final
focal_class.original_string: private final MongoSessionFactory sessionFactory;
focal_class.type: MongoSessionFactory
focal_class.var_name: sessionFactory
focal_class.declarator: db
focal_class.modifier: private final
focal_class.original_string: private final MongoDatabase db;
focal_class.type: MongoDatabase
focal_class.var_name: db
focal_class.declarator: nodesCache
focal_class.modifier: private final
focal_class.original_string: private final NodeDocumentCache nodesCache;
focal_class.type: NodeDocumentCache
focal_class.var_name: nodesCache
focal_class.declarator: nodeLocks
focal_class.modifier: private final
focal_class.original_string: private final NodeDocumentLocks nodeLocks;
focal_class.type: NodeDocumentLocks
focal_class.var_name: nodeLocks
focal_class.declarator: clock = Clock.SIMPLE
focal_class.modifier: private
focal_class.original_string: private Clock clock = Clock.SIMPLE;
focal_class.type: Clock
focal_class.var_name: clock
focal_class.declarator: maxReplicationLagMillis
focal_class.modifier: private final
focal_class.original_string: private final long maxReplicationLagMillis;
focal_class.type: long
focal_class.var_name: maxReplicationLagMillis
focal_class.declarator: maxDeltaForModTimeIdxSecs =
              Long.getLong("oak.mongo.maxDeltaForModTimeIdxSecs", 60)
focal_class.modifier: private final
focal_class.original_string: private final long maxDeltaForModTimeIdxSecs =
              Long.getLong("oak.mongo.maxDeltaForModTimeIdxSecs", 60);
focal_class.type: long
focal_class.var_name: maxDeltaForModTimeIdxSecs
focal_class.declarator: disableIndexHint =
              Boolean.getBoolean("oak.mongo.disableIndexHint")
focal_class.modifier: private final
focal_class.original_string: private final boolean disableIndexHint =
              Boolean.getBoolean("oak.mongo.disableIndexHint");
focal_class.type: boolean
focal_class.var_name: disableIndexHint
focal_class.declarator: maxQueryTimeMS =
              Long.getLong("oak.mongo.maxQueryTimeMS", TimeUnit.MINUTES.toMillis(1))
focal_class.modifier: private final
focal_class.original_string: private final long maxQueryTimeMS =
              Long.getLong("oak.mongo.maxQueryTimeMS", TimeUnit.MINUTES.toMillis(1));
focal_class.type: long
focal_class.var_name: maxQueryTimeMS
focal_class.declarator: bulkSize =
              Integer.getInteger("oak.mongo.bulkSize", 30)
focal_class.modifier: private
focal_class.original_string: private int bulkSize =
              Integer.getInteger("oak.mongo.bulkSize", 30);
focal_class.type: int
focal_class.var_name: bulkSize
focal_class.declarator: bulkRetries =
              Integer.getInteger("oak.mongo.bulkRetries", 0)
focal_class.modifier: private
focal_class.original_string: private int bulkRetries =
              Integer.getInteger("oak.mongo.bulkRetries", 0);
focal_class.type: int
focal_class.var_name: bulkRetries
focal_class.declarator: queryRetries =
              Integer.getInteger("oak.mongo.queryRetries", 2)
focal_class.modifier: private final
focal_class.original_string: private final int queryRetries =
              Integer.getInteger("oak.mongo.queryRetries", 2);
focal_class.type: int
focal_class.var_name: queryRetries
focal_class.declarator: acceptableLagMillis =
              Integer.getInteger("oak.mongo.acceptableLagMillis", 5000)
focal_class.modifier: private final
focal_class.original_string: private final int acceptableLagMillis =
              Integer.getInteger("oak.mongo.acceptableLagMillis", 5000);
focal_class.type: int
focal_class.var_name: acceptableLagMillis
focal_class.declarator: useClientSession
focal_class.modifier: private final
focal_class.original_string: private final boolean useClientSession;
focal_class.type: boolean
focal_class.var_name: useClientSession
focal_class.declarator: lastReadWriteMode
focal_class.modifier: private
focal_class.original_string: private String lastReadWriteMode;
focal_class.type: String
focal_class.var_name: lastReadWriteMode
focal_class.declarator: metadata
focal_class.modifier: private final
focal_class.original_string: private final Map<String, String> metadata;
focal_class.type: Map<String, String>
focal_class.var_name: metadata
focal_class.declarator: stats
focal_class.modifier: private
focal_class.original_string: private DocumentStoreStatsCollector stats;
focal_class.type: DocumentStoreStatsCollector
focal_class.var_name: stats
focal_class.declarator: hasModifiedIdCompoundIndex = true
focal_class.modifier: private
focal_class.original_string: private boolean hasModifiedIdCompoundIndex = true;
focal_class.type: boolean
focal_class.var_name: hasModifiedIdCompoundIndex
focal_class.declarator: KEY_MODIFIED = new Key(MODIFIED_IN_SECS, null)
focal_class.modifier: private static final
focal_class.original_string: private static final Key KEY_MODIFIED = new Key(MODIFIED_IN_SECS, null);
focal_class.type: Key
focal_class.var_name: KEY_MODIFIED
focal_class.declarator: readOnly
focal_class.modifier: private final
focal_class.original_string: private final boolean readOnly;
focal_class.type: boolean
focal_class.var_name: readOnly
focal_class.file: oak-store-document/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java
focal_class.identifier: MongoDocumentStore
focal_class.interfaces: implements DocumentStore
focal_class.class_method_signature: MongoDocumentStore.MongoDocumentStore(MongoClient client, MongoDatabase db,
                                MongoDocumentNodeStoreBuilderBase<?> builder)
focal_class.full_signature: public  MongoDocumentStore(MongoClient client, MongoDatabase db,
                                MongoDocumentNodeStoreBuilderBase<?> builder)
focal_class.identifier: MongoDocumentStore
focal_class.modifiers: public
focal_class.parameters: (MongoClient client, MongoDatabase db,
                                MongoDocumentNodeStoreBuilderBase<?> builder)
focal_class.signature:  MongoDocumentStore(MongoClient client, MongoDatabase db,
                                MongoDocumentNodeStoreBuilderBase<?> builder)
focal_class.class_method_signature: MongoDocumentStore.ensureIndexes(@NotNull MongoStatus mongoStatus)
focal_class.full_signature: private void ensureIndexes(@NotNull MongoStatus mongoStatus)
focal_class.identifier: ensureIndexes
focal_class.modifiers: private
focal_class.parameters: (@NotNull MongoStatus mongoStatus)
focal_class.return: void
focal_class.signature: void ensureIndexes(@NotNull MongoStatus mongoStatus)
focal_class.class_method_signature: MongoDocumentStore.isReadOnly()
focal_class.full_signature: public boolean isReadOnly()
focal_class.identifier: isReadOnly
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isReadOnly()
focal_class.class_method_signature: MongoDocumentStore.finalize()
focal_class.full_signature: @Override public void finalize()
focal_class.identifier: finalize
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void finalize()
focal_class.class_method_signature: MongoDocumentStore.invalidateCache()
focal_class.full_signature: @Override public CacheInvalidationStats invalidateCache()
focal_class.identifier: invalidateCache
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: CacheInvalidationStats
focal_class.signature: CacheInvalidationStats invalidateCache()
focal_class.class_method_signature: MongoDocumentStore.invalidateCache(Iterable<String> keys)
focal_class.full_signature: @Override public CacheInvalidationStats invalidateCache(Iterable<String> keys)
focal_class.identifier: invalidateCache
focal_class.modifiers: @Override public
focal_class.parameters: (Iterable<String> keys)
focal_class.return: CacheInvalidationStats
focal_class.signature: CacheInvalidationStats invalidateCache(Iterable<String> keys)
focal_class.class_method_signature: MongoDocumentStore.invalidateCache(Collection<T> collection, String key)
focal_class.full_signature: @Override public void invalidateCache(Collection<T> collection, String key)
focal_class.identifier: invalidateCache
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, String key)
focal_class.return: void
focal_class.signature: void invalidateCache(Collection<T> collection, String key)
focal_class.class_method_signature: MongoDocumentStore.find(Collection<T> collection, String key)
focal_class.full_signature: @Override public T find(Collection<T> collection, String key)
focal_class.identifier: find
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, String key)
focal_class.return: T
focal_class.signature: T find(Collection<T> collection, String key)
focal_class.class_method_signature: MongoDocumentStore.find(final Collection<T> collection,
                                         final String key,
                                         int maxCacheAge)
focal_class.full_signature: @Override public T find(final Collection<T> collection,
                                         final String key,
                                         int maxCacheAge)
focal_class.identifier: find
focal_class.modifiers: @Override public
focal_class.parameters: (final Collection<T> collection,
                                         final String key,
                                         int maxCacheAge)
focal_class.return: T
focal_class.signature: T find(final Collection<T> collection,
                                         final String key,
                                         int maxCacheAge)
focal_class.class_method_signature: MongoDocumentStore.find(final Collection<T> collection,
                                         final String key,
                                         boolean preferCached,
                                         final int maxCacheAge)
focal_class.full_signature: @SuppressWarnings("unchecked") private T find(final Collection<T> collection,
                                         final String key,
                                         boolean preferCached,
                                         final int maxCacheAge)
focal_class.identifier: find
focal_class.modifiers: @SuppressWarnings("unchecked") private
focal_class.parameters: (final Collection<T> collection,
                                         final String key,
                                         boolean preferCached,
                                         final int maxCacheAge)
focal_class.return: T
focal_class.signature: T find(final Collection<T> collection,
                                         final String key,
                                         boolean preferCached,
                                         final int maxCacheAge)
focal_class.class_method_signature: MongoDocumentStore.findUncachedWithRetry(
              Collection<T> collection, String key,
              DocumentReadPreference docReadPref)
focal_class.full_signature: @Nullable private T findUncachedWithRetry(
              Collection<T> collection, String key,
              DocumentReadPreference docReadPref)
focal_class.identifier: findUncachedWithRetry
focal_class.modifiers: @Nullable private
focal_class.parameters: (
              Collection<T> collection, String key,
              DocumentReadPreference docReadPref)
focal_class.return: T
focal_class.signature: T findUncachedWithRetry(
              Collection<T> collection, String key,
              DocumentReadPreference docReadPref)
focal_class.class_method_signature: MongoDocumentStore.findUncached(Collection<T> collection, String key, DocumentReadPreference docReadPref)
focal_class.full_signature: @Nullable protected T findUncached(Collection<T> collection, String key, DocumentReadPreference docReadPref)
focal_class.identifier: findUncached
focal_class.modifiers: @Nullable protected
focal_class.parameters: (Collection<T> collection, String key, DocumentReadPreference docReadPref)
focal_class.return: T
focal_class.signature: T findUncached(Collection<T> collection, String key, DocumentReadPreference docReadPref)
focal_class.class_method_signature: MongoDocumentStore.query(Collection<T> collection,
                                  String fromKey,
                                  String toKey,
                                  int limit)
focal_class.full_signature: @NotNull @Override public List<T> query(Collection<T> collection,
                                  String fromKey,
                                  String toKey,
                                  int limit)
focal_class.identifier: query
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (Collection<T> collection,
                                  String fromKey,
                                  String toKey,
                                  int limit)
focal_class.return: List<T>
focal_class.signature: List<T> query(Collection<T> collection,
                                  String fromKey,
                                  String toKey,
                                  int limit)
focal_class.class_method_signature: MongoDocumentStore.query(Collection<T> collection,
                                                String fromKey,
                                                String toKey,
                                                String indexedProperty,
                                                long startValue,
                                                int limit)
focal_class.full_signature: @NotNull @Override public List<T> query(Collection<T> collection,
                                                String fromKey,
                                                String toKey,
                                                String indexedProperty,
                                                long startValue,
                                                int limit)
focal_class.identifier: query
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (Collection<T> collection,
                                                String fromKey,
                                                String toKey,
                                                String indexedProperty,
                                                long startValue,
                                                int limit)
focal_class.return: List<T>
focal_class.signature: List<T> query(Collection<T> collection,
                                                String fromKey,
                                                String toKey,
                                                String indexedProperty,
                                                long startValue,
                                                int limit)
focal_class.class_method_signature: MongoDocumentStore.queryWithRetry(Collection<T> collection,
                                                          String fromKey,
                                                          String toKey,
                                                          String indexedProperty,
                                                          long startValue,
                                                          int limit,
                                                          long maxQueryTime)
focal_class.full_signature: @NotNull private List<T> queryWithRetry(Collection<T> collection,
                                                          String fromKey,
                                                          String toKey,
                                                          String indexedProperty,
                                                          long startValue,
                                                          int limit,
                                                          long maxQueryTime)
focal_class.identifier: queryWithRetry
focal_class.modifiers: @NotNull private
focal_class.parameters: (Collection<T> collection,
                                                          String fromKey,
                                                          String toKey,
                                                          String indexedProperty,
                                                          long startValue,
                                                          int limit,
                                                          long maxQueryTime)
focal_class.return: List<T>
focal_class.signature: List<T> queryWithRetry(Collection<T> collection,
                                                          String fromKey,
                                                          String toKey,
                                                          String indexedProperty,
                                                          long startValue,
                                                          int limit,
                                                          long maxQueryTime)
focal_class.class_method_signature: MongoDocumentStore.queryInternal(Collection<T> collection,
                                                           String fromKey,
                                                           String toKey,
                                                           String indexedProperty,
                                                           long startValue,
                                                           int limit,
                                                           long maxQueryTime)
focal_class.full_signature: @SuppressWarnings("unchecked") @NotNull protected List<T> queryInternal(Collection<T> collection,
                                                           String fromKey,
                                                           String toKey,
                                                           String indexedProperty,
                                                           long startValue,
                                                           int limit,
                                                           long maxQueryTime)
focal_class.identifier: queryInternal
focal_class.modifiers: @SuppressWarnings("unchecked") @NotNull protected
focal_class.parameters: (Collection<T> collection,
                                                           String fromKey,
                                                           String toKey,
                                                           String indexedProperty,
                                                           long startValue,
                                                           int limit,
                                                           long maxQueryTime)
focal_class.return: List<T>
focal_class.signature: List<T> queryInternal(Collection<T> collection,
                                                           String fromKey,
                                                           String toKey,
                                                           String indexedProperty,
                                                           long startValue,
                                                           int limit,
                                                           long maxQueryTime)
focal_class.class_method_signature: MongoDocumentStore.canUseModifiedTimeIdx(long modifiedTimeInSecs)
focal_class.full_signature:  boolean canUseModifiedTimeIdx(long modifiedTimeInSecs)
focal_class.identifier: canUseModifiedTimeIdx
focal_class.parameters: (long modifiedTimeInSecs)
focal_class.return: boolean
focal_class.signature: boolean canUseModifiedTimeIdx(long modifiedTimeInSecs)
focal_class.class_method_signature: MongoDocumentStore.remove(Collection<T> collection, String key)
focal_class.full_signature: @Override public void remove(Collection<T> collection, String key)
focal_class.identifier: remove
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, String key)
focal_class.return: void
focal_class.signature: void remove(Collection<T> collection, String key)
focal_class.class_method_signature: MongoDocumentStore.remove(Collection<T> collection, List<String> keys)
focal_class.full_signature: @Override public void remove(Collection<T> collection, List<String> keys)
focal_class.identifier: remove
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, List<String> keys)
focal_class.return: void
focal_class.signature: void remove(Collection<T> collection, List<String> keys)
focal_class.class_method_signature: MongoDocumentStore.remove(Collection<T> collection, Map<String, Long> toRemove)
focal_class.full_signature: @Override public int remove(Collection<T> collection, Map<String, Long> toRemove)
focal_class.identifier: remove
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, Map<String, Long> toRemove)
focal_class.return: int
focal_class.signature: int remove(Collection<T> collection, Map<String, Long> toRemove)
focal_class.class_method_signature: MongoDocumentStore.remove(Collection<T> collection,
                                      String indexedProperty, long startValue, long endValue)
focal_class.full_signature: @Override public int remove(Collection<T> collection,
                                      String indexedProperty, long startValue, long endValue)
focal_class.identifier: remove
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection,
                                      String indexedProperty, long startValue, long endValue)
focal_class.return: int
focal_class.signature: int remove(Collection<T> collection,
                                      String indexedProperty, long startValue, long endValue)
focal_class.class_method_signature: MongoDocumentStore.findAndModify(Collection<T> collection,
                                                   UpdateOp updateOp,
                                                   boolean upsert,
                                                   boolean checkConditions)
focal_class.full_signature: @SuppressWarnings("unchecked") @Nullable private T findAndModify(Collection<T> collection,
                                                   UpdateOp updateOp,
                                                   boolean upsert,
                                                   boolean checkConditions)
focal_class.identifier: findAndModify
focal_class.modifiers: @SuppressWarnings("unchecked") @Nullable private
focal_class.parameters: (Collection<T> collection,
                                                   UpdateOp updateOp,
                                                   boolean upsert,
                                                   boolean checkConditions)
focal_class.return: T
focal_class.signature: T findAndModify(Collection<T> collection,
                                                   UpdateOp updateOp,
                                                   boolean upsert,
                                                   boolean checkConditions)
focal_class.class_method_signature: MongoDocumentStore.createOrUpdate(Collection<T> collection, UpdateOp update)
focal_class.full_signature: @Nullable @Override public T createOrUpdate(Collection<T> collection, UpdateOp update)
focal_class.identifier: createOrUpdate
focal_class.modifiers: @Nullable @Override public
focal_class.parameters: (Collection<T> collection, UpdateOp update)
focal_class.return: T
focal_class.signature: T createOrUpdate(Collection<T> collection, UpdateOp update)
focal_class.class_method_signature: MongoDocumentStore.createOrUpdate(Collection<T> collection,
                                                         List<UpdateOp> updateOps)
focal_class.full_signature: @SuppressWarnings("unchecked") @Nullable @Override public List<T> createOrUpdate(Collection<T> collection,
                                                         List<UpdateOp> updateOps)
focal_class.identifier: createOrUpdate
focal_class.modifiers: @SuppressWarnings("unchecked") @Nullable @Override public
focal_class.parameters: (Collection<T> collection,
                                                         List<UpdateOp> updateOps)
focal_class.return: List<T>
focal_class.signature: List<T> createOrUpdate(Collection<T> collection,
                                                         List<UpdateOp> updateOps)
focal_class.class_method_signature: MongoDocumentStore.getCachedNodes(Set<String> keys)
focal_class.full_signature: private Map<String, NodeDocument> getCachedNodes(Set<String> keys)
focal_class.identifier: getCachedNodes
focal_class.modifiers: private
focal_class.parameters: (Set<String> keys)
focal_class.return: Map<String, NodeDocument>
focal_class.signature: Map<String, NodeDocument> getCachedNodes(Set<String> keys)
focal_class.class_method_signature: MongoDocumentStore.bulkUpdate(Collection<T> collection,
                                                               List<UpdateOp> updateOperations,
                                                               Map<String, T> oldDocs)
focal_class.full_signature: private Map<UpdateOp, T> bulkUpdate(Collection<T> collection,
                                                               List<UpdateOp> updateOperations,
                                                               Map<String, T> oldDocs)
focal_class.identifier: bulkUpdate
focal_class.modifiers: private
focal_class.parameters: (Collection<T> collection,
                                                               List<UpdateOp> updateOperations,
                                                               Map<String, T> oldDocs)
focal_class.return: Map<UpdateOp, T>
focal_class.signature: Map<UpdateOp, T> bulkUpdate(Collection<T> collection,
                                                               List<UpdateOp> updateOperations,
                                                               Map<String, T> oldDocs)
focal_class.class_method_signature: MongoDocumentStore.createMap(List<UpdateOp> updateOps)
focal_class.full_signature: private static Map<String, UpdateOp> createMap(List<UpdateOp> updateOps)
focal_class.identifier: createMap
focal_class.modifiers: private static
focal_class.parameters: (List<UpdateOp> updateOps)
focal_class.return: Map<String, UpdateOp>
focal_class.signature: Map<String, UpdateOp> createMap(List<UpdateOp> updateOps)
focal_class.class_method_signature: MongoDocumentStore.findDocuments(Collection<T> collection, Set<String> keys)
focal_class.full_signature: private Map<String, T> findDocuments(Collection<T> collection, Set<String> keys)
focal_class.identifier: findDocuments
focal_class.modifiers: private
focal_class.parameters: (Collection<T> collection, Set<String> keys)
focal_class.return: Map<String, T>
focal_class.signature: Map<String, T> findDocuments(Collection<T> collection, Set<String> keys)
focal_class.class_method_signature: MongoDocumentStore.sendBulkUpdate(Collection<T> collection,
              java.util.Collection<UpdateOp> updateOps, Map<String, T> oldDocs)
focal_class.full_signature: private BulkUpdateResult sendBulkUpdate(Collection<T> collection,
              java.util.Collection<UpdateOp> updateOps, Map<String, T> oldDocs)
focal_class.identifier: sendBulkUpdate
focal_class.modifiers: private
focal_class.parameters: (Collection<T> collection,
              java.util.Collection<UpdateOp> updateOps, Map<String, T> oldDocs)
focal_class.return: BulkUpdateResult
focal_class.signature: BulkUpdateResult sendBulkUpdate(Collection<T> collection,
              java.util.Collection<UpdateOp> updateOps, Map<String, T> oldDocs)
focal_class.class_method_signature: MongoDocumentStore.findAndUpdate(Collection<T> collection, UpdateOp update)
focal_class.full_signature: @Override public T findAndUpdate(Collection<T> collection, UpdateOp update)
focal_class.identifier: findAndUpdate
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, UpdateOp update)
focal_class.return: T
focal_class.signature: T findAndUpdate(Collection<T> collection, UpdateOp update)
focal_class.class_method_signature: MongoDocumentStore.create(Collection<T> collection, List<UpdateOp> updateOps)
focal_class.full_signature: @Override public boolean create(Collection<T> collection, List<UpdateOp> updateOps)
focal_class.identifier: create
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, List<UpdateOp> updateOps)
focal_class.return: boolean
focal_class.signature: boolean create(Collection<T> collection, List<UpdateOp> updateOps)
focal_class.class_method_signature: MongoDocumentStore.getModStamps(Iterable<String> keys)
focal_class.full_signature: @NotNull private Map<String, ModificationStamp> getModStamps(Iterable<String> keys)
focal_class.identifier: getModStamps
focal_class.modifiers: @NotNull private
focal_class.parameters: (Iterable<String> keys)
focal_class.return: Map<String, ModificationStamp>
focal_class.signature: Map<String, ModificationStamp> getModStamps(Iterable<String> keys)
focal_class.class_method_signature: MongoDocumentStore.getReadPreference(int maxCacheAge)
focal_class.full_signature:  DocumentReadPreference getReadPreference(int maxCacheAge)
focal_class.identifier: getReadPreference
focal_class.parameters: (int maxCacheAge)
focal_class.return: DocumentReadPreference
focal_class.signature: DocumentReadPreference getReadPreference(int maxCacheAge)
focal_class.class_method_signature: MongoDocumentStore.getDefaultReadPreference(Collection col)
focal_class.full_signature:  DocumentReadPreference getDefaultReadPreference(Collection col)
focal_class.identifier: getDefaultReadPreference
focal_class.parameters: (Collection col)
focal_class.return: DocumentReadPreference
focal_class.signature: DocumentReadPreference getDefaultReadPreference(Collection col)
focal_class.class_method_signature: MongoDocumentStore.getMongoReadPreference(@NotNull Collection<T> collection,
                                                                 @Nullable String parentId,
                                                                 @NotNull DocumentReadPreference preference)
focal_class.full_signature:  ReadPreference getMongoReadPreference(@NotNull Collection<T> collection,
                                                                 @Nullable String parentId,
                                                                 @NotNull DocumentReadPreference preference)
focal_class.identifier: getMongoReadPreference
focal_class.parameters: (@NotNull Collection<T> collection,
                                                                 @Nullable String parentId,
                                                                 @NotNull DocumentReadPreference preference)
focal_class.return: ReadPreference
focal_class.signature: ReadPreference getMongoReadPreference(@NotNull Collection<T> collection,
                                                                 @Nullable String parentId,
                                                                 @NotNull DocumentReadPreference preference)
focal_class.class_method_signature: MongoDocumentStore.getConfiguredReadPreference(Collection<T> collection)
focal_class.full_signature:  ReadPreference getConfiguredReadPreference(Collection<T> collection)
focal_class.identifier: getConfiguredReadPreference
focal_class.parameters: (Collection<T> collection)
focal_class.return: ReadPreference
focal_class.signature: ReadPreference getConfiguredReadPreference(Collection<T> collection)
focal_class.class_method_signature: MongoDocumentStore.convertFromDBObject(@NotNull Collection<T> collection,
                                                           @Nullable DBObject n)
focal_class.full_signature: @Nullable protected T convertFromDBObject(@NotNull Collection<T> collection,
                                                           @Nullable DBObject n)
focal_class.identifier: convertFromDBObject
focal_class.modifiers: @Nullable protected
focal_class.parameters: (@NotNull Collection<T> collection,
                                                           @Nullable DBObject n)
focal_class.return: T
focal_class.signature: T convertFromDBObject(@NotNull Collection<T> collection,
                                                           @Nullable DBObject n)
focal_class.class_method_signature: MongoDocumentStore.convertMongoMap(@NotNull BasicDBObject obj)
focal_class.full_signature: @NotNull private Map<Revision, Object> convertMongoMap(@NotNull BasicDBObject obj)
focal_class.identifier: convertMongoMap
focal_class.modifiers: @NotNull private
focal_class.parameters: (@NotNull BasicDBObject obj)
focal_class.return: Map<Revision, Object>
focal_class.signature: Map<Revision, Object> convertMongoMap(@NotNull BasicDBObject obj)
focal_class.class_method_signature: MongoDocumentStore.getDBCollection(Collection<T> collection)
focal_class.full_signature:  MongoCollection<BasicDBObject> getDBCollection(Collection<T> collection)
focal_class.identifier: getDBCollection
focal_class.parameters: (Collection<T> collection)
focal_class.return: MongoCollection<BasicDBObject>
focal_class.signature: MongoCollection<BasicDBObject> getDBCollection(Collection<T> collection)
focal_class.class_method_signature: MongoDocumentStore.getDBCollection(Collection<T> collection,
                                                                          ReadPreference readPreference)
focal_class.full_signature:  MongoCollection<BasicDBObject> getDBCollection(Collection<T> collection,
                                                                          ReadPreference readPreference)
focal_class.identifier: getDBCollection
focal_class.parameters: (Collection<T> collection,
                                                                          ReadPreference readPreference)
focal_class.return: MongoCollection<BasicDBObject>
focal_class.signature: MongoCollection<BasicDBObject> getDBCollection(Collection<T> collection,
                                                                          ReadPreference readPreference)
focal_class.class_method_signature: MongoDocumentStore.getDatabase()
focal_class.full_signature:  MongoDatabase getDatabase()
focal_class.identifier: getDatabase
focal_class.parameters: ()
focal_class.return: MongoDatabase
focal_class.signature: MongoDatabase getDatabase()
focal_class.class_method_signature: MongoDocumentStore.getClient()
focal_class.full_signature:  MongoClient getClient()
focal_class.identifier: getClient
focal_class.parameters: ()
focal_class.return: MongoClient
focal_class.signature: MongoClient getClient()
focal_class.class_method_signature: MongoDocumentStore.getByKeyQuery(String key)
focal_class.full_signature: private static Bson getByKeyQuery(String key)
focal_class.identifier: getByKeyQuery
focal_class.modifiers: private static
focal_class.parameters: (String key)
focal_class.return: Bson
focal_class.signature: Bson getByKeyQuery(String key)
focal_class.class_method_signature: MongoDocumentStore.dispose()
focal_class.full_signature: @Override public void dispose()
focal_class.identifier: dispose
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void dispose()
focal_class.class_method_signature: MongoDocumentStore.getCacheStats()
focal_class.full_signature: @Override public Iterable<CacheStats> getCacheStats()
focal_class.identifier: getCacheStats
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Iterable<CacheStats>
focal_class.signature: Iterable<CacheStats> getCacheStats()
focal_class.class_method_signature: MongoDocumentStore.getMetadata()
focal_class.full_signature: @Override public Map<String, String> getMetadata()
focal_class.identifier: getMetadata
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Map<String, String>
focal_class.signature: Map<String, String> getMetadata()
focal_class.class_method_signature: MongoDocumentStore.getStats()
focal_class.full_signature: @NotNull @Override public Map<String, String> getStats()
focal_class.identifier: getStats
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: ()
focal_class.return: Map<String, String>
focal_class.signature: Map<String, String> getStats()
focal_class.class_method_signature: MongoDocumentStore.getMaxDeltaForModTimeIdxSecs()
focal_class.full_signature:  long getMaxDeltaForModTimeIdxSecs()
focal_class.identifier: getMaxDeltaForModTimeIdxSecs
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getMaxDeltaForModTimeIdxSecs()
focal_class.class_method_signature: MongoDocumentStore.getDisableIndexHint()
focal_class.full_signature:  boolean getDisableIndexHint()
focal_class.identifier: getDisableIndexHint
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean getDisableIndexHint()
focal_class.class_method_signature: MongoDocumentStore.log(String message, Object... args)
focal_class.full_signature: private static void log(String message, Object... args)
focal_class.identifier: log
focal_class.modifiers: private static
focal_class.parameters: (String message, Object... args)
focal_class.return: void
focal_class.signature: void log(String message, Object... args)
focal_class.class_method_signature: MongoDocumentStore.getIfCached(Collection<T> collection, String key)
focal_class.full_signature: @Override public T getIfCached(Collection<T> collection, String key)
focal_class.identifier: getIfCached
focal_class.modifiers: @Override public
focal_class.parameters: (Collection<T> collection, String key)
focal_class.return: T
focal_class.signature: T getIfCached(Collection<T> collection, String key)
focal_class.class_method_signature: MongoDocumentStore.createQueryForUpdate(String key,
                                               Map<Key, Condition> conditions)
focal_class.full_signature: @NotNull private static Bson createQueryForUpdate(String key,
                                               Map<Key, Condition> conditions)
focal_class.identifier: createQueryForUpdate
focal_class.modifiers: @NotNull private static
focal_class.parameters: (String key,
                                               Map<Key, Condition> conditions)
focal_class.return: Bson
focal_class.signature: Bson createQueryForUpdate(String key,
                                               Map<Key, Condition> conditions)
focal_class.class_method_signature: MongoDocumentStore.createUpdate(UpdateOp updateOp,
                                                boolean failOnInsert)
focal_class.full_signature: private static BasicDBObject createUpdate(UpdateOp updateOp,
                                                boolean failOnInsert)
focal_class.identifier: createUpdate
focal_class.modifiers: private static
focal_class.parameters: (UpdateOp updateOp,
                                                boolean failOnInsert)
focal_class.return: BasicDBObject
focal_class.signature: BasicDBObject createUpdate(UpdateOp updateOp,
                                                boolean failOnInsert)
focal_class.class_method_signature: MongoDocumentStore.applyChanges(Collection<T> collection, T oldDoc, UpdateOp update)
focal_class.full_signature: @NotNull private T applyChanges(Collection<T> collection, T oldDoc, UpdateOp update)
focal_class.identifier: applyChanges
focal_class.modifiers: @NotNull private
focal_class.parameters: (Collection<T> collection, T oldDoc, UpdateOp update)
focal_class.return: T
focal_class.signature: T applyChanges(Collection<T> collection, T oldDoc, UpdateOp update)
focal_class.class_method_signature: MongoDocumentStore.startWatch()
focal_class.full_signature: private Stopwatch startWatch()
focal_class.identifier: startWatch
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Stopwatch
focal_class.signature: Stopwatch startWatch()
focal_class.class_method_signature: MongoDocumentStore.setReadWriteMode(String readWriteMode)
focal_class.full_signature: @Override public void setReadWriteMode(String readWriteMode)
focal_class.identifier: setReadWriteMode
focal_class.modifiers: @Override public
focal_class.parameters: (String readWriteMode)
focal_class.return: void
focal_class.signature: void setReadWriteMode(String readWriteMode)
focal_class.class_method_signature: MongoDocumentStore.getTime()
focal_class.full_signature: private long getTime()
focal_class.identifier: getTime
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getTime()
focal_class.class_method_signature: MongoDocumentStore.setClock(Clock clock)
focal_class.full_signature:  void setClock(Clock clock)
focal_class.identifier: setClock
focal_class.parameters: (Clock clock)
focal_class.return: void
focal_class.signature: void setClock(Clock clock)
focal_class.class_method_signature: MongoDocumentStore.getNodeDocumentCache()
focal_class.full_signature:  NodeDocumentCache getNodeDocumentCache()
focal_class.identifier: getNodeDocumentCache
focal_class.parameters: ()
focal_class.return: NodeDocumentCache
focal_class.signature: NodeDocumentCache getNodeDocumentCache()
focal_class.class_method_signature: MongoDocumentStore.setStatsCollector(DocumentStoreStatsCollector stats)
focal_class.full_signature: public void setStatsCollector(DocumentStoreStatsCollector stats)
focal_class.identifier: setStatsCollector
focal_class.modifiers: public
focal_class.parameters: (DocumentStoreStatsCollector stats)
focal_class.return: void
focal_class.signature: void setStatsCollector(DocumentStoreStatsCollector stats)
focal_class.class_method_signature: MongoDocumentStore.determineServerTimeDifferenceMillis()
focal_class.full_signature: @Override public long determineServerTimeDifferenceMillis()
focal_class.identifier: determineServerTimeDifferenceMillis
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long determineServerTimeDifferenceMillis()
focal_class.class_method_signature: MongoDocumentStore.handleException(Throwable ex,
                                                                          Collection<T> collection,
                                                                          Iterable<String> ids)
focal_class.full_signature: private DocumentStoreException handleException(Throwable ex,
                                                                          Collection<T> collection,
                                                                          Iterable<String> ids)
focal_class.identifier: handleException
focal_class.modifiers: private
focal_class.parameters: (Throwable ex,
                                                                          Collection<T> collection,
                                                                          Iterable<String> ids)
focal_class.return: DocumentStoreException
focal_class.signature: DocumentStoreException handleException(Throwable ex,
                                                                          Collection<T> collection,
                                                                          Iterable<String> ids)
focal_class.class_method_signature: MongoDocumentStore.handleException(Throwable ex,
                                                                          Collection<T> collection,
                                                                          String id)
focal_class.full_signature: private DocumentStoreException handleException(Throwable ex,
                                                                          Collection<T> collection,
                                                                          String id)
focal_class.identifier: handleException
focal_class.modifiers: private
focal_class.parameters: (Throwable ex,
                                                                          Collection<T> collection,
                                                                          String id)
focal_class.return: DocumentStoreException
focal_class.signature: DocumentStoreException handleException(Throwable ex,
                                                                          Collection<T> collection,
                                                                          String id)
focal_class.class_method_signature: MongoDocumentStore.toMapBuilder(ImmutableMap.Builder<String, String> builder,
                                       BasicDBObject stats,
                                       String prefix)
focal_class.full_signature: private static void toMapBuilder(ImmutableMap.Builder<String, String> builder,
                                       BasicDBObject stats,
                                       String prefix)
focal_class.identifier: toMapBuilder
focal_class.modifiers: private static
focal_class.parameters: (ImmutableMap.Builder<String, String> builder,
                                       BasicDBObject stats,
                                       String prefix)
focal_class.return: void
focal_class.signature: void toMapBuilder(ImmutableMap.Builder<String, String> builder,
                                       BasicDBObject stats,
                                       String prefix)
focal_class.class_method_signature: MongoDocumentStore.withClientSession()
focal_class.full_signature: private boolean withClientSession()
focal_class.identifier: withClientSession
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean withClientSession()
focal_class.class_method_signature: MongoDocumentStore.secondariesWithinAcceptableLag()
focal_class.full_signature: private boolean secondariesWithinAcceptableLag()
focal_class.identifier: secondariesWithinAcceptableLag
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean secondariesWithinAcceptableLag()
focal_class.class_method_signature: MongoDocumentStore.lagTooHigh()
focal_class.full_signature: private void lagTooHigh()
focal_class.identifier: lagTooHigh
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void lagTooHigh()
focal_class.class_method_signature: MongoDocumentStore.execute(DocumentStoreCallable<T> callable)
focal_class.full_signature: private T execute(DocumentStoreCallable<T> callable)
focal_class.identifier: execute
focal_class.modifiers: private
focal_class.parameters: (DocumentStoreCallable<T> callable)
focal_class.return: T
focal_class.signature: T execute(DocumentStoreCallable<T> callable)
focal_method.body: <T extends Document> MongoCollection<BasicDBObject> getDBCollection(Collection<T> collection) {
          if (collection == Collection.NODES) {
              return nodes;
          } else if (collection == Collection.CLUSTER_NODES) {
              return clusterNodes;
          } else if (collection == Collection.SETTINGS) {
              return settings;
          } else if (collection == Collection.JOURNAL) {
              return journal;
          } else {
              throw new IllegalArgumentException(
                      "Unknown collection: " + collection.toString());
          }
      }
focal_method.class_method_signature: MongoDocumentStore.getDBCollection(Collection<T> collection)
focal_method.full_signature:  MongoCollection<BasicDBObject> getDBCollection(Collection<T> collection)
focal_method.identifier: getDBCollection
focal_method.invocations: toString
focal_method.parameters: (Collection<T> collection)
focal_method.return: MongoCollection<BasicDBObject>
focal_method.signature: MongoCollection<BasicDBObject> getDBCollection(Collection<T> collection)