diff options
author | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2016-12-20 16:57:15 +0000 |
---|---|---|
committer | Jinfeng Ni <jni@apache.org> | 2017-03-01 23:46:19 -0800 |
commit | dcbcb94fd2695edd4bbca63b2759292e99695d47 (patch) | |
tree | 7bbfc6493c42caa02a64d5478f65d32932417f8a /contrib/storage-mongo | |
parent | 79811db5aa8c7f2cdbe6f74c0a40124bea9fb1fd (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.java | 14 |
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); |