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

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

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

JavaConversions.mapAsJavaMap介绍

暂无

代码示例

代码示例来源：origin: twosigma/beakerx

@Override
 public boolean writeObject(Object obj, JsonGenerator jgen, boolean expand) throws JsonProcessingException, IOException {
  logger.debug("list of maps");
  // convert this 'on the fly' to a datatable
  Collection<?> col = scala.collection.JavaConversions.asJavaCollection((Iterable<?>) obj);
  List<Map<String, Object>> tab = new ArrayList<Map<String, Object>>();
  for (Object o : col) {
   Map<String, Object> row = scala.collection.JavaConversions.mapAsJavaMap((scala.collection.Map<String, Object>) o);
   tab.add(row);
  }
  TableDisplay t = new TableDisplay(tab, parent);
  jgen.writeObject(t);
  return true;
 }
}

代码示例来源：origin: twosigma/beakerx

@Override
 public boolean writeObject(Object obj, JsonGenerator jgen, boolean expand) throws JsonProcessingException, IOException {
  logger.debug("primitive type map");

  List<String> columns = new ArrayList<String>();
  columns.add("Key");
  columns.add("Value");

  List<List<?>> values = new ArrayList<List<?>>();

  Map<?, ?> m = scala.collection.JavaConversions.mapAsJavaMap((scala.collection.Map<?, ?>) obj);
  Set<?> keys = m.keySet();
  for (Object key : keys) {
   Object val = m.get(key);
   List<Object> l = new ArrayList<Object>();
   l.add(key.toString());
   l.add(val);
   values.add(l);
  }

  jgen.writeStartObject();
  jgen.writeObjectField("type", "TableDisplay");
  jgen.writeObjectField("columnNames", columns);
  jgen.writeObjectField("values", values);
  jgen.writeObjectField("subtype", TableDisplay.DICTIONARY_SUBTYPE);
  jgen.writeEndObject();
  return true;
 }
}

代码示例来源：origin: twosigma/beakerx

@Override
public boolean canBeUsed(Object obj, boolean expand) {
 if (!expand)
  return false;
 if (!(obj instanceof scala.collection.immutable.Map))
  return false;
 Map<?, ?> m = scala.collection.JavaConversions.mapAsJavaMap((scala.collection.Map<?, ?>) obj);
 Set<?> keys = m.keySet();
 for (Object key : keys) {
  if (key != null && !parent.isPrimitiveType(key.getClass().getName()))
   return false;
  Object val = m.get(key);
  if (val != null && !parent.isPrimitiveType(val.getClass().getName()))
   return false;
 }
 return true;
}

代码示例来源：origin: twosigma/beakerx

@Override
 public boolean writeObject(Object obj, JsonGenerator jgen, boolean expand) throws JsonProcessingException, IOException {
  logger.debug("generic map");
  // convert this 'on the fly' to a map of objects
  Map<?, ?> m = scala.collection.JavaConversions.mapAsJavaMap((scala.collection.Map<?, ?>) obj);

  Set<?> keys = m.keySet();
  for (Object key : keys) {
   if (key == null || !(key instanceof String)) {
    jgen.writeObject(obj.toString());
    return true;
   }
  }

  jgen.writeStartObject();
  for (Object key : keys) {
   Object val = m.get(key);
   jgen.writeFieldName(key.toString());
   if (!parent.writeObject(val, jgen, false))
    jgen.writeObject(val != null ? (val.toString()) : "null");
  }
  jgen.writeEndObject();
  return true;
 }
}

代码示例来源：origin: twosigma/beakerx

@Override
public boolean canBeUsed(Object obj, boolean expand) {
 if (!expand)
  return false;
 if (!(obj instanceof scala.collection.immutable.Seq<?>))
  return false;
 Collection<?> col = scala.collection.JavaConversions.asJavaCollection((Iterable<?>) obj);
 if (col.isEmpty())
  return false;
 for (Object o : col) {
  if (!(o instanceof scala.collection.Map<?, ?>))
   return false;
  Map<?, ?> m = scala.collection.JavaConversions.mapAsJavaMap((scala.collection.Map<?, ?>) o);
  Set<?> keys = m.keySet();
  for (Object key : keys) {
   if (key != null && !parent.isPrimitiveType(key.getClass().getName()))
    return false;
   Object val = m.get(key);
   if (val != null && !parent.isPrimitiveType(val.getClass().getName()))
    return false;
  }
 }
 return true;
}

代码示例来源：origin: Graylog2/graylog2-server

/**
 * A Java transliteration of what the scala implementation does, which unfortunately is declared as private
 */
protected void flushDirtyLogs() {
  LOG.debug("Checking for dirty logs to flush...");
  final Set<Map.Entry<TopicAndPartition, Log>> entries = JavaConversions.mapAsJavaMap(logManager.logsByTopicPartition()).entrySet();
  for (final Map.Entry<TopicAndPartition, Log> topicAndPartitionLogEntry : entries) {
    final TopicAndPartition topicAndPartition = topicAndPartitionLogEntry.getKey();
    final Log kafkaLog = topicAndPartitionLogEntry.getValue();
    final long timeSinceLastFlush = JODA_TIME.milliseconds() - kafkaLog.lastFlushTime();
    try {
      LOG.debug(
          "Checking if flush is needed on {} flush interval {} last flushed {} time since last flush: {}",
          topicAndPartition.topic(),
          kafkaLog.config().flushInterval(),
          kafkaLog.lastFlushTime(),
          timeSinceLastFlush);
      if (timeSinceLastFlush >= kafkaLog.config().flushMs()) {
        kafkaLog.flush();
      }
    } catch (Exception e) {
      LOG.error("Error flushing topic " + topicAndPartition.topic(), e);
    }
  }
}

代码示例来源：origin: com.typesafe.play/play_2.10

/**
 * Creates a new HTTP context.
 *
 * @param request the HTTP request
 */
public Context(Request request) {
  this.request = request;
  this.header = request._underlyingHeader();
  this.id = header.id();
  this.response = new Response();
  this.session = new Session(JavaConversions.mapAsJavaMap(header.session().data()));
  this.flash = new Flash(JavaConversions.mapAsJavaMap(header.flash().data()));
  this.args = new HashMap<String,Object>();
  this.args.putAll(JavaConversions.mapAsJavaMap(header.tags()));
}

代码示例来源：origin: com.typesafe.play/play_2.10

/**
 * @return the sessions in the request
 */
public Map<String,String> session() {
 play.api.mvc.Cookies scalaCookies = scalaCookies();
 scala.Option<play.api.mvc.Cookie> cookie = scalaCookies.get(play.api.mvc.Session$.MODULE$.COOKIE_NAME());
 scala.collection.Map<String,String> data = play.api.mvc.Session$.MODULE$.decodeCookieToMap(cookie);
 return JavaConversions.mapAsJavaMap(data);
}

代码示例来源：origin: com.typesafe.play/play_2.10

/**
 * @return the cookies in a Java map
 */
public Map<String,String> flash() {
 play.api.mvc.Cookies scalaCookies = scalaCookies();
 scala.Option<play.api.mvc.Cookie> cookie = scalaCookies.get(play.api.mvc.Flash$.MODULE$.COOKIE_NAME());
 scala.collection.Map<String,String> data = play.api.mvc.Flash$.MODULE$.decodeCookieToMap(cookie);
 return JavaConversions.mapAsJavaMap(data);
}

代码示例来源：origin: apache/crunch

/** Called by the default implementation of {@link #writeMap} to enumerate
  * map elements.  The default implementation is for {@link Map}.*/
 @SuppressWarnings("unchecked")
 protected Iterable<Map.Entry<Object,Object>> getMapEntries(Object map) {
  if (map instanceof scala.collection.Map) {
   return JavaConversions.mapAsJavaMap((scala.collection.Map) map).entrySet();
  }
  return super.getMapEntries(map);
 }
}

代码示例来源：origin: com.github.gitssie/play-transport

public static Map<String, String> urlDecode(String body,String encode) throws IOException{
    Map<String, String> postData = Maps.newHashMap();
    scala.collection.immutable.Map<String, Seq<String>> formData = FormUrlEncodedParser.parse(body,encode);
    Map<String, Seq<String>> map = JavaConversions.mapAsJavaMap(formData);
    for(Map.Entry<String, Seq<String>> entry : map.entrySet()){
      postData.put(entry.getKey(), entry.getValue().apply(0));
    }
    return postData;
  }
}

代码示例来源：origin: SiftScience/kafka-assigner

JavaConversions.mapAsJavaMap(topicMap);
for (Map.Entry<String, scala.collection.Map<Object,
    scala.collection.Seq<Object>>> topicMapEntry : convertedTopicMap.entrySet()) {
  String topic = topicMapEntry.getKey();
  Map<Object, scala.collection.Seq<Object>> convertedPartitionMap =
      JavaConversions.mapAsJavaMap(topicMapEntry.getValue());
  Map<Integer, List<Integer>> resultPartitionMap = Maps.newHashMap();
  for (Map.Entry<Object, scala.collection.Seq<Object>> partitionMapEntry :

代码示例来源：origin: play/play-java

@Override
  public UserInfo apply(play.api.libs.openid.UserInfo scalaUserInfo) {
    return new UserInfo(scalaUserInfo.id(), JavaConversions.mapAsJavaMap(scalaUserInfo.attributes()));
  }
},Invoker.executionContext());

代码示例来源：origin: com.typesafe.play/play-java-ws

@Override
  public UserInfo apply(play.api.libs.openid.UserInfo scalaUserInfo) {
    return new UserInfo(scalaUserInfo.id(), JavaConversions.mapAsJavaMap(scalaUserInfo.attributes()));
  }
}, Execution.internalContext());

代码示例来源：origin: uk.gov.gchq.gaffer/parquet-store

objectsList.add(((WrappedArray) nestedRow).array());
} else if (nestedRow instanceof scala.collection.Map) {
  objectsList.add(scala.collection.JavaConversions.mapAsJavaMap((scala.collection.Map) nestedRow));
} else if (nestedRow instanceof Object[]) {
  objectsList.add(nestedRow);

代码示例来源：origin: kframework/k

private Sort nthArgSort(KLabel klabel, int n) {
    java.util.Set<Tuple2<Seq<Sort>,Sort>> sigs =
        mutable(JavaConversions.mapAsJavaMap(module.signatureFor()).get(klabel));
    if (sigs == null) {
      throw new IllegalArgumentException("Not found signature for label: " + klabel);
    }
    Sort sort = null;
    for (Tuple2<Seq<Sort>,Sort> sig : sigs) {
      List<Sort> sorts = JavaConversions.seqAsJavaList(sig._1());
      if (n >= sorts.size()) continue;
      sort = sorts.get(n);
      if (!sort.equals(Sorts.K())) {
        return sort;
      }
    }
    return sort;
  }
}

代码示例来源：origin: kframework/k

JavaConversions.mapAsJavaMap(moduleWithPolyProds.signatureFor()).entrySet().stream().forEach(e -> {
  JavaConversions.setAsJavaSet(e.getValue()).stream().forEach(p -> {
    ImmutableList.Builder<Sort> sortsBuilder = ImmutableList.builder();
JavaConversions.mapAsJavaMap(module.attributesFor()).entrySet().stream().forEach(e -> {
  attributesBuilder.put(e.getKey().name(), e.getValue());
});

代码示例来源：origin: org.graylog2/graylog2-server

/**
 * A Java transliteration of what the scala implementation does, which unfortunately is declared as private
 */
protected void flushDirtyLogs() {
  LOG.debug("Checking for dirty logs to flush...");
  final Set<Map.Entry<TopicAndPartition, Log>> entries = JavaConversions.mapAsJavaMap(logManager.logsByTopicPartition()).entrySet();
  for (final Map.Entry<TopicAndPartition, Log> topicAndPartitionLogEntry : entries) {
    final TopicAndPartition topicAndPartition = topicAndPartitionLogEntry.getKey();
    final Log kafkaLog = topicAndPartitionLogEntry.getValue();
    final long timeSinceLastFlush = JODA_TIME.milliseconds() - kafkaLog.lastFlushTime();
    try {
      LOG.debug(
          "Checking if flush is needed on {} flush interval {} last flushed {} time since last flush: {}",
          topicAndPartition.topic(),
          kafkaLog.config().flushInterval(),
          kafkaLog.lastFlushTime(),
          timeSinceLastFlush);
      if (timeSinceLastFlush >= kafkaLog.config().flushMs()) {
        kafkaLog.flush();
      }
    } catch (Exception e) {
      LOG.error("Error flushing topic " + topicAndPartition.topic(), e);
    }
  }
}

代码示例来源：origin: org.graylog2/graylog2-shared

/**
 * A Java transliteration of what the scala implementation does, which unfortunately is declared as private
 */
protected void flushDirtyLogs() {
  LOG.debug("Checking for dirty logs to flush...");
  final Set<Map.Entry<TopicAndPartition, Log>> entries = JavaConversions.mapAsJavaMap(logManager.logsByTopicPartition()).entrySet();
  for (final Map.Entry<TopicAndPartition, Log> topicAndPartitionLogEntry : entries) {
    final TopicAndPartition topicAndPartition = topicAndPartitionLogEntry.getKey();
    final Log kafkaLog = topicAndPartitionLogEntry.getValue();
    final long timeSinceLastFlush = JODA_TIME.milliseconds() - kafkaLog.lastFlushTime();
    try {
      LOG.debug(
          "Checking if flush is needed on {} flush interval {} last flushed {} time since last flush: {}",
          topicAndPartition.topic(),
          kafkaLog.config().flushInterval(),
          kafkaLog.lastFlushTime(),
          timeSinceLastFlush);
      if (timeSinceLastFlush >= kafkaLog.config().flushMs()) {
        kafkaLog.flush();
      }
    } catch (Exception e) {
      LOG.error("Error flushing topic " + topicAndPartition.topic(), e);
    }
  }
}

代码示例来源：origin: apache/samza

@Test
 public void testGetIntermediateStreamProperties() {
  Map<String, String> config = new HashMap<>();
  KafkaSystemFactory factory = new KafkaSystemFactory();
  Map<String, Properties> properties = JavaConversions.mapAsJavaMap(
    factory.getIntermediateStreamProperties(new MapConfig(config)));
  assertTrue(properties.isEmpty());

  // no properties for stream
  config.put("streams.test.samza.intermediate", "true");
  config.put("streams.test.compression.type", "lz4"); //some random config
  properties = JavaConversions.mapAsJavaMap(
    factory.getIntermediateStreamProperties(new MapConfig(config)));
  assertTrue(properties.isEmpty());

  config.put(ApplicationConfig.APP_MODE, ApplicationConfig.ApplicationMode.BATCH.name());
  properties = JavaConversions.mapAsJavaMap(
    factory.getIntermediateStreamProperties(new MapConfig(config)));
  assertTrue(!properties.isEmpty());
  Properties prop = properties.get("test");
  assertEquals(prop.getProperty("retention.ms"), String.valueOf(KafkaConfig.DEFAULT_RETENTION_MS_FOR_BATCH()));
  assertEquals(prop.getProperty("compression.type"), "lz4");
 }
}

内容来源于网络，如有侵权，请联系作者删除！

JavaConversions

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com