scala.collection.JavaConversions类的使用及代码示例

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

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

JavaConversions介绍

暂无

代码示例

代码示例来源：origin: twitter/distributedlog

private static Seq<String> gaugeName(String name) {
  return scala.collection.JavaConversions.asScalaBuffer(Arrays.asList(name)).toList();
}

代码示例来源：origin: linkedin/cruise-control

Map<Integer, String> rackByBroker = new HashMap<>();
for (BrokerMetadata bm :
   JavaConversions.seqAsJavaList(AdminUtils.getBrokerMetadatas(zkUtils, RackAwareMode.Enforced$.MODULE$, Option.empty()))) {

代码示例来源：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.immutable.Seq))
   return false;
  Collection<?> col2 = scala.collection.JavaConversions.asJavaCollection((Iterable<?>) o);
  for (Object o2 : col2) {
   if (!parent.isPrimitiveType(o2.getClass().getName()))
    return false;
  }
 }
 return true;
}

代码示例来源：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

@SuppressWarnings("unchecked")
@Override
public Object deserialize(JsonNode n, ObjectMapper mapper) {
 org.apache.commons.lang3.tuple.Pair<String, Object> deserializeObject = TableDisplayDeSerializer.getDeserializeObject(parent, n, mapper);
 String subtype = deserializeObject.getLeft();
 if (subtype != null && subtype.equals(TableDisplay.DICTIONARY_SUBTYPE)) {
  return JavaConverters.mapAsScalaMapConverter((Map<String, Object>) deserializeObject.getRight()).asScala().toMap(Predef.<Tuple2<String, Object>>conforms());
 } else if (subtype != null && subtype.equals(TableDisplay.LIST_OF_MAPS_SUBTYPE)) {
  List<Map<String, Object>> rows = (List<Map<String, Object>>) deserializeObject.getRight();
  List<Object> oo = new ArrayList<Object>();
  for (Map<String, Object> row : rows) {
   oo.add(JavaConverters.mapAsScalaMapConverter(row).asScala().toMap(Predef.<Tuple2<String, Object>>conforms()));
  }
  return scala.collection.JavaConversions.collectionAsScalaIterable(oo);
 } else if (subtype != null && subtype.equals(TableDisplay.MATRIX_SUBTYPE)) {
  List<List<?>> matrix = (List<List<?>>) deserializeObject.getRight();
  ArrayList<Object> ll = new ArrayList<Object>();
  for (List<?> ob : matrix) {
   ll.add(scala.collection.JavaConversions.asScalaBuffer(ob).toList());
  }
  return scala.collection.JavaConversions.asScalaBuffer(ll).toList();
 }
 return deserializeObject.getRight();
}

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

.fetchTopicMetadataFromZk(JavaConversions.asScalaSet(Collections.singleton(topicName)), zkClient);
if (topicMetadatas != null && topicMetadatas.size() > 0) {
  return JavaConversions.asJavaSet(topicMetadatas).iterator().next().partitionsMetadata().size();
} else {
  throw new IllegalStateException("Failed to get metadata for topic " + topicName);

代码示例来源：origin: apache/incubator-gobblin

public void pushToStream(String message) {
 int streamNo = (int) this.nextStream.incrementAndGet() % this.queues.size();
 AtomicLong offset = this.offsets.get(streamNo);
 BlockingQueue<FetchedDataChunk> queue = this.queues.get(streamNo);
 AtomicLong thisOffset = new AtomicLong(offset.incrementAndGet());
 List<Message> seq = Lists.newArrayList();
 seq.add(new Message(message.getBytes(Charsets.UTF_8)));
 ByteBufferMessageSet messageSet = new ByteBufferMessageSet(NoCompressionCodec$.MODULE$, offset, JavaConversions.asScalaBuffer(seq));
 FetchedDataChunk chunk = new FetchedDataChunk(messageSet,
   new PartitionTopicInfo("topic", streamNo, queue, thisOffset, thisOffset, new AtomicInteger(1), "clientId"),
   thisOffset.get());
 queue.add(chunk);
}

代码示例来源：origin: co.cask.cdap/cdap-api-spark2

return JavaConversions.asScalaBuffer(result).toSeq();
return JavaConversions.mapAsScalaMap(result);

代码示例来源：origin: uk.gov.dstl.baleen/baleen-odin

private DirectedGraph<String> getDependencies(uk.gov.dstl.baleen.types.language.Sentence key) {

  List<WordToken> tokens = ImmutableList.copyOf(indexWords.get(key));
  Set<Object> roots = new HashSet<>();

  List<Edge<String>> edges =
    indexDependency
      .get(key)
      .stream()
      .peek(
        d -> {
         if (MaltParser.ROOT.equals(d.getDependencyType())) {
          roots.add(tokens.indexOf(d.getGovernor()));
         }
        })
      .map(
        d -> {
         int source = tokens.indexOf(d.getGovernor());
         int destination = tokens.indexOf(d.getDependent());
         return new Edge<>(source, destination, d.getDependencyType().toLowerCase());
        })
      .collect(toList());

  return new DirectedGraph<>(
    JavaConversions.asScalaBuffer(edges).toList(), JavaConversions.asScalaSet(roots).toSet());
 }
}

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

private long flushMessages(List<Message> messages, long payloadSize) {
  if (messages.isEmpty()) {
    LOG.debug("No messages to flush, not trying to write an empty message set.");
    return -1L;
  }
  final ByteBufferMessageSet messageSet = new ByteBufferMessageSet(JavaConversions.asScalaBuffer(messages).toSeq());
  if (LOG.isDebugEnabled()) {
    LOG.debug("Trying to write ByteBufferMessageSet with size of {} bytes to journal", messageSet.sizeInBytes());
  }
  final LogAppendInfo appendInfo = kafkaLog.append(messageSet, true);
  long lastWriteOffset = appendInfo.lastOffset();
  if (LOG.isDebugEnabled()) {
    LOG.debug("Wrote {} messages to journal: {} bytes (payload {} bytes), log position {} to {}",
        messages.size(), messageSet.sizeInBytes(), payloadSize, appendInfo.firstOffset(), lastWriteOffset);
  }
  writtenMessages.mark(messages.size());
  return lastWriteOffset;
}

代码示例来源：origin: info.kwarc.sally4.mhw/mhw-mmt

public void getDependents(String MMTUri) {
  ToSubject dependsOn = new ToSubject(DependsOn$.MODULE$);
  ToSubject hasMeta = new ToSubject(HasMeta$.MODULE$);
  ToSubject includes = new ToSubject(Includes$.MODULE$);
  RelationExp reflexive = Reflexive$.MODULE$;
  List<RelationExp> rels  = Arrays.asList(new RelationExp[]{dependsOn, hasMeta, includes, reflexive});
  
  Transitive transitive = new Transitive(new Choice(JavaConversions.asScalaBuffer(rels)));
  Path startURI = Path.parse(MMTUri);
  for (Path p : JavaConversions.asJavaCollection(controller.depstore().queryList(startURI, transitive))) {
    System.out.println(p);
  }
  
}

代码示例来源：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: linkedin/cruise-control

private void ensureTopicCreated(ZkUtils zkUtils,
                Set<String> allTopics,
                String topic,
                long retentionMs,
                int replicationFactor,
                int partitionCount) {
 Properties props = new Properties();
 props.setProperty(LogConfig.RetentionMsProp(), Long.toString(retentionMs));
 props.setProperty(LogConfig.CleanupPolicyProp(), DEFAULT_CLEANUP_POLICY);
 if (!allTopics.contains(topic)) {
  AdminUtils.createTopic(zkUtils, topic, partitionCount, replicationFactor, props, RackAwareMode.Safe$.MODULE$);
 } else {
  try {
   AdminUtils.changeTopicConfig(zkUtils, topic, props);
   MetadataResponse.TopicMetadata topicMetadata = AdminUtils.fetchTopicMetadataFromZk(JavaConversions.asScalaSet(Collections.singleton(topic)),
                           zkUtils,
                           ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT)).head();
   maybeIncreaseTopicReplicationFactor(zkUtils, topicMetadata, replicationFactor, topic);
   maybeIncreaseTopicPartitionCount(zkUtils, topic, topicMetadata, partitionCount);
  }  catch (RuntimeException re) {
   LOG.error("Skip updating topic " +  topic + " configuration due to failure:" + re.getMessage() + ".");
  }
 }
}

代码示例来源：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: org.scalatra.scalate/scalate-core_2.11

static <A, B> scala.collection.mutable.Map<A, B> mapAsScalaMap(java.util.Map<A, B> map) {
  return JavaConversions.mapAsScalaMap(map);
 }
}

代码示例来源：origin: cloudera-labs/envelope

val = JavaConversions.mapAsScalaMap(convertedMap);
val = JavaConverters.asScalaBufferConverter(childValues).asScala().toSeq();

代码示例来源：origin: linkedin/kafka-monitor

/**
 * Read number of partitions for the given topic on the specified zookeeper
 * @param zkUrl zookeeper connection url
 * @param topic topic name
 *
 * @return the number of partitions of the given topic
 */
public static int getPartitionNumForTopic(String zkUrl, String topic) {
 ZkUtils zkUtils = ZkUtils.apply(zkUrl, ZK_SESSION_TIMEOUT_MS, ZK_CONNECTION_TIMEOUT_MS, JaasUtils.isZkSecurityEnabled());
 try {
  Seq<String> topics = scala.collection.JavaConversions.asScalaBuffer(Arrays.asList(topic));
  return zkUtils.getPartitionsForTopics(topics).apply(topic).size();
 } catch (NoSuchElementException e) {
  return 0;
 } finally {
  zkUtils.close();
 }
}

代码示例来源：origin: cdapio/cdap

return JavaConversions.asScalaBuffer(result).toSeq();
return JavaConversions.mapAsScalaMap(result);

代码示例来源：origin: dstl/baleen

private DirectedGraph<String> getDependencies(uk.gov.dstl.baleen.types.language.Sentence key) {

  List<WordToken> tokens = ImmutableList.copyOf(indexWords.get(key));
  Set<Object> roots = new HashSet<>();

  List<Edge<String>> edges =
    indexDependency
      .get(key)
      .stream()
      .peek(
        d -> {
         if (MaltParser.ROOT.equals(d.getDependencyType())) {
          roots.add(tokens.indexOf(d.getGovernor()));
         }
        })
      .map(
        d -> {
         int source = tokens.indexOf(d.getGovernor());
         int destination = tokens.indexOf(d.getDependent());
         return new Edge<>(source, destination, d.getDependencyType().toLowerCase());
        })
      .collect(toList());

  return new DirectedGraph<>(
    JavaConversions.asScalaBuffer(edges).toList(), JavaConversions.asScalaSet(roots).toSet());
 }
}

代码示例来源：origin: com.twitter/util-core_2.10

/**
 * Creates a new `Spool` of given `elems`.
 */
public static <T> Spool<T> newSpool(Collection<T> elems) {
 Seq<T> seq = JavaConversions.asScalaBuffer(new ArrayList<T>(elems)).toSeq();
 return new Spool.ToSpool<T>(seq).toSpool();
}

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

JavaConversions

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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