import org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair; //导入依赖的package包/类
@Override
public long addSpanReceiver(SpanReceiverInfo info) throws IOException {
  try {
    AddSpanReceiverRequestProto.Builder bld =
        AddSpanReceiverRequestProto.newBuilder();
    bld.setClassName(info.getClassName());
    for (ConfigurationPair configPair : info.configPairs) {
      ConfigPair tuple = ConfigPair.newBuilder().
          setKey(configPair.getKey()).
          setValue(configPair.getValue()).build();
      bld.addConfig(tuple);
    }
    AddSpanReceiverResponseProto resp =
        rpcProxy.addSpanReceiver(null, bld.build());
    return resp.getId();
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}
 

import org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair; //导入依赖的package包/类
public synchronized long addSpanReceiver(SpanReceiverInfo info)
    throws IOException {
  StringBuilder configStringBuilder = new StringBuilder();
  String prefix = "";
  for (ConfigurationPair pair : info.configPairs) {
    configStringBuilder.append(prefix).append(pair.getKey()).
        append(" = ").append(pair.getValue());
    prefix = ", ";
  }
  SpanReceiver rcvr = null;
  try {
    rcvr = new SpanReceiver.Builder(TraceUtils.wrapHadoopConf(
            confPrefix, conf, info.configPairs)).
        className(info.getClassName().trim()).
        build();
  } catch (RuntimeException e) {
    LOG.info("Failed to add SpanReceiver " + info.getClassName() +
        " with configuration " + configStringBuilder.toString(), e);
    throw e;
  }
  TracerPool.getGlobalTracerPool().addReceiver(rcvr);
  LOG.info("Successfully added SpanReceiver " + info.getClassName() +
      " with configuration " + configStringBuilder.toString());
  return rcvr.getId();
}
 

import org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair; //导入依赖的package包/类
@Test
public void testExtraConfig() {
  String key = "test.extra.config";
  String oldValue = "old value";
  String newValue = "new value";
  Configuration conf = new Configuration();
  conf.set(TEST_PREFIX + key, oldValue);
  LinkedList<ConfigurationPair> extraConfig =
      new LinkedList<ConfigurationPair>();
  extraConfig.add(new ConfigurationPair(TEST_PREFIX + key, newValue));
  HTraceConfiguration wrapped = TraceUtils.wrapHadoopConf(TEST_PREFIX, conf, extraConfig);
  assertEquals(newValue, wrapped.get(key));
}
 

import org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair; //导入依赖的package包/类
private synchronized SpanReceiver loadInstance(String className,
    List<ConfigurationPair> extraConfig) throws IOException {
  SpanReceiverBuilder builder =
      new SpanReceiverBuilder(TraceUtils.
          wrapHadoopConf(confPrefix, config, extraConfig));
  SpanReceiver rcvr = builder.spanReceiverClass(className.trim()).build();
  if (rcvr == null) {
    throw new IOException("Failed to load SpanReceiver " + className);
  }
  return rcvr;
}
 

import org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair; //导入依赖的package包/类
@Test
public void testExtraConfig() {
  String key = "test.extra.config";
  String oldValue = "old value";
  String newValue = "new value";
  Configuration conf = new Configuration();
  conf.set(TEST_PREFIX + key, oldValue);
  LinkedList<ConfigurationPair> extraConfig =
      new LinkedList<ConfigurationPair>();
  extraConfig.add(new ConfigurationPair(key, newValue));
  HTraceConfiguration wrapped = TraceUtils.wrapHadoopConf(TEST_PREFIX, conf, extraConfig);
  assertEquals(newValue, wrapped.get(key));
}
 

import org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair; //导入依赖的package包/类
public void addConfigurationPair(String key, String value) {
  info.configPairs.add(new ConfigurationPair(key, value));
}