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 getStats() throws Exception {
          Map<String, String> info = mk.getNodeStore().getDocumentStore().getStats();
          assertThat(info.keySet(), hasItem("nodes.count"));
          assertThat(info.keySet(), hasItem("clusterNodes.count"));
          assertThat(info.keySet(), hasItem("journal.count"));
          assertThat(info.keySet(), hasItem("settings.count"));
      }
test_case.class_method_signature: MongoDocumentStoreTest.getStats()
test_case.full_signature: @Test public void getStats()
test_case.identifier: getStats
test_case.invocations: getStats getDocumentStore getNodeStore assertThat keySet hasItem assertThat keySet hasItem assertThat keySet hasItem assertThat keySet hasItem
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void getStats()
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: @NotNull
      @Override
      public Map<String, String> getStats() {
          ImmutableMap.Builder<String, String> builder = ImmutableMap.builder();
          List<MongoCollection<?>> all = ImmutableList.of(nodes, clusterNodes, settings, journal);
          all.forEach(c -> toMapBuilder(builder,
                  db.runCommand(
                      new BasicDBObject("collStats", c.getNamespace().getCollectionName()),
                          BasicDBObject.class),
                  c.getNamespace().getCollectionName()));
          return builder.build();
      }
focal_method.class_method_signature: MongoDocumentStore.getStats()
focal_method.full_signature: @NotNull @Override public Map<String, String> getStats()
focal_method.identifier: getStats
focal_method.invocations: builder of forEach toMapBuilder runCommand getCollectionName getNamespace getCollectionName getNamespace build
focal_method.modifiers: @NotNull @Override public
focal_method.parameters: ()
focal_method.return: Map<String, String>
focal_method.signature: Map<String, String> getStats()