aboutsummaryrefslogtreecommitdiff
path: root/contrib/storage-mongo
diff options
context:
space:
mode:
authorArina Ielchiieva <arina.yelchiyeva@gmail.com>2016-12-20 16:57:15 +0000
committerJinfeng Ni <jni@apache.org>2017-03-01 23:46:19 -0800
commitdcbcb94fd2695edd4bbca63b2759292e99695d47 (patch)
tree7bbfc6493c42caa02a64d5478f65d32932417f8a /contrib/storage-mongo
parent79811db5aa8c7f2cdbe6f74c0a40124bea9fb1fd (diff)
DRILL-4963: Fix issues with dynamically loaded overloaded functions
close #701
Diffstat (limited to 'contrib/storage-mongo')
-rw-r--r--contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/config/MongoPersistentStore.java14
1 files changed, 13 insertions, 1 deletions
diff --git a/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/config/MongoPersistentStore.java b/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/config/MongoPersistentStore.java
index b5cc3eefa..73ff31de5 100644
--- a/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/config/MongoPersistentStore.java
+++ b/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/config/MongoPersistentStore.java
@@ -1,4 +1,4 @@
-/**
+/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
@@ -61,6 +61,18 @@ public class MongoPersistentStore<V> extends BasePersistentStore<V> {
}
@Override
+ public boolean contains(String key) {
+ try {
+ Bson query = Filters.eq(DrillMongoConstants.ID, key);
+ Document document = collection.find(query).first();
+ return document != null && document.containsKey(pKey);
+ } catch (Exception e) {
+ logger.error(e.getMessage(), e);
+ throw new DrillRuntimeException(e.getMessage(), e);
+ }
+ }
+
+ @Override
public V get(String key) {
try {
Bson query = Filters.eq(DrillMongoConstants.ID, key);