scala.collection.JavaConverters.mapAsJavaMap()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(6.3k)|赞(0)|评价(0)|浏览(115)

本文整理了Java中scala.collection.JavaConverters.mapAsJavaMap()方法的一些代码示例,展示了JavaConverters.mapAsJavaMap()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JavaConverters.mapAsJavaMap()方法的具体详情如下:
包路径:scala.collection.JavaConverters
类名称:JavaConverters
方法名:mapAsJavaMap

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),

相关文章