本文整理汇总了Java中org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair类的典型用法代码示例。如果您正苦于以下问题:Java ConfigurationPair类的具体用法?Java ConfigurationPair怎么用?Java ConfigurationPair使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ConfigurationPair类属于org.apache.hadoop.tracing.SpanReceiverInfo包,在下文中一共展示了ConfigurationPair类的6个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: addSpanReceiver
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);
}
}
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:20,代码来源:TraceAdminProtocolTranslatorPB.java
示例2: addSpanReceiver
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();
}
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:26,代码来源:TracerConfigurationManager.java
示例3: testExtraConfig
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));
}
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:14,代码来源:TestTraceUtils.java
示例4: loadInstance
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;
}
开发者ID:naver,项目名称:hadoop,代码行数:12,代码来源:SpanReceiverHost.java
示例5: testExtraConfig
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));
}
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:TestTraceUtils.java
示例6: addConfigurationPair
import org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair; //导入依赖的package包/类
public void addConfigurationPair(String key, String value) {
info.configPairs.add(new ConfigurationPair(key, value));
}
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:4,代码来源:SpanReceiverInfoBuilder.java
注:本文中的org.apache.hadoop.tracing.SpanReceiverInfo.ConfigurationPair类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论