本文整理了Java中scala.collection.JavaConverters.mapAsJavaMap()
方法的一些代码示例,展示了JavaConverters.mapAsJavaMap()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JavaConverters.mapAsJavaMap()
方法的具体详情如下:
包路径:scala.collection.JavaConverters
类名称:JavaConverters
方法名:mapAsJavaMap
暂无
代码示例来源:origin: sdl/odata
/**
* Checks if we are trying to force expand all Nav properties for function calls by looking at expand parameter.
*
* @param oDataUri The OData URI
* @return boolean if force expand parameter is set
*/
public static boolean isForceExpandParamSet(ODataUri oDataUri) {
if (isFunctionCallUri(oDataUri)) {
// Check if we have expand param set to true
Option<scala.collection.immutable.Map<String, String>> params = getFunctionCallParameters(oDataUri);
if (params.isDefined() && !params.get().isEmpty()) {
Map<String, String> parametersMap = JavaConverters.mapAsJavaMap(params.get());
if (parametersMap.containsKey(FORCE_EXPAND_PARAM)) {
return Boolean.parseBoolean(parametersMap.get(FORCE_EXPAND_PARAM));
}
}
}
return false;
}
代码示例来源:origin: com.sdl/odata_renderer
/**
* Checks if we are trying to force expand all Nav properties for function calls by looking at expand parameter.
*
* @param oDataUri The OData URI
* @return boolean if force expand parameter is set
*/
public static boolean isForceExpandParamSet(ODataUri oDataUri) {
if (isFunctionCallUri(oDataUri)) {
// Check if we have expand param set to true
Option<scala.collection.immutable.Map<String, String>> params = getFunctionCallParameters(oDataUri);
if (params.isDefined() && !params.get().isEmpty()) {
Map<String, String> parametersMap = JavaConverters.mapAsJavaMap(params.get());
if (parametersMap.containsKey(FORCE_EXPAND_PARAM)) {
return Boolean.parseBoolean(parametersMap.get(FORCE_EXPAND_PARAM));
}
}
}
return false;
}
代码示例来源:origin: sdl/odata
private void fillOperationParameters(Object functionOperationObject,
Option<scala.collection.immutable.Map<String, String>> functionCallParameters,
Set<Parameter> parameters)
throws ODataUnmarshallingException {
StringBuilder validationMessage = new StringBuilder();
if (functionCallParameters.isDefined() && !functionCallParameters.get().isEmpty()) {
Map<String, String> parametersMap = JavaConverters.mapAsJavaMap(functionCallParameters.get());
validateAndSetParameters(functionOperationObject, parameters, parametersMap, validationMessage);
} else {
validateAndSetParameters(functionOperationObject, parameters, null, validationMessage);
}
if (!"".equals(validationMessage.toString())) {
throwValidationException(validationMessage);
}
}
代码示例来源:origin: com.sdl/odata_processor
private void fillOperationParameters(Object functionOperationObject,
Option<scala.collection.immutable.Map<String, String>> functionCallParameters,
Set<Parameter> parameters)
throws ODataUnmarshallingException {
StringBuilder validationMessage = new StringBuilder();
if (functionCallParameters.isDefined() && !functionCallParameters.get().isEmpty()) {
Map<String, String> parametersMap = JavaConverters.mapAsJavaMap(functionCallParameters.get());
validateAndSetParameters(functionOperationObject, parameters, parametersMap, validationMessage);
} else {
validateAndSetParameters(functionOperationObject, parameters, null, validationMessage);
}
if (!"".equals(validationMessage.toString())) {
throwValidationException(validationMessage);
}
}
代码示例来源:origin: ContainX/marathon-ldap
@Override
public void initialize(scala.collection.immutable.Map<String, Object> map, JsObject jsObject) {
Map<String, JsValue> conf = scala.collection.JavaConverters.mapAsJavaMap(jsObject.value());
String intervalKey = "refresh-interval-seconds";
if(conf.containsKey(intervalKey)){
代码示例来源:origin: com.github.pinterest/kafkastats
scala.collection.JavaConverters.mapAsJavaMap(scalaTpMap);
brokerStats.setInReassignmentReplicas(new ArrayList<>());
for (Map.Entry<TopicAndPartition, ReassignedPartitionsContext> entry : tpMap.entrySet()) {
代码示例来源:origin: pinterest/doctorkafka
scala.collection.JavaConverters.mapAsJavaMap(scalaTpMap);
brokerStats.setInReassignmentReplicas(new ArrayList<>());
for (Map.Entry<TopicAndPartition, ReassignedPartitionsContext> entry : tpMap.entrySet()) {
代码示例来源:origin: dstl/baleen
JavaConverters.mapAsJavaMap(eventMention.arguments())
.forEach(
(k, v) ->
代码示例来源:origin: uk.gov.dstl.baleen/baleen-odin
JavaConverters.mapAsJavaMap(eventMention.arguments())
.forEach(
(k, v) ->
代码示例来源:origin: openzipkin/zipkin-finagle
@Test public void incrementsCounterWhenUnexpected_binaryAnnotation() throws Exception {
recorder.record(
new Record(root, Time.fromMilliseconds(TODAY),
new Annotation.BinaryAnnotation("web", new Date()), empty())
);
assertThat(mapAsJavaMap(stats.counters())).containsExactly(
entry(seq("record", "unhandled", "java.util.Date"), 1L)
);
}
代码示例来源:origin: openzipkin/zipkin-finagle
@Test public void incrementsCounterWhenUnexpected_annotation() throws Exception {
recorder.record(
new Record(root, Time.fromMilliseconds(TODAY), new FancyAnnotation(), empty())
);
assertThat(mapAsJavaMap(stats.counters())).containsExactly(
entry(seq("record", "unhandled", FancyAnnotation.class.getName()), 1L)
);
}
代码示例来源:origin: openzipkin/zipkin-finagle
assertThat(mapAsJavaMap(stats.counters())).containsOnly(
entry(seq("spans"), 1L),
entry(seq("span_bytes"), 165L),
代码示例来源:origin: openzipkin/zipkin-finagle
@Test
public void reportIncrementsAcceptedMetrics() throws Exception {
tracer.record(new Record(root, Time.fromMilliseconds(TODAY), new ServiceName("web"), empty()));
tracer.record(new Record(root, Time.fromMilliseconds(TODAY), new Rpc("get"), empty()));
tracer.record(new Record(root, Time.fromMilliseconds(TODAY), ClientSend$.MODULE$, empty()));
tracer.record(new Record(root, Time.fromMilliseconds(TODAY + 1), ClientRecv$.MODULE$, empty()));
tracer.reporter.flush();
assertThat(mapAsJavaMap(stats.counters())).containsExactly(
entry(seq("span_bytes"), 165L),
entry(seq("spans"), 1L),
entry(seq("spans_dropped"),0L),
entry(seq("message_bytes"), 170L),
entry(seq("messages"), 1L)
);
}
代码示例来源:origin: openzipkin/zipkin-finagle
messageSizeInBytes(asList(encoder().encode(span1), encoder().encode(span2)));
assertThat(mapAsJavaMap(stats.counters())).containsExactly(
entry(FinagleTestObjects.seq("span_bytes"), expectedSpanBytes),
entry(FinagleTestObjects.seq("spans"), 2L),
内容来源于网络,如有侵权,请联系作者删除!