公开(公告)号：US09680919B2

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

申请号：US14458773

申请日：2014-08-13

申请人： Software AG USA Inc.

发明人： Eddie McDaid ,  Desmond Chan ,  Manish Devgan

IPC分类号： G06F15/16 ,  H04L29/08 ,  H04L12/725 ,  H04L12/58 ,  H04L12/701 ,  H04W40/00 ,  G06F11/30 ,  H04L12/54 ,  G06F9/54 ,  H04W40/02 ,  H04W72/12 ,  H04L12/64

CPC分类号： H04L67/10 ,  G06F9/542 ,  G06F11/3006 ,  H04L45/00 ,  H04L45/302 ,  H04L51/26 ,  H04L67/322 ,  H04L2012/6443 ,  H04W40/00 ,  H04W40/02 ,  H04W72/1242

摘要： Certain example embodiments relate to an intelligent messaging grid for Big Data ingestion and/or associated methods. Each node in a network of nodes is dynamically configurable to send and/or receive messages using one of brokered and brokerless communication models. At least some of the nodes have a complex event processing (CEP) engine deployed thereto, the CEP engines being configured to operate on messages received by the respective nodes and being classified as one of at least two different types of CEP engines. For each message received by a given node that is to be forwarded to a further node along one of multiple possible paths, the given node is configured to route the message to be forwarded to an intermediate node in one of the possible paths. The intermediate node is selected by the CEP engine of the given node based on metadata associated with the message to be forwarded.

公开(公告)号：US09465752B2

公开(公告)日：2016-10-11

申请号：US14569026

申请日：2014-12-12

申请人： Software AG USA, Inc.

发明人： Manish Devgan

IPC分类号： G06F12/00 ,  G06F13/00 ,  G06F13/28 ,  G06F12/14 ,  G06F12/08

CPC分类号： G06F12/1483 ,  G06F12/0811 ,  G06F12/0813 ,  G06F12/0815 ,  G06F12/0866 ,  G06F12/0868 ,  G06F12/0897 ,  G06F12/1458 ,  G06F2212/1052 ,  G06F2212/60

摘要： Certain example embodiments provide efficient policy-based access to data stored in memory tiers, including volatile local in-process (L1) cache memory of an application and at least one managed (e.g., non-volatile) in-memory (L2) cache. Operations include receiving an access request for access to a data element in L2; detecting whether a copy of the data element is in L1; if so, copying the data element and the access policy from L2 to L1 and providing the user with access to the copy of data element from L1 if the access policy allows access to the user; and if not, determining, by referring to a copy of the access policy stored in L1, whether the user is allowed to access the data element, and, if the user is allowed to access the data element, providing the user with access to the copy of the data element from the L1 cache memory.

摘要翻译： 某些示例性实施例提供对存储在存储器层中的数据的有效的基于策略的访问，包括应用的易失性本地进程（L1）高速缓存存储器和至少一个被管理（例如，非易失性）存储器（L2）高速缓存。 操作包括在L2中接收访问数据元素的访问请求; 检测数据元素的副本是否在L1中; 如果是，则将数据元素和访问策略从L2复制到L1，并且如果访问策略允许访问用户，则向用户提供对来自L1的数据元素的副本的访问; 如果不是，则通过参考存储在L1中的访问策略的副本来确定是否允许用户访问数据元素，并且如果允许用户访问数据元素，则向用户提供对 数据元素从L1高速缓存存储器复制。

公开(公告)号：US10990288B2

公开(公告)日：2021-04-27

申请号：US14449517

申请日：2014-08-01

申请人： Software AG USA, Inc.

发明人： Gagan Mehra ,  Manish Devgan

IPC分类号： G06F3/06

摘要： Certain example embodiments relate to a computer system for performing a map reduce sequence. Nodes therein include at least one processor and memory and are divided into at least mapper and reducer nodes. Each mapper node executes a map function on input to generate intermediate output elements. Each said intermediate output element includes a first key-value pair. Each element key includes associated map and reduce task identifiers. Each element value includes substantive data, organized as another key-value pair. The intermediate output elements are stored to memory. Each reducer node: retrieves at least intermediate output element values from the memory of a given mapper node, using specified map and reduce task identifiers; stores the retrieved element values to its memory; executes a reduce function on the retrieved element values, in order; and outputs a result from the reduce function for the map reduce sequence. Disk operations advantageously are reduced or eliminated.