0001
0002
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018 package org.apache.spark.network.yarn.util;
0019
0020 import java.util.Map;
0021 import java.util.NoSuchElementException;
0022
0023 import org.apache.hadoop.conf.Configuration;
0024
0025 import org.apache.spark.network.util.ConfigProvider;
0026
0027
0028 public class HadoopConfigProvider extends ConfigProvider {
0029 private final Configuration conf;
0030
0031 public HadoopConfigProvider(Configuration conf) {
0032 this.conf = conf;
0033 }
0034
0035 @Override
0036 public String get(String name) {
0037 String value = conf.get(name);
0038 if (value == null) {
0039 throw new NoSuchElementException(name);
0040 }
0041 return value;
0042 }
0043
0044 @Override
0045 public String get(String name, String defaultValue) {
0046 String value = conf.get(name);
0047 return value == null ? defaultValue : value;
0048 }
0049
0050 @Override
0051 public Iterable<Map.Entry<String, String>> getAll() {
0052 return conf;
0053 }
0054
0055 }