本文整理了Java中scala.collection.JavaConversions.asJavaList()
方法的一些代码示例,展示了JavaConversions.asJavaList()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JavaConversions.asJavaList()
方法的具体详情如下:
包路径:scala.collection.JavaConversions
类名称: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;
}
});
内容来源于网络,如有侵权,请联系作者删除!