aboutsummaryrefslogtreecommitdiff
path: root/common/network-common/src/main/java/org/apache/spark/network/util/MapConfigProvider.java
diff options
context:
space:
mode:
Diffstat (limited to 'common/network-common/src/main/java/org/apache/spark/network/util/MapConfigProvider.java')
-rw-r--r--common/network-common/src/main/java/org/apache/spark/network/util/MapConfigProvider.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/common/network-common/src/main/java/org/apache/spark/network/util/MapConfigProvider.java b/common/network-common/src/main/java/org/apache/spark/network/util/MapConfigProvider.java
index 9cfee7f08d..a2cf87d1af 100644
--- a/common/network-common/src/main/java/org/apache/spark/network/util/MapConfigProvider.java
+++ b/common/network-common/src/main/java/org/apache/spark/network/util/MapConfigProvider.java
@@ -43,6 +43,12 @@ public class MapConfigProvider extends ConfigProvider {
}
@Override
+ public String get(String name, String defaultValue) {
+ String value = config.get(name);
+ return value == null ? defaultValue : value;
+ }
+
+ @Override
public Iterable<Map.Entry<String, String>> getAll() {
return config.entrySet();
}