jjzjj

collectors

全部标签

go - Prometheus type Collector - 如何用我自己的数据提供 map

免责声明:我是Golang的新手,之前没有用任何其他语言做过太多编程。不过,我仍然希望有人能为我指明正确的方向。目标是:根据PrometheusGolang模块(https://godoc.org/github.com/prometheus/client_golang/prometheus#Collector)下的“示例”部分以及提到“//仅示例假数据”的部分。当然是使用我自己的真实数据。我的数据以JSON格式来自RabbitMQ端点。我解析JSON,并且可以使用正确的键创建自己的映射:我需要的值作为funcmain()范围内的goroutine的一部分。假设我的map如下所示:[“设

go - 无法使用带有 BurntSushi 库的 Go 读取 TOML 文件

我正在使用BurntSushi库在我的GO应用程序中加载TOML配置文件。我已按照库中的说明编写结构和配置toml文件本身。我遇到了一些麻烦,而且我似乎找不到问题的根源。详情如下:结构:packagemain//ConfigurationParametersprovidesthestructtoholdconfigurationparametersfromconfigfiletypeConfigurationParametersstruct{Titlestring//serviceDiscoverycapturesconfigurationparametersneededforserv

python - 如何在不卸载 PythonWin 的情况下禁用 PythonWin 的 “Redirecting output to win32trace remote collector” 功能?

当我运行wxPython应用程序时,它会打印字符串“Redirectingoutputtowin32traceremotecollector”,我必须打开PythonWin的跟踪收集器工具才能查看该跟踪输出。由于我对收集此输出不感兴趣,我应该如何禁用此功能? 最佳答案 您甚至可以在实例化您的wx.App()时传递它:if__name__=="__main__":app=wx.App(redirect=False)#or0app.MainLoop()wxPythonwx.Appdocs 关

java - 合并 Java 流

我有很大的版本化文档流,按文档ID和版本排序。例如Av1,Av2,Bv1,Cv1,Cv2我必须将其转换为另一个Stream,其记录按文档ID聚合。A[v1,v2],B[v1],C[v1,V2]这可以不使用Collectors.groupBy()来完成吗?我不想使用groupBy()因为它会在对它们进行分组之前将流中的所有项目加载到内存中。理论上,不需要将整个流加载到内存中,因为它是有序的。 最佳答案 这是我想出的解决方案:Streamstream=Stream.of(newDocument("A","v1"),newDocument

java - 使用 Java 8 的复杂自定义收集器

我有一个对象流,我想通过以下方式收集这些对象。假设我们正在处理论坛帖子:classPost{privateDatetime;privateDatadata}我想创建一个按句点对帖子进行分组的列表。如果没有关于X的帖子分钟,创建一个新组。classPostsGroup{Listposts=newArrayList();}我想要一个List包含按时间间隔分组的帖子。示例:10的区间分钟。帖子:[{time:x,data:{}},{time:x+3,data:{}},{time:x+12,data:{},{time:x+45,data:{}}}]我想获取帖子组的列表:[{posts:[{ti

java - 仅当存在多个项目时才向 Collectors.joining() 添加前缀和后缀

我有一个字符串流:Streamstream=...;我想构造一个字符串,将这些项与,连接起来作为分隔符。我这样做如下:stream.collect(Collectors.joining(","));现在我想添加一个前缀[和后缀]仅当有多个项目时才输出此输出。例如:a[a,b][a,b,c]这可以在不首先实现Stream的情况下完成吗?到List然后查看List.size()==1?在代码中:publicStringformat(Streamstream){Listlist=stream.collect(Collectors.toList());if(list.size()==1){re

java - 如何使用特定的键和值将流分组到 map ?

我有一个Stream>myStream;我想把它聚合成一个Map>result;我设法做到了以下几点:Map>>result=myStream.collect(Collectors.groupingBy(Pair::getKey,Collectors.toSet()));失败并显示“无法从静态上下文引用非静态方法”:Map>result=myStream.collect(Collectors.groupingBy(Pair::getKey,Pair::getValue,Collectors.toSet()));我做错了什么? 最佳答案

Java 8 流 : build multilevel/composite objects

我开始使用Java8流API。我想将“sql结果集”列表转换为域对象,即复合结构。领域对象:一个用户有一个权限的集合,每个权限都有一个申请年份的集合。例如,John有2个权限(MODERATOR和DEV)。版主权限仅适用于2014年和2015年其开发许可仅适用于2014年。classUser{//someprimitivesattributesListpermission;}classPermission{//someprimitivesattributesListyears;}现在我进行查询并得到一个简单的结果列表,类似于:[1,"moderator",2014][1,"modera

Java流-收集组合器

为什么会出现下面的代码:StringBuildersb22=IntStream.range(1,101).filter(x->x>50).boxed().parallel().collect(//objectthatisusedinaccumulatortodoaccumulatingonStringBuilder::new,//useobjectfromaboveandcallappendonitwitheachstreamelementasargument(sb,a)->sb.append(":"+a),//(executesonlywhenusingparallel!)(sb1,

java - flatMap Set of Sets inside groupingBy 的优雅方式

所以我有一段代码,我在其中迭代数据列表。每一个都是一个ReportData包含带有LongcaseId的案例和一个Ruling.每个Ruling有一个或多个Payment.我想要一个Map与caseId作为键和支付集作为值(即Map>)。个案在行中不是唯一的,但个案是。换句话说,我可以有几行相同的案例,但它们会有独特的裁定。下面的代码给我一个Map>>这几乎是我想要的,但我一直在努力寻找在给定上下文中对最终集合进行flatMap的正确方法。我一直在做变通办法,使逻辑按原样使用此map正确工作,但我非常想修复算法以将付款集正确组合成一个集,而不是创建一组集。我四处搜索并没有找到相同类型迭