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

JavaConverters.asScalaBuffer介绍

暂无

代码示例

代码示例来源：origin: pinterest/doctorkafka

private scala.collection.Map<Object, Seq<Object>> getReplicaAssignmentForTopic(
  ZkUtils zkUtils, String topic) {
 if (topicPartitionAssignments.containsKey(topic)) {
  return topicPartitionAssignments.get(topic);
 }
 List<String> topics = new ArrayList<>();
 topics.add(topic);
 Seq<String> topicsSeq = scala.collection.JavaConverters.asScalaBuffer(topics).toSeq();
 scala.collection.mutable.Map<String, scala.collection.Map<Object, Seq<Object>>> assignments;
 assignments = zkUtils.getPartitionAssignmentForTopics(topicsSeq);
 scala.collection.Map<Object, Seq<Object>> partitionAssignment = assignments.get(topic).get();
 topicPartitionAssignments.put(topic, partitionAssignment);
 return partitionAssignment;
}

代码示例来源：origin: openzipkin/zipkin-finagle

public static Seq<String> seq(String... entries) {
 return JavaConverters.asScalaBuffer(asList(entries));
}

代码示例来源：origin: org.eclipse.ditto/ditto-services-connectivity-messaging

private static Seq<Pair<String, MqttQoS>> getSubscriptions(final MqttSource mqttSource) {
    final int qos = mqttSource.getQos();
    final MqttQoS mqttQos = MqttValidator.getQoS(qos);
    final List<Pair<String, MqttQoS>> subscriptions =
        mqttSource.getAddresses()
            .stream()
            .map(sourceAddress -> Pair.create(sourceAddress, mqttQos))
            .collect(Collectors.toList());
    return JavaConverters.asScalaBuffer(subscriptions);
  }
}

代码示例来源：origin: eclipse/ditto

private static Seq<Pair<String, MqttQoS>> getSubscriptions(final MqttSource mqttSource) {
    final int qos = mqttSource.getQos();
    final MqttQoS mqttQos = MqttValidator.getQoS(qos);
    final List<Pair<String, MqttQoS>> subscriptions =
        mqttSource.getAddresses()
            .stream()
            .map(sourceAddress -> Pair.create(sourceAddress, mqttQos))
            .collect(Collectors.toList());
    return JavaConverters.asScalaBuffer(subscriptions);
  }
}

代码示例来源：origin: open-korean-text/elasticsearch-analysis-openkoreantext

@Override
  protected Seq<KoreanToken> perform(Seq<KoreanToken> tokens) {
    List<KoreanToken> performed = new ArrayList<>();
    for(KoreanToken token : JavaConverters.seqAsJavaList(tokens)) {
      if(redundantTypes.contains(token.pos().toString())){
        continue;
      }
      if(redundantTerms.contains(token.text())){
        continue;
      }
      performed.add(token);
    }

    return JavaConverters.asScalaBuffer(performed).toSeq();
  }
}

代码示例来源：origin: open-korean-text/elasticsearch-analysis-openkoreantext

public static void addUserDictionary(List<String> words) {
  OpenKoreanTextProcessor.addNounsToDictionary(JavaConverters.asScalaBuffer(words).toSeq());
}

代码示例来源：origin: pinterest/doctorkafka

private scala.collection.Map<TopicAndPartition, Seq<Object>> getAssignmentPlan(
  Map<TopicPartition, Integer[]> replicasMap) {
 scala.collection.mutable.HashMap<TopicAndPartition, Seq<Object>> result =
   new scala.collection.mutable.HashMap<>();
 for (Map.Entry<TopicPartition, Integer[]> entry : replicasMap.entrySet()) {
  TopicPartition tp = entry.getKey();
  TopicAndPartition tap = new TopicAndPartition(tp.topic(), tp.partition());
  List<Object> objs = Arrays.asList(entry.getValue()).stream()
    .map(val -> (Object) val).collect(Collectors.toList());
  Seq<Object> replicas = JavaConverters.asScalaBuffer(objs).seq();
  result.put(tap, replicas);
 }
 assert replicasMap.size() == result.size();
 LOG.debug("replicaMap.size = {}, result.size = {}", replicasMap.size(), result.size());
 return result;
}

代码示例来源：origin: eclipse/ditto

/**
 * Load the configured protocol adapter provider by reflection.
 * Call the 1-argument constructor every subclass of {@link ProtocolAdapterProvider} should implement.
 *
 * @param actorSystem Akka actor system to perform reflection with.
 * @return the loaded protocol adapter provider.
 */
public ProtocolAdapterProvider loadProtocolAdapterProvider(final ActorSystem actorSystem) {
  final String className = provider();
  final ClassTag<ProtocolAdapterProvider> tag = ClassTag$.MODULE$.apply(ProtocolAdapterProvider.class);
  final List<Tuple2<Class<?>, Object>> constructorArgs =
      Collections.singletonList(new Tuple2<>(getClass(), this));
  final DynamicAccess dynamicAccess = ((ExtendedActorSystem) actorSystem).dynamicAccess();
  final Try<ProtocolAdapterProvider> providerBox = dynamicAccess.createInstanceFor(className,
      JavaConverters.asScalaBuffer(constructorArgs).toList(), tag);
  return providerBox.get();
}

代码示例来源：origin: open-korean-text/elasticsearch-analysis-openkoreantext

@Override
protected Seq<KoreanToken> perform(Seq<KoreanToken> tokens) {
  KoreanToken[] performed = new KoreanToken[tokens.length()];
  int i = 0;
  Iterator<KoreanToken> tokenIterator =  tokens.iterator();
  while (tokenIterator.hasNext()) {
    KoreanToken token = tokenIterator.next();
    performed[i++] = token.stem().nonEmpty() ? stem(token) : token;
  }
  return JavaConverters.asScalaBuffer(Arrays.asList(performed)).toSeq();
}

代码示例来源：origin: open-korean-text/elasticsearch-analysis-openkoreantext

private Seq<KoreanToken> convertPhrasesToTokens(Seq<KoreanPhrase> phrases) {
    KoreanToken[] tokens = new KoreanToken[phrases.length()];

    Iterator<KoreanPhrase> iterator = phrases.iterator();
    int i = 0;
    while (iterator.hasNext()) {
      KoreanPhrase phrase = iterator.next();
      tokens[i++] = new KoreanToken(phrase.text(), phrase.pos(), phrase.offset(), phrase.length(), scala.Option.apply(null), false);
    }

    Arrays.sort(tokens, (o1, o2) -> {
      if(o1.offset()== o2.offset())
        return 0;
      return o1.offset()< o2.offset()? -1 : 1;
    });

    return JavaConverters.asScalaBuffer(Arrays.asList(tokens)).toSeq();
  }
}