scala.collection.Iterator.toSeq()方法的使用及代码示例

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

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

Iterator.toSeq介绍

暂无

代码示例

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

  1. JavaConverters.asScalaIteratorConverter(newAssignedReplica.iterator()).asScala().toSeq());

代码示例来源:origin: apache/phoenix

  1. /**
  2. * Sets the schema using all the table columns before any column pruning has been done
  3. */
  4. private void setSchema() {
  5. try (Connection conn = DriverManager.getConnection("jdbc:phoenix:" + zkUrl)) {
  6. List<ColumnInfo> columnInfos = PhoenixRuntime.generateColumnInfo(conn, tableName, null);
  7. Seq<ColumnInfo> columnInfoSeq = JavaConverters.asScalaIteratorConverter(columnInfos.iterator()).asScala().toSeq();
  8. schema = SparkSchemaUtil.phoenixSchemaToCatalystSchema(columnInfoSeq, dateAsTimestamp);
  9. }
  10. catch (SQLException e) {
  11. throw new RuntimeException(e);
  12. }
  13. }

代码示例来源:origin: gnuhpc/Kafka-zk-restapi

  1. private List<TopicAndPartition> getTopicPartitions(String t) {
  2. List<TopicAndPartition> tpList = new ArrayList<>();
  3. List<String> l = Arrays.asList(t);
  4. java.util.Map<String, Seq<Object>> tpMap =
  5. JavaConverters.mapAsJavaMapConverter(
  6. zkUtils.getPartitionsForTopics(
  7. JavaConverters.asScalaIteratorConverter(l.iterator()).asScala().toSeq()))
  8. .asJava();
  9. if (tpMap != null) {
  10. ArrayList<Object> partitionLists =
  11. new ArrayList<>(JavaConverters.seqAsJavaListConverter(tpMap.get(t)).asJava());
  12. tpList =
  13. partitionLists.stream().map(p -> new TopicAndPartition(t, (Integer) p)).collect(toList());
  14. }
  15. return tpList;
  16. }

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

  1. @Override public void incrementMessagesDropped(Throwable cause) {
  2. if (cause instanceof FinagleSender.WrappedException) cause = cause.getCause();
  3. Seq<Traversable<String>> paths = Throwables.mkString(cause).inits().toSeq();
  4. for (Iterator<Traversable<String>> i = paths.iterator(); i.hasNext();) {
  5. messagesDropped.counter(i.next().toSeq()).incr();
  6. }
  7. }

代码示例来源:origin: io.zipkin.finagle2/zipkin-finagle

  1. @Override public void incrementMessagesDropped(Throwable cause) {
  2. if (cause instanceof FinagleSender.WrappedException) cause = cause.getCause();
  3. Seq<Traversable<String>> paths = Throwables.mkString(cause).inits().toSeq();
  4. for (Iterator<Traversable<String>> i = paths.iterator(); i.hasNext();) {
  5. messagesDropped.counter(i.next().toSeq()).incr();
  6. }
  7. }

代码示例来源:origin: io.zipkin.finagle/zipkin-finagle

  1. @Override public void incrementMessagesDropped(Throwable cause) {
  2. Seq<Traversable<String>> paths = Throwables.mkString(cause).inits().toSeq();
  3. for (Iterator<Traversable<String>> i = paths.iterator(); i.hasNext();) {
  4. messagesDropped.counter(i.next().toSeq()).incr();
  5. }
  6. }

相关文章