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

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

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

JavaConversions.asJavaList介绍

暂无

代码示例

代码示例来源:origin: shunfei/DCMonitor

public List<String> getTopics() {
 try {
  return JavaConversions.asJavaList(ZkUtils.getAllTopics(zkClient));
 } catch (Exception e) {
  log.error(e, "could not get topics");
  return Collections.emptyList();
 }
}

代码示例来源:origin: shunfei/DCMonitor

public List<BrokerInfo> getCluster() {
 return Lists.transform(
  JavaConversions.asJavaList(ZkUtils.getAllBrokersInCluster(zkClient)), new Function<Broker, BrokerInfo>() {
   @Override
   public BrokerInfo apply(Broker input) {
    BrokerInfo info = new BrokerInfo();
    info.host = input.host();
    info.port = input.port();
    info.id = input.id();
    return info;
   }
  }
 );
}

代码示例来源:origin: com.twitter/summingbird-core-java

/**
 * @param tail
 * @return the planed producer
 */
public <T> List<T> plan(JTailProducer<Memory, T> tail) {
 return JavaConversions.asJavaList(platform.plan(tail.unwrap()));
}

代码示例来源:origin: shunfei/DCMonitor

public List<PartitionInfo> getPartitionInfos(String group, String topic) {
 Seq<String> singleTopic = JavaConversions.asScalaBuffer(Collections.singletonList(topic)).toSeq();
 scala.collection.Map<String, Seq<Object>> pidMap = ZkUtils.getPartitionsForTopics(zkClient, singleTopic);
 Option<Seq<Object>> partitions = pidMap.get(topic);
 if (partitions.get() == null) {
  return Collections.emptyList();
 }
 List<PartitionInfo> infos = Lists.newArrayList();
 for (Object o : JavaConversions.asJavaList(partitions.get())) {
  PartitionInfo info = getPartitionInfo(group, topic, Int.unbox(o));
  if (info != null) {
   infos.add(info);
  }
 }
 return infos;
}

代码示例来源:origin: shunfei/DCMonitor

consumers = JavaConversions.asJavaList(ZkUtils.getChildren(zkClient, ZkUtils.ConsumersPath()));
} catch (Exception e) {
 log.error(e, "could not get all consumer list");

代码示例来源:origin: com.outbrain.swinfra/ob1k-db

@Override
  public List<T> handle(final QueryResult res) {
    final Option<ResultSet> rowsOption = res.rows();
    final List<T> response = new ArrayList<>();
    if (rowsOption.isDefined()) {
      final ResultSet resultSet = rowsOption.get();
      final List<String> columnNames = JavaConversions.asJavaList(resultSet.columnNames());
      final Iterator<RowData> rows = resultSet.iterator();
      while (rows.hasNext()) {
        final RowData row = rows.next();
        final T obj = mapper.map(new TypedRowData(row), columnNames);
        response.add(obj);
      }
    }
    return response;
  }
});

代码示例来源:origin: eirslett/thrift-zookeeper

public static List<SocketAddress> getOnlineServers(String clusterName) {
  try {
    ZookeeperServerSetCluster cluster = getForService(clusterName);
    // Run the monitor() method, which will block the thread until the initial list of servers arrives.
    new ServerSetImpl(zooKeeperClient, getPath(clusterName)).monitor(new DynamicHostSet.HostChangeMonitor<ServiceInstance>(){
      public void onChange(ImmutableSet<ServiceInstance> serviceInstances) {
        // do nothing
      }
    });
    return JavaConversions.asJavaList(cluster.snap()._1());
  } catch (DynamicHostSet.MonitorException e) {
    throw new RuntimeException("Couldn't get list of online servers", e);
  }
}

代码示例来源:origin: com.outbrain.swinfra/ob1k-db

@Override
  public T handle(final QueryResult res) {
    final Option<ResultSet> rowsOption = res.rows();
    if (rowsOption.isDefined()) {
      final ResultSet resultSet = rowsOption.get();
      final List<String> columnNames = JavaConversions.asJavaList(resultSet.columnNames());
      final Iterator<RowData> rows = resultSet.iterator();
      if (rows.hasNext()) {
        final RowData row = rows.next();
        return mapper.map(new TypedRowData(row), columnNames);
      }
    }
    return null;
  }
});

相关文章