Formula-based load evaluation in distributed streaming platform for real-time applications
    1.
    发明授权
    Formula-based load evaluation in distributed streaming platform for real-time applications 有权
    用于实时应用的分布式流平台中基于公式的负载评估

    公开(公告)号:US09563486B1

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

    申请号:US14205234

    申请日:2014-03-11

    申请人: DataTorrent Inc.

    摘要: Software for a distributed streaming platform receives an application that runs on a streaming platform. The application is structured as a directed acyclic graph (DAG) with instances of operators as nodes and streams as edges between nodes. The application is associated with a pre-defined hint that is a key-value pair. The software launches the application by assigning the instances of operators to containers provided by the streaming platform and initiating the streams. Then the software reads a value for the pre-defined hint and transmits the value to the application through an application programming interface (API) exposed by the streaming platform. The software receives a request from the application through the API to make a dynamic adjustment. And the software makes the dynamic adjustment and re-launches the application using a recovery policy.

    摘要翻译: 分布式流媒体平台的软件接收在流媒体平台上运行的应用程序。 应用程序被构造为有向非循环图(DAG),其中运算符的实例作为节点之间的边缘的节点和流。 应用程序与一个键值对的预定义提示相关联。 该软件通过将运算符的实例分配给由流平台提供的容器并启动流来启动应用。 然后,软件读取预定义提示的值,并通过流媒体平台暴露的应用程序编程接口(API)将该值传输到应用程序。 软件通过API接收应用程序的请求,进行动态调整。 该软件使用恢复策略进行动态调整并重新启动应用程序。