公开(公告)号：US08527458B2

公开(公告)日：2013-09-03

申请号：US12534384

申请日：2009-08-03

申请人： Hoyong Park ,  Parul Jain ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Parul Jain ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F7/00 ,  G06F17/00 ,  G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30306

摘要： Techniques for logging data pertaining to the operation of a data stream processing server. In one set of embodiments, logging configuration information can be received specifying a functional area of a data stream processing server to be logged. Based on the logging configuration information, logging can be dynamically enabled for objects associated with the functional area that are instantiated by the data stream processing server, and logging can be dynamically disabled for objects associated with the functional area that are discarded (or no longer used) by the data stream processing server. In another set of embodiments, a tool can be provided for visualizing the data logged by the data stream processing server.

摘要翻译： 用于记录与数据流处理服务器的操作有关的数据的技术。 在一组实施例中，可以接收指定要记录的数据流处理服务器的功能区域的记录配置信息。 基于记录配置信息，可以对与数据流处理服务器实例化的功能区域相关联的对象动态启用日志记录，并且可以对与丢弃（或不再使用的功能区域）相关联的对象动态禁用日志记录 ）由数据流处理服务器。 在另一组实施例中，可以提供用于可视化由数据流处理服务器记录的数据的工具。

公开(公告)号：US20100223437A1

公开(公告)日：2010-09-02

申请号：US12396008

申请日：2009-03-02

申请人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F12/02

CPC分类号： G06F12/12

摘要： Techniques for managing memory usage of a processing system by spilling data from a memory to a persistent store based upon an evict policy are provided. A triggering event is detected. In response to the triggering event and based on the evict policy, it is determined whether data from the memory of the processing system is to be spilled to the persistent storage. The determination is made by comparing a level of free memory of the processing system with a threshold specified by the evict policy. The data is evicted from the memory.

摘要翻译： 提供了用于通过基于逐出策略从存储器将数据溢出到持久存储器来管理处理系统的存储器使用的技术。 检测到触发事件。 响应于触发事件并且基于逐出策略，确定来自处理系统的存储器的数据是否将被溢出到持久存储器。 通过将处理系统的空闲内存的级别与逐出策略规定的阈值进行比较来确定。 数据从内存中逐出。

公开(公告)号：US20080275891A1

公开(公告)日：2008-11-06

申请号：US11867471

申请日：2007-10-04

申请人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F17/30533

摘要： A method to create a partition by time/tuple based window in an event processing service is provided. When continuous data streams are received, tuples are stored in a data structure with partitions based upon partition keys. Only a specified amount of tuples may be stored in each partition. When a partition exceeds the specified number of tuples, the oldest tuples are removed from the data structure. Tuples stored beyond a specified time period are also removed from the data structure. Two data structures may also be used to implement a time/tuple based window. Tuples are stored in both a data structure with a partition by window and a data structure with a range window. Tuples are removed in the partition by window when tuples exceed the amount in the partition. Tuples are removed in the range window when tuples exceed a specified time period. The two data structures are synchronized.

摘要翻译： 提供了一种在事件处理服务中通过基于时间/元组的窗口创建分区的方法。 当连续数据流被接收时，元组被存储在具有基于分区键的分区的数据结构中。 每个分区中只能存储一定量的元组。 当分区超过指定数量的元组时，最旧的元组将从数据结构中删除。 存储超过指定时间段的元组也从数据结构中删除。 也可以使用两个数据结构来实现基于时间/元组的窗口。 元组被存储在具有分区的数据结构的窗口和具有范围窗口的数据结构中。 当元组超过分区中的数量时，元组在窗口中被删除。 当元组超过指定的时间段时，元组在范围窗口中被移除。 两个数据结构是同步的。

公开(公告)号：US08935293B2

公开(公告)日：2015-01-13

申请号：US12396464

申请日：2009-03-02

申请人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F7/00 ,  G06F17/30 ,  G06F9/445 ,  G06F9/455

CPC分类号： G06F9/44521 ,  G06F9/45504

摘要： Techniques for reducing the memory used for processing events received in a data stream are provided. This may be achieved by reducing the memory required for storing tuples. A method for processing a data stream includes receiving a tuple and determining a tuple specification that defines a layout of the tuple. The layout identifies one or more data types that are included in the tuple. A tuple class corresponding to the tuple specification may be determined. A tuple object based on the tuple class is instantiated, and during runtime of the processing system. The tuple object is stored in a memory.

摘要翻译： 提供了用于减少用于处理在数据流中接收的事件的存储器的技术。 这可以通过减少存储元组所需的内存来实现。 一种用于处理数据流的方法包括接收元组并确定定义元组的布局的元组规范。 布局标识包含在元组中的一个或多个数据类型。 可以确定对应于元组规范的元组类。 基于元组类的元组对象被实例化，并且在处理系统的运行期间。 元组对象存储在内存中。

公开(公告)号：US08386466B2

公开(公告)日：2013-02-26

申请号：US12534398

申请日：2009-08-03

申请人： Hoyong Park ,  Rakesh Komuravelli ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Rakesh Komuravelli ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F7/00 ,  G06F17/00 ,  G06F17/30

CPC分类号： G06F17/30368

摘要： Techniques for logging data pertaining to the operation of a data stream processing server. In one set of embodiments, logging configuration information can be received specifying a functional area of a data stream processing server to be logged. Based on the logging configuration information, logging can be dynamically enabled for objects associated with the functional area that are instantiated by the data stream processing server, and logging can be dynamically disabled for objects associated with the functional area that are discarded (or no longer used) by the data stream processing server. In another set of embodiments, a tool can be provided for visualizing the data logged by the data stream processing server.

摘要翻译： 用于记录与数据流处理服务器的操作有关的数据的技术。 在一组实施例中，可以接收指定要记录的数据流处理服务器的功能区域的记录配置信息。 基于记录配置信息，可以对与数据流处理服务器实例化的功能区域相关联的对象动态启用日志记录，并且可以对与丢弃（或不再使用的功能区域）相关联的对象动态禁用日志记录 ）由数据流处理服务器。 在另一组实施例中，可以提供用于可视化由数据流处理服务器记录的数据的工具。

公开(公告)号：US08352517B2

公开(公告)日：2013-01-08

申请号：US12395871

申请日：2009-03-02

申请人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F17/00

CPC分类号： G06F17/30463 ,  G06F17/30471

摘要： Techniques for managing memory usage in a processing system are provided. This may be achieved by receiving a data stream including multiple tuples and determining a query plan that was generated for a continuous query applied to the multiple tuples in the data stream. The query plan may include one or more operators. Before scheduling an operator in the query plan, it is determined when an eviction is to be performed based a level of free memory of the processing system. An eviction candidate is determined and a page associated with the eviction candidate is evicted from the memory to a persistent storage.

摘要翻译： 提供了用于管理处理系统中的存储器使用的技术。 这可以通过接收包括多个元组的数据流并且确定为应用于数据流中的多个元组的连续查询而生成的查询计划来实现。 查询计划可以包括一个或多个运算符。 在调度查询计划中的运算符之前，确定何时根据处理系统的空闲内存的级别执行逐出。 确定驱逐候选人，并且与驱逐候选人相关联的页面从存储器逐出到永久存储器。

公开(公告)号：US08145859B2

公开(公告)日：2012-03-27

申请号：US12396008

申请日：2009-03-02

申请人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F12/02

CPC分类号： G06F12/12

摘要： Techniques for managing memory usage of a processing system by spilling data from a memory to a persistent store based upon an evict policy are provided. A triggering event is detected. In response to the triggering event and based on the evict policy, it is determined whether data from the memory of the processing system is to be spilled to the persistent storage. The determination is made by comparing a level of free memory of the processing system with a threshold specified by the evict policy. The data is evicted from the memory.

摘要翻译： 提供了用于通过基于逐出策略从存储器将数据溢出到持久存储器来管理处理系统的存储器使用的技术。 检测到触发事件。 响应于触发事件并且基于逐出策略，确定来自处理系统的存储器的数据是否将被溢出到持久存储器。 通过将处理系统的空闲内存的级别与逐出策略规定的阈值进行比较来确定。 数据从内存中逐出。

公开(公告)号：US07945540B2

公开(公告)日：2011-05-17

申请号：US11867471

申请日：2007-10-04

申请人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F17/30533

摘要： A method to create a partition by time/tuple based window in an event processing service is provided. When continuous data streams are received, tuples are stored in a data structure with partitions based upon partition keys. Only a specified amount of tuples may be stored in each partition. When a partition exceeds the specified number of tuples, the oldest tuples are removed from the data structure. Tuples stored beyond a specified time period are also removed from the data structure. Two data structures may also be used to implement a time/tuple based window. Tuples are stored in both a data structure with a partition by window and a data structure with a range window. Tuples are removed in the partition by window when tuples exceed the amount in the partition. Tuples are removed in the range window when tuples exceed a specified time period. The two data structures are synchronized.

摘要翻译： 提供了一种在事件处理服务中通过基于时间/元组的窗口创建分区的方法。 当连续数据流被接收时，元组被存储在具有基于分区键的分区的数据结构中。 每个分区中只能存储一定量的元组。 当分区超过指定数量的元组时，最旧的元组将从数据结构中删除。 存储超过指定时间段的元组也从数据结构中删除。 也可以使用两个数据结构来实现基于时间/元组的窗口。 元组被存储在具有分区的数据结构的窗口和具有范围窗口的数据结构中。 当元组超过分区中的数量时，元组在窗口中被删除。 当元组超过指定的时间段时，元组在范围窗口中被移除。 两个数据结构是同步的。

公开(公告)号：US20110029485A1

公开(公告)日：2011-02-03

申请号：US12534398

申请日：2009-08-03

申请人： Hoyong Park ,  Rakesh Komuravelli ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Rakesh Komuravelli ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F17/30368

摘要： Techniques for logging data pertaining to the operation of a data stream processing server. In one set of embodiments, logging configuration information can be received specifying a functional area of a data stream processing server to be logged. Based on the logging configuration information, logging can be dynamically enabled for objects associated with the functional area that are instantiated by the data stream processing server, and logging can be dynamically disabled for objects associated with the functional area that are discarded (or no longer used) by the data stream processing server. In another set of embodiments, a tool can be provided for visualizing the data logged by the data stream processing server.

摘要翻译： 用于记录与数据流处理服务器的操作有关的数据的技术。 在一组实施例中，可以接收指定要记录的数据流处理服务器的功能区域的记录配置信息。 基于记录配置信息，可以对与数据流处理服务器实例化的功能区域相关联的对象动态启用日志记录，并且可以对与丢弃（或不再使用的功能区域）相关联的对象动态禁用日志记录 ）由数据流处理服务器。 在另一组实施例中，可以提供用于可视化由数据流处理服务器记录的数据的工具。

公开(公告)号：US20110029484A1

公开(公告)日：2011-02-03

申请号：US12534384

申请日：2009-08-03

申请人： Hoyong Park ,  Parul Jain ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Parul Jain ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30306

摘要： Techniques for logging data pertaining to the operation of a data stream processing server. In one set of embodiments, logging configuration information can be received specifying a functional area of a data stream processing server to be logged. Based on the logging configuration information, logging can be dynamically enabled for objects associated with the functional area that are instantiated by the data stream processing server, and logging can be dynamically disabled for objects associated with the functional area that are discarded (or no longer used) by the data stream processing server. In another set of embodiments, a tool can be provided for visualizing the data logged by the data stream processing server.

摘要翻译： 用于记录与数据流处理服务器的操作有关的数据的技术。 在一组实施例中，可以接收指定要记录的数据流处理服务器的功能区域的记录配置信息。 基于记录配置信息，可以对与数据流处理服务器实例化的功能区域相关联的对象动态启用日志记录，并且可以对与丢弃（或不再使用的功能区域）相关联的对象动态禁用日志记录 ）由数据流处理服务器。 在另一组实施例中，可以提供用于可视化由数据流处理服务器记录的数据的工具。