公开(公告)号：CN110795458A

公开(公告)日：2020-02-14

申请号：CN201910950353.0

申请日：2019-10-08

Applicant: 北京百分点信息科技有限公司

Inventor： 黄伟 ,  刘译璟 ,  廖锐 ,  于帮付 ,  赵群 ,  郭志金 ,  代其锋

IPC: G06F16/2455 ,  G06F16/248 ,  G06F9/451

Abstract: 本申请公开了一种交互式数据分析方法、装置、电子设备和计算机可读存储介质。其中，本申请基于用户在前端显示的可视化图表上执行的数据分析选择操作，确定用于数据检索的索引字段以及数据聚合类型；从预设的数据库中检索出与索引字段对应的待分析数据；根据数据聚合类型对该待分析数据进行数据聚合分析；将聚合分析结果展示在所述前端，从而实现基于可视化图表的交互式数据分析，提高数据分析效率。

公开(公告)号：CN110795476A

公开(公告)日：2020-02-14

申请号：CN201910985063.X

申请日：2019-10-16

Applicant: 北京百分点信息科技有限公司

Inventor： 黄伟 ,  刘译璟 ,  廖锐 ,  于帮付 ,  苏萌 ,  刘钰 ,  龚鑫

IPC: G06F16/248 ,  G06F16/27 ,  G06F16/28

Abstract: 本申请公开了一种本体库的数据写入方法及装置，其中，该方法包括：基于本体配置信息，将至少一个外部数据源中的本体相关数据导入到列式存储的分布式数据库中，得到一个或多个本体实例的本体数据；其中，在分布式数据库中，来自不同外部数据源的相同本体实例的本体数据基于本体实例标识关联；基于本体实例标识将分布式数据库中存储的同一本体实例的本体数据进行聚合，并写入到本体库中。

公开(公告)号：CN110647547A

公开(公告)日：2020-01-03

申请号：CN201910895091.2

申请日：2019-09-20

Applicant: 北京百分点信息科技有限公司

Inventor： 黄伟 ,  廖锐 ,  刘译璟 ,  于帮付 ,  马志峰 ,  杜晓梦 ,  苏海波 ,  苏萌 ,  左云鹏 ,  陆攀

IPC: G06F16/2455 ,  G06F16/2458

Abstract: 本说明书实施例公开了一种消费延迟监控方法、装置、电子设备及计算机可读存储介质。其中，该方法应用于基于Spark Streaming框架的流处理系统，包括：按照预设时间间隔从Kafka系统中读取流数据，所述流数据中包括多条携带有生产时间戳的业务数据；基于所述流数据中的目标业务数据的生产时间戳确定所述Kafka系统的消费延迟时间，其中，所述目标业务数据为所述流数据中生产时间戳最晚的业务数据；基于所述消费延迟时间，对所述Kafka系统进行消费延迟监控。本申请能够实现对Kafka系统中的消费延迟信息的有效监控。