公开(公告)号：US20120297080A1

公开(公告)日：2012-11-22

申请号：US13108005

申请日：2011-05-16

申请人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

发明人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

IPC分类号： G06F15/16

CPC分类号： G06F9/542

摘要： Aspects of the subject matter described herein relate to stream operators. In aspects, a stream event is received. Based on a timestamp associated with the stream event and the number of stream operators that have asked to be activated prior to or at the timestamp, zero or more stream objects are informed of one or more time events and torn down if no longer needed. In addition, a destination stream operator is instantiated, if needed, data (e.g., the timestamp and packet, if any) corresponding to the stream event is provided to a stream operator, output data, if any, is received from the stream operator, and the stream operator is torn down if it no longer needs state data between invocations.

摘要翻译： 本文描述的主题的方面涉及流操作员。 在方面，接收流事件。 基于与流事件相关联的时间戳和要求在时间戳之前或时间戳处被激活的流运算符的数量，零或多个流对象被通知一个或多个时间事件，并且如果不再需要则被拆除。 另外，如果需要，将目的地流运算符进行实例化，将与流事件相对应的数据（例如，时间戳和分组，如果有的话）提供给流运算符，则从流运算符接收输出数据（如果有的话） 如果流操作员不再需要调用之间的状态数据，则该流操作符将被拆除。

公开(公告)号：US08683074B2

公开(公告)日：2014-03-25

申请号：US13108005

申请日：2011-05-16

申请人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

发明人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

IPC分类号： G06F15/16

CPC分类号： G06F9/542

摘要： Aspects of the subject matter described herein relate to stream operators. In aspects, a stream event is received. Based on a timestamp associated with the stream event and the number of stream operators that have asked to be activated prior to or at the timestamp, zero or more stream objects are informed of one or more time events and torn down if no longer needed. In addition, a destination stream operator is instantiated, if needed, data (e.g., the timestamp and packet, if any) corresponding to the stream event is provided to a stream operator, output data, if any, is received from the stream operator, and the stream operator is torn down if it no longer needs state data between invocations.

摘要翻译： 本文描述的主题的方面涉及流操作员。 在方面，接收流事件。 基于与流事件相关联的时间戳和要求在时间戳之前或时间戳处被激活的流运算符的数量，零或多个流对象被通知一个或多个时间事件，并且如果不再需要则被拆除。 另外，如果需要，将目的地流运算符进行实例化，将与流事件相对应的数据（例如，时间戳和分组，如果有的话）提供给流运算符，则从流运算符接收输出数据（如果有的话） 如果流操作员不再需要调用之间的状态数据，则该流操作符将被拆除。