Methods and Apparatus for Functional Model-Based Data Provenance in Stream Processing Environments
    1.
    发明申请
    Methods and Apparatus for Functional Model-Based Data Provenance in Stream Processing Environments 失效
    流处理环境中基于功能模型的数据发现的方法与装置

    公开(公告)号:US20080307104A1

    公开(公告)日:2008-12-11

    申请号:US11760070

    申请日:2007-06-08

    IPC分类号: G06F15/16

    CPC分类号: G06F17/30516

    摘要: Techniques for deriving a provenance of one or more of a plurality of output data elements generated from a given output port of a PC are provided. At least one dependency function is created that relates the one or more output data elements to a set of one or more input ports of the PC and a corresponding plurality of input data elements. The dependency function comprises an encoding of at least one of one or more temporal filters and one or more sequence filters relating to the plurality of input data elements. The at least one dependency function is stored. A history of stream-level bindings of one or more input streams to one or more input ports of the processing component and one or more output streams from one or more output ports of the processing component is stored. The plurality of input data elements belonging to the one or more input streams and the plurality of output data elements belonging to the one or more output streams are stored. The set of one or more input data elements from the plurality of input data elements are determined that relate to the one or more output data elements in accordance with at least one dependency function and the history of stream-level bindings.

    摘要翻译: 提供了用于导出从PC的给定输出端口生成的多个输出数据元素中的一个或多个的来源的技术。 创建至少一个依赖函数,其将一个或多个输出数据元素与PC的一个或多个输入端口的集合和相应的多个输入数据元素相关联。 依赖函数包括一个或多个时间滤波器和与多个输入数据元素相关的一个或多个序列滤波器中的至少一个的编码。 存储至少一个依赖函数。 存储一个或多个输入流到处理组件的一个或多个输入端口和来自处理组件的一个或多个输出端口的一个或多个输出流的流级绑定的历史。 存储属于一个或多个输入流的多个输入数据元素和属于一个或多个输出流的多个输出数据元素。 根据至少一个依赖函数和流级绑定的历史,确定来自多个输入数据元素的一个或多个输入数据元素的集合,其与一个或多个输出数据元素相关。

    Methods and apparatus for functional model-based data provenance in stream processing environments
    2.
    发明授权
    Methods and apparatus for functional model-based data provenance in stream processing environments 失效
    在流处理环境中基于功能模型的数据来源的方法和装置

    公开(公告)号:US07539753B2

    公开(公告)日:2009-05-26

    申请号:US11760070

    申请日:2007-06-08

    IPC分类号: G06F11/34

    CPC分类号: G06F17/30516

    摘要: Techniques for deriving a provenance of one or more of a plurality of output data elements generated from a given output port of a PC are provided. At least one dependency function is created that relates the one or more output data elements to a set of one or more input ports of the PC and a corresponding plurality of input data elements. The dependency function comprises an encoding of at least one of one or more temporal filters and one or more sequence filters relating to the plurality of input data elements. The at least one dependency function is stored. A history of stream-level bindings of one or more input streams to one or more input ports of the processing component and one or more output streams from one or more output ports of the processing component is stored. The plurality of input data elements belonging to the one or more input streams and the plurality of output data elements belonging to the one or more output streams are stored. The set of one or more input data elements from the plurality of input data elements are determined that relate to the one or more output data elements in accordance with at least one dependency function and the history of stream-level bindings.

    摘要翻译: 提供了用于导出从PC的给定输出端口生成的多个输出数据元素中的一个或多个的来源的技术。 创建至少一个依赖函数,其将一个或多个输出数据元素与PC的一个或多个输入端口的集合和相应的多个输入数据元素相关联。 依赖函数包括一个或多个时间滤波器和与多个输入数据元素相关的一个或多个序列滤波器中的至少一个的编码。 存储至少一个依赖函数。 存储一个或多个输入流到处理组件的一个或多个输入端口和来自处理组件的一个或多个输出端口的一个或多个输出流的流级绑定的历史。 存储属于一个或多个输入流的多个输入数据元素和属于一个或多个输出流的多个输出数据元素。 根据至少一个依赖函数和流级绑定的历史,确定来自多个输入数据元素的一个或多个输入数据元素的集合,其与一个或多个输出数据元素相关。

    SYSTEMS AND METHODS FOR USING PROVENANCE INFORMATION FOR DATA RETENTION IN STREAM-PROCESSING
    3.
    发明申请
    SYSTEMS AND METHODS FOR USING PROVENANCE INFORMATION FOR DATA RETENTION IN STREAM-PROCESSING 有权
    用于在流水线处理中使用数据保留的资源信息的系统和方法

    公开(公告)号:US20100287204A1

    公开(公告)日:2010-11-11

    申请号:US11939176

    申请日:2007-11-13

    IPC分类号: G06F17/30

    摘要: A system and method for determining data usage based on provenance information, in a stream-processing system, includes progressively setting usage information for output stream data objects (SDOs), determining input SDOs that an output SDO depends on, based on a provenance dependency function; recursively feeding back the usage information for a subset of SDOs that can be discarded; and discarding the subset of SDOs. A system and method for data retention based on usage information, in a stream-processing system, includes managing retention of SDOs by deleting SDOs that are determined to be of null usage; and enhancing retention characteristics of SDOs that are deemed to have usage.

    摘要翻译: 一种用于在流处理系统中基于来源信息确定数据使用的系统和方法包括逐渐设置输出流数据对象(SDO)的使用信息,基于来源依赖函数确定输出SDO所依赖的输入SDO ; 递归地反馈可以丢弃的SDO子集的使用信息; 并丢弃SDO的子集。 在流处理系统中,基于使用信息的用于数据保留的系统和方法包括通过删除被确定为零使用的SDO来管理SDO的保留; 并增强被认为具有使用性的SDO的保留特性。

    Method and system for dynamic application composition in streaming systems
    4.
    发明申请
    Method and system for dynamic application composition in streaming systems 审中-公开
    流系统中动态应用组合的方法和系统

    公开(公告)号:US20070261041A1

    公开(公告)日:2007-11-08

    申请号:US11209584

    申请日:2005-08-23

    IPC分类号: G06F9/45

    CPC分类号: G06F8/41 G06F9/4494

    摘要: A system and method for dynamically building applications for stream processing includes providing processing elements with a flow specification describing each input and a stream description describing each output such that the flow specification indicates a stream or streams which are to be received based on processing information and the stream descriptions indicate the processing information. Processing elements that can be reused are identified by determining equivalence between the processing elements. Processing elements that are new and are not reusable are instantiated in a flow graph. An application is dynamically composed, using the instantiated processing elements by routing available streams to the instantiated processing elements in accordance with the flow specifications.

    摘要翻译: 用于动态构建用于流处理的应用的系统和方法包括向处理元件提供描述每个输入的流程规范和描述每个输出的流描述,使得流规范基于处理信息指示要被接收的流或流, 流描述指示处理信息。 可以重新使用的处理元件通过确定处理元件之间的等价来识别。 处理新的且不可重用的元素在流程图中被实例化。 动态组合应用程序,使用实例化的处理元件,根据流程规范将可用流路由到实例处理元件。

    Method and system for dynamic application composition in streaming systems
    5.
    发明授权
    Method and system for dynamic application composition in streaming systems 有权
    流系统中动态应用组合的方法和系统

    公开(公告)号:US08112541B2

    公开(公告)日:2012-02-07

    申请号:US12131310

    申请日:2008-06-02

    IPC分类号: G06F15/16

    CPC分类号: G06F8/41 G06F9/4494

    摘要: A system and method for dynamically building applications for stream processing includes providing processing elements with a flow specification describing each input and a stream description describing each output such that the flow specification indicates a stream or streams which are to be received based on processing information and the stream descriptions indicate the processing information. Processing elements that can be reused are identified by determining equivalence between the processing elements. Processing elements that are new and are not reusable are instantiated in a flow graph. An application is dynamically composed, using the instantiated processing elements by routing available streams to the instantiated processing elements in accordance with the flow specifications.

    摘要翻译: 用于动态构建用于流处理的应用的系统和方法包括向处理元件提供描述每个输入的流程规范和描述每个输出的流描述,使得流规范基于处理信息指示要被接收的流或流, 流描述指示处理信息。 可以重新使用的处理元件通过确定处理元件之间的等价来识别。 处理新的且不可重用的元素在流程图中被实例化。 动态组合应用程序,使用实例化的处理元件,根据流程规范将可用流路由到实例处理元素。

    Method and system for supporting dynamic stream attributes
    6.
    发明申请
    Method and system for supporting dynamic stream attributes 有权
    支持动态流属性的方法和系统

    公开(公告)号:US20070280381A1

    公开(公告)日:2007-12-06

    申请号:US11445889

    申请日:2006-06-01

    IPC分类号: H03D1/00 H04L27/06

    CPC分类号: H04L67/2804

    摘要: A publisher-subscriber system includes a broker configured to receive and distribute at least one data stream from publishers to subscribers in accordance with subscriptions. An annotator/classifier is configured to annotate or classify the data stream by employing one or more additional stream-level attributes to create an annotated data stream wherein the annotated data stream applies the stream-level attribute to all messages therein such that subscribers can subscribe to the annotated data stream created by the annotator/classifier.

    摘要翻译: 发布者订户系统包括被配置为根据订阅从发布者接收和分发至少一个数据流的代理。 注释器/分类器被配置为通过使用一个或多个附加流级别属性来创建注释数据流来对数据流进行注释或分类,其中注释的数据流将流级属性应用于其中的所有消息,使得用户可以订阅 由注释器/分类器创建的注释数据流。

    Method and system for supporting dynamic stream attributes
    7.
    发明授权
    Method and system for supporting dynamic stream attributes 有权
    支持动态流属性的方法和系统

    公开(公告)号:US07944864B2

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

    申请号:US11445889

    申请日:2006-06-01

    CPC分类号: H04L67/2804

    摘要: A publisher-subscriber system includes a broker configured to receive and distribute at least one data stream from publishers to subscribers in accordance with subscriptions. An annotator/classifier is configured to annotate or classify the data stream by employing one or more additional stream-level attributes to create an annotated data stream wherein the annotated data stream applies the stream-level attribute to all messages therein. Subscribers can subscribe to the annotated data stream created by the annotator/classifier.

    摘要翻译: 发布者订户系统包括被配置为根据订阅从发布者接收和分发至少一个数据流的代理。 注释器/分类器被配置为通过使用一个或多个附加流级属性来创建注释数据流来对数据流进行注释或分类,其中注释的数据流将流级属性应用于其中的所有消息。 订阅者可以订阅由注释器/分类器创建的注释数据流。

    Methods and Apparatus for Secure and Adaptive Delivery of Multimedia Content
    8.
    发明申请
    Methods and Apparatus for Secure and Adaptive Delivery of Multimedia Content 有权
    多媒体内容的安全和自适应传送的方法和装置

    公开(公告)号:US20080013719A1

    公开(公告)日:2008-01-17

    申请号:US11781699

    申请日:2007-07-23

    IPC分类号: H04K1/04

    摘要: Techniques for securely and adaptively delivering multimedia content. It is assumed that a set of alternate access units for each time slot is obtained. Then, the encryption stream index of each access unit from the set of alternate access units of the previous time slot are obtained. An encryption stream index is then assigned to each access unit in the set of alternate access units in the current time slot, such that the encryption index increases over time. Thus, the invention overcomes the problem of encrypting a multimedia stream that may have multiple access units for each time slot by selecting the encryption index for each access unit such that the encryption index increases, regardless of which access unit the delivery system (e.g., server) selects for transmission.

    摘要翻译: 安全和自适应地传送多媒体内容的技术。 假设获得了用于每个时隙的一组备用存取单元。 然后,获得来自前一时隙的一组备用访问单元的每个访问单元的加密流索引。 然后,将加密流索引分配给当前时隙中的备用访问单元集合中的​​每个访问单元,使得加密索引随时间增加。 因此,本发明克服了通过选择每个接入单元的加密索引来加密每个时隙可能具有多个接入单元的多媒体流的问题,使得加密索引增加,而不考虑哪个接入单元的传送系统(例如,服务器 )选择进行传输。

    RESOURCE-EFFICIENT MEDIA STREAMING TO HETEROGENEOUS CLIENTS
    9.
    发明申请
    RESOURCE-EFFICIENT MEDIA STREAMING TO HETEROGENEOUS CLIENTS 有权
    资源有效的媒体流向异构客户

    公开(公告)号:US20070130359A1

    公开(公告)日:2007-06-07

    申请号:US11670512

    申请日:2007-02-02

    IPC分类号: G06F15/16

    摘要: A resource-efficient live streaming system includes a broadcaster and a streaming server. The broadcaster receives a live feed and broadcasts a media stream to the streaming server containing several descriptions of the live feed along with control information. The broadcaster includes a stream thinner that implements a pruning algorithm. If descriptions from different streams are similar enough, one or more of them may be discarded without penalizing the quality of service perceived by the receivers. The streaming server assembles compressed data units into streams according to the control information from the broadcaster. The streaming server may also gather client feedback in order to estimate the status of the transmission channels and forwards the information to the broadcaster. The streaming server builds and streams media information to clients according to user preferences and receiver capabilities.

    摘要翻译: 一个资源有效的直播流系统包括一个广播公司和一个流媒体服务器。 广播公司收到实时订阅源,并将媒体流广播到流媒体服务器,其中包含有关实时供稿的多个描述以及控制信息。 广播者包括实现修剪算法的流更薄。 如果来自不同流的描述足够相似,则可以丢弃它们中的一个或多个,而不会损害接收器感知到的服务质量。 流媒体服务器根据来自广播公司的控制信息将压缩数据单元组装成流。 流服务器还可以收集客户端反馈,以估计传输信道的状态并将信息转发给广播者。 流媒体服务器根据用户偏好和接收机功能,将媒体信息建立并传输给客户端。

    METHOD AND SYSTEM FOR DYNAMIC APPLICATION COMPOSITION IN STREAMING SYSTEMS
    10.
    发明申请
    METHOD AND SYSTEM FOR DYNAMIC APPLICATION COMPOSITION IN STREAMING SYSTEMS 有权
    流动系统中动态应用组合的方法与系统

    公开(公告)号:US20080235685A1

    公开(公告)日:2008-09-25

    申请号:US12131310

    申请日:2008-06-02

    IPC分类号: G06F9/46

    CPC分类号: G06F8/41 G06F9/4494

    摘要: A system and method for dynamically building applications for stream processing includes providing processing elements with a flow specification describing each input and a stream description describing each output such that the flow specification indicates a stream or streams which are to be received based on processing information and the stream descriptions indicate the processing information. Processing elements that can be reused are identified by determining equivalence between the processing elements. Processing elements that are new and are not reusable are instantiated in a flow graph. An application is dynamically composed, using the instantiated processing elements by routing available streams to the instantiated processing elements in accordance with the flow specifications.

    摘要翻译: 用于动态构建用于流处理的应用的系统和方法包括向处理元件提供描述每个输入的流程规范和描述每个输出的流描述,使得流规范基于处理信息指示要被接收的流或流, 流描述指示处理信息。 可以重新使用的处理元件通过确定处理元件之间的等价来识别。 处理新的且不可重用的元素在流程图中被实例化。 动态组合应用程序,使用实例化的处理元件,根据流程规范将可用流路由到实例处理元素。