公开(公告)号：CN103970520B

公开(公告)日：2017-06-16

申请号：CN201310037826.0

申请日：2013-01-31

Applicant: 国际商业机器公司

Inventor： 史巨伟 ,  李立 ,  邹嘉 ,  于琦

IPC: G06F9/44 ,  G06F9/50

CPC classification number: G06F9/5066 ,  G06F9/5016 ,  G06F12/023 ,  G06F2209/5017 ,  G06F2212/1016 ,  G06F2212/154 ,  G06F2212/263

Abstract: 本发明实施例公开了一种用于MapReduce架构中的资源管理的方法、装置和MapReduce架构系统。该方法包括：确定Map任务的输入数据量和Map任务的输出数据量之比r以及Map输出结果中记录的平均大小R；确定一个Map资源槽对应的能够分配给Map任务的内存大小Memory_Size；根据所确定的r、R和Memory_Size，确定适合该Map任务的输入切片大小；以及将待处理的MapReduce作业中具有该输入切片大小的输入分片分配给占用该Map资源槽的Map任务。通过利用上述方法，可以尽量避免磁盘溢出，从而提高处理效率，避免资源浪费。

公开(公告)号：CN104252493A

公开(公告)日：2014-12-31

申请号：CN201310269339.7

申请日：2013-06-28

Applicant: 国际商业机器公司

Inventor： 郭崎 ,  陈飞 ,  戈弋 ,  于琦 ,  章宇

IPC: G06F17/30

CPC classification number: G06F17/3089 ,  G06F17/30867 ,  G06F17/30914

Abstract: 公开一种基于事件的内容匹配系统，包含软件子系统和硬件子系统，所述硬件子系统包含至少一个基于FPGA的匹配引擎，用于将事件内容与预定的谓词匹配，生成供软件子系统使用的匹配结果，所述匹配引擎包含：事件存储装置，被设置得用于存储一个事件序列；至少一个谓词表，用于存储要被查询的谓词；至少一个映射表，与所述至少一个谓词表一一对应，每个映射表用于将事件队列中的事件映射到该映射表对应的谓词表中的至少一个对应谓词；至少一个比较器，与所述至少一个谓词表的所有表列一一对应，每个比较器用于将事件序列中的一个事件与该比较器对应的表列中的对应谓词进行匹配，生成匹配结果；匹配结果存储器，被配置得用于存储所述至少一个比较器的每个生成的匹配结果。

公开(公告)号：CN103970520A

公开(公告)日：2014-08-06

申请号：CN201310037826.0

申请日：2013-01-31

Applicant: 国际商业机器公司

Inventor： 史巨伟 ,  李立 ,  邹嘉 ,  于琦

IPC: G06F9/44 ,  G06F9/50

CPC classification number: G06F9/5066 ,  G06F9/5016 ,  G06F12/023 ,  G06F2209/5017 ,  G06F2212/1016 ,  G06F2212/154 ,  G06F2212/263

Abstract: 本发明实施例公开了一种用于MapReduce架构中的资源管理的方法、装置和MapReduce架构系统。该方法包括：确定Map任务的输入数据量和Map任务的输出数据量之比r以及Map输出结果中记录的平均大小R；确定一个Map资源槽对应的能够分配给Map任务的内存大小Memory_Size；根据所确定的r、R和Memory_Size，确定适合该Map任务的输入切片大小；以及将待处理的MapReduce作业中具有该输入切片大小的输入分片分配给占用该Map资源槽的Map任务。通过利用上述方法，可以尽量避免磁盘溢出，从而提高处理效率，避免资源浪费。

公开(公告)号：CN103379114A

公开(公告)日：2013-10-30

申请号：CN201210133550.1

申请日：2012-04-28

Applicant: 国际商业机器公司

Inventor： 史巨伟 ,  李立 ,  于琦 ,  刘驰 ,  王文杰

IPC: H04L29/06 ,  H04L29/08

CPC classification number: G06F21/60 ,  G06F21/6245

Abstract: 本发明涉及MapReduce系统中的数据处理，具体地，公开一种用于在MapReduce系统中保护隐私数据的方法和装置。其中，所述MapReduce系统包含公有子系统和私有子系统，该方法包含：接收要在MapReduce系统中执行的MapReduce程序，其中，所述MapReduce程序中包含指定Map函数的输入、输出数据和Reduce函数的输出数据的隐私属性的指令；在执行MapReduce程序之前，检测Map函数的输入、输出数据和Reduce函数的输出数据的隐私属性；根据所检测的隐私属性，分配用于被私有子系统和共有子系统处理的数据，其中，将隐私属性为私有的数据分配到私有子系统。

公开(公告)号：CN102170618A

公开(公告)日：2011-08-31

申请号：CN201010127149.8

申请日：2010-02-26

Applicant: 国际商业机器公司

Inventor： 史巨伟 ,  杨博 ,  于琦 ,  温嘉佳

IPC: H04W4/14 ,  H04W88/18

CPC classification number: H04W4/14 ,  H04L51/38 ,  H04L67/14 ,  H04L67/142 ,  H04L67/146

Abstract: 本发明公开了一种在短消息交互通信中通过向每个业务实例分配标识码并以嵌有该标识码的号码与用户进行短信交互的短消息处理方法和设备。在本发明的短消息处理方法和设备中，响应于接收到来自通信终端的短消息，根据该短消息所包含的服务器方通信号码确定该短消息所针对的业务实例，然后以嵌有与所确定的业务实例相对应的业务实例标识码的服务器方通信号码向通信终端发送应答短消息。本发明能够准确、便捷地将多条短消息关联到相应的业务实例，增强了用户在交互过程中的体验。