You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by dz...@apache.org on 2022/01/31 05:30:44 UTC
[drill] branch master updated: DRILL-8118: Add Option to Allow Disk Use on Mongo Queries
This is an automated email from the ASF dual-hosted git repository.
dzamo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git
The following commit(s) were added to refs/heads/master by this push:
new 447218a DRILL-8118: Add Option to Allow Disk Use on Mongo Queries
447218a is described below
commit 447218a8d761e7d87171f430da6301360e592bbd
Author: Charles S. Givre <cg...@apache.org>
AuthorDate: Mon Jan 31 00:30:34 2022 -0500
DRILL-8118: Add Option to Allow Disk Use on Mongo Queries
---
.../org/apache/drill/exec/store/mongo/MongoStoragePluginConfig.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/MongoStoragePluginConfig.java b/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/MongoStoragePluginConfig.java
index e1da24b..385ade9 100644
--- a/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/MongoStoragePluginConfig.java
+++ b/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/MongoStoragePluginConfig.java
@@ -53,14 +53,14 @@ public class MongoStoragePluginConfig extends AbstractSecuredStoragePluginConfig
public MongoStoragePluginConfig(@JsonProperty("connection") String connection,
@JsonProperty("pluginOptimizations") MongoPluginOptimizations pluginOptimizations,
@JsonProperty("batchSize") Integer batchSize,
- @JsonProperty("allowDiskUse") Boolean allowDiskUse,
+ @JsonProperty("allowDiskUse") boolean allowDiskUse,
@JsonProperty("credentialsProvider") CredentialsProvider credentialsProvider) {
super(getCredentialsProvider(credentialsProvider), credentialsProvider == null);
this.connection = connection;
this.clientURI = new ConnectionString(connection);
this.pluginOptimizations = ObjectUtils.defaultIfNull(pluginOptimizations, new MongoPluginOptimizations());
this.batchSize = batchSize != null ? batchSize : 100;
- this.allowDiskUse = allowDiskUse != null && allowDiskUse;
+ this.allowDiskUse = allowDiskUse;
}
public MongoPluginOptimizations getPluginOptimizations() {
@@ -80,6 +80,7 @@ public class MongoStoragePluginConfig extends AbstractSecuredStoragePluginConfig
return batchSize;
}
+ @JsonProperty("allowDiskUse")
public boolean allowDiskUse() {
return allowDiskUse;
}