CN111831383B 窗口拼接方法、装置、设备以及存储介质 （北京百度网讯科技有限公司）

2将多条流在同一窗口内的数据按照主键进行存储，包括，将主流与至少一在至少一个流的水位超出窗口的时长达到设定时长的情况下，扫描存在至少一个流的水位超出窗口的时长达到第一时长的情况下在至少一个流的水位超出窗口的时长达到第二时长的情况下第二版本的拼接数据包括时间戳处于所述窗口内且数据更新时间处于第二时间范围内的扫描模块，用于在至少一个流的水位超出窗口的第一版本扫描子模块，用于在至少一个流的水位超出窗口本的拼接数据包括时间戳处于所述窗口内且数据更新时间处于第一时间范围内的拼接数第二版本扫描子模块，用于在至少一个流的水位超出窗口所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被6.一种存储有计算机指令的非瞬时计算机可读存储介7.一种计算机程序产品，包括计算机程序，34[0020]应当理解，本部分所描述的内容并非旨在标识本申请的实施例的关键或重要特5[0037]流式计算(streamcomputing，或者称为流计算)即是对数据流(简称流)进行计6水位超出窗口。水位超出窗口的时长可以为收到当前数据的时间与窗口的结束时间的差可以为扫描存储的数据中处于该窗口内的数据，扫描得到的数据可以为该窗口的拼接数[0042]图2是根据本申请另一实施例的窗口拼接方法的流程图。该实施例的窗口拼接方从流中在同一窗口内具有相同主键的数据存储在一起，具体可以在外存中存储这些数据。7[0052]图3是根据本申请另一实施例的窗口拼接方法的流程图。该实施例的窗口拼接方储器(backstore)的行键(rowkey)可以包括数据的时间时间戳(unify_time)和连接键8以将主流、从流当前的水位发给触发器，用于触发器(trigger)的触发以及延时数据的判发器在水位超出窗口结束时间10分钟触发扫描，大版本触发器在超出窗口结束时间1小时[0070](1)数据的存储以时间戳(unify_time)和连接键(join_key)为行键。当某行数据[0071](2)当某个窗口的小版本触发器触发计算时，扫描完成时间(scan_done_ts)的初行拼接计算，并且更新这个窗口的扫描完成时间(scan_done_ts)为写入完成时间(write_[0073]如图6所示的进度格式中的行键为窗口起始时间(windows_start)和窗口结束时描完成时间(scan_done_ts)内的数据为小版本的拼接数据，在[scan_done_ts,write_9[0078]扫描模块42，用于在至少一个流的水位超出窗口的时长[0084]第一版本扫描子模块421，用于在至少一个流的水位超出窗口的时长达到第一时[0087]第二版本扫描子模块422，用于在至少一个流的水位超出窗口的时长达到第二时时间范围内的拼接数据，该第二时间范围的起始时间等于或晚于第一时间范围的结束时设备提供部分必要的操作(例如，作为服务器阵列、一组刀片式服务器、或者多处理器系瞬时计算机可执行程序以及模块，如本申请实施例中的窗口拼接方法对应的程序指令/模[0095]存储器902可以包括存储程序区和存储数据区，其中，存储程序区可存储操作系[0097]输入装置903可接收输入的数字或字符信息，以及产生与窗口拼接方法的电子设[0098]此处描述的系统和技术的各种实施方式可以在数字电子电路系统、集成电路系包括至少一个可编程处理器的可编程系统上执行和/或解释，该可编程处理器可以是专用[0101]可以将此处描述的系统和技术实施在包括后台部件的计算系统(例如，作为数据面或者该网络浏览器来与此处描述的系统和技术的实施方式交互)、或者包括这种后台部字数据通信(例如，通信网络)来将系统的部件相互连接。通信网络的示例包括：局域网过通信网络进行交互。通过在相应的计算机上运行并且彼此具有客户端-服务器关系的计如，本发申请中记载的各步骤可以并行地执行也可以顺序地执行也可