Work flow management system and method
    1.
    发明授权
    Work flow management system and method 失效
    工作流程管理系统和方法

    公开(公告)号:US5581691A

    公开(公告)日:1996-12-03

    申请号:US516729

    申请日:1995-08-18

    CPC分类号: G06F9/4436 G06F9/466

    摘要: A work flow description database represents long running work flows as a set of work units, called steps, with information flows therebetween. The description database defines each step's input and output signals, input condition criteria for creating an instance of the step, an application program associated with the step, and criteria for selecting a resource to execute the step. A work flow controller controls the process of executing instances of each defined type of work flow. Execution of a long running work flow begins when a corresponding set of externally generated input event signals are received by the work flow controller. During execution of a work flow, each step of the work flow is instantiated only when a sufficient set of input signals is received to execute that step. At that point an instance of the required type of step is created and then executed by a selected resource. After termination of a step, output signals from the step are converted into input event signals for other steps in the work flow in accordance with data stored in the work flow description database. Each step executes an application program and is treated as an individual transaction insofar as durable storage of its results. Log records are durably stored upon instantiation, execution and termination of each step of a work flow, and output event signals are also logged, thereby durably storing sufficient data to recover a work flow with virtually no loss of the work that was accomplished prior to a system failure.

    摘要翻译: 工作流程描述数据库表示作为一组工作单元(称为步骤)的长时间运行的工作流程,其间具有信息流。 描述数据库定义每个步骤的输入和输出信号,用于创建步骤的实例的输入条件标准,与步骤相关联的应用程序以及用于选择执行步骤的资源的标准。 工作流控制器控制执行每个定义类型的工作流的实例的过程。 当工作流控制器接收到相应的一组外部生成的输入事件信号时,开始长时间运行的工作流程的执行。 在执行工作流程期间,仅当接收到足够的输入信号集才能执行该步骤时,工作流程的每个步骤被​​实例化。 此时,创建所需类型步骤的实例,然后由所选资源执行。 在步骤结束之后,根据存储在工作流程描述数据库中的数据,将来自步骤的输出信号转换为工作流程中的其他步骤的输入事件信号。 每个步骤执行一个应用程序,并将其视为一个单独的事务,只要其结果的持久存储即可。 日志记录在工作流程的每个步骤的实例化,执行和终止时持久地存储,并且还记录输出事件信号,从而持久地存储足够的数据以恢复工作流程,几乎不损失在 系统错误。

    System and method for executing, tracking and recovering long running
computations
    2.
    发明授权
    System and method for executing, tracking and recovering long running computations 失效
    用于执行,跟踪和恢复长时间计算的系统和方法

    公开(公告)号:US5524241A

    公开(公告)日:1996-06-04

    申请号:US426415

    申请日:1995-04-18

    摘要: A transaction description database represents long running computations as a flow or set of computational steps with data arcs therebetween. The description database defines each step's input and output signals, input condition criteria for creating an instance of the step, an application program associated with the step, and criteria for selecting a resource to execute the step. A flow controller controls the process of executing instances of each defined type of long running transaction. Execution of a long running transaction begins when a corresponding set of externally generated input event signals are received by the flow controller. During execution of a long running transaction, each step of the transaction is instantiated only when a sufficient set of input signals is received to execute that step. At that point an instance of the required type of step is created and then executed by a selected resource. After termination of a step, output signals from the step are converted into input event signals for other steps in the long running transaction in accordance with data stored in the transaction description database. Each step executes an application program and is treated as an individual computation insofar as durable storage of its computational results. Log records are durably stored upon instantiation, execution and termination of each step of a long running transaction, and output event signals are also logged, thereby durably storing sufficient data to recover a long running transaction with virtually no loss of the work that was accomplished prior to a system failure.

    摘要翻译: 事务描述数据库表示长时间计算,作为其间具有数据弧的计算步骤的流或一组。 描述数据库定义每个步骤的输入和输出信号,用于创建步骤的实例的输入条件标准,与步骤相关联的应用程序以及用于选择执行步骤的资源的标准。 流控制器控制执行每个定义类型的长时间运行事务的实例的过程。 当流控制器接收到相应的一组外部生成的输入事件信号时,开始执行长时间运行的事务。 在执行长时间运行的事务期间,仅当接收到足够的一组输入信号来执行该步骤时,事务的每个步骤被​​实例化。 此时,创建所需类型步骤的实例,然后由所选资源执行。 在步骤结束之后,根据存储在交易描述数据库中的数据,来自步骤的输出信号被转换成长时间运行的交易中的其他步骤的输入事件信号。 每个步骤都执行一个应用程序,并将其视为一个单独的计算,只要其持久存储其计算结果即可。 日志记录可以在长时间运行的事务的每个步骤的实例化,执行和终止时持久地存储,并且还记录输出事件信号,从而持久地存储足够的数据以恢复长时间运行的事务,几乎不会损失在之前完成的工作 到系统故障。

    Page feed for efficient dataflow between distributed query engines

    公开(公告)号:US09836513B2

    公开(公告)日:2017-12-05

    申请号:US13418055

    申请日:2012-03-12

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30575

    摘要: Page feed for efficient dataflow between distributed query engines is disclosed. An example method comprises storing a query result relation by a producer query as pages in a query engine buffer pool, and then sending these pages to a distributed caching platform (DCP) as the data source of another query. The example method also includes reading the result relation by a consumer query from the page stored in the DCP.

    Support Actual and Virtual SQL Dataflow by Streaming Infrastructure
    4.
    发明申请
    Support Actual and Virtual SQL Dataflow by Streaming Infrastructure 审中-公开
    通过流式传输基础架构支持实际和虚拟SQL数据流

    公开(公告)号:US20160034535A1

    公开(公告)日:2016-02-04

    申请号:US14439919

    申请日:2012-10-31

    IPC分类号: G06F17/30

    摘要: A method includes binding a stationed operator to a database query engine, wherein the stationed operator comprises system utilities and an open executor to execute user-supplied application logic. The method further includes receiving an unbounded input stream of input tuples by the stationed operator, the stream of input tuples comprising a succession of chunks. The method also includes applying a query defined by the application logic to each successive chunk of the input stream to produce an output packet for each such chunk, and generating an unbounded output stream comprising the output packets.

    摘要翻译: 一种方法包括将驻点运算符绑定到数据库查询引擎,其中驻点运算符包括系统实用程序和用于执行用户提供的应用逻辑的开放执行器。 该方法还包括由驻点操作者接收输入元组的无界输入流,所述输入元组流包括一系列块。 该方法还包括将由应用逻辑定义的查询应用于输入流的每个连续块以产生每个这样的块的输出分组,以及生成包括输出分组的无界输出流。

    User defined data partitioning (UDP)—grouping of data based on computation model
    5.
    发明授权
    User defined data partitioning (UDP)—grouping of data based on computation model 有权
    用户定义的数据分区(UDP) - 基于计算模型的数据分组

    公开(公告)号:US08904381B2

    公开(公告)日:2014-12-02

    申请号:US12358995

    申请日:2009-01-23

    IPC分类号: G06F17/30 G06F9/50

    摘要: Methods, systems, and computer program products are provided for generating application-aware data partitioning to support parallel computing. A label for a user defined data partitioning (UDP) key is generated by a labeling process to configure data partitions of original data. The UDP is labeled by the labeling process to include at least one key property excluded from the original data. The data partitions are evenly distributed to co-locate and balance the data partitions and corresponding computations performed by computational servers. A data record of the data partitions is retrieved by performing an all-node parallel search of the computational servers using the UDP key.

    摘要翻译: 提供了方法,系统和计算机程序产品,用于生成应用感知数据分区以支持并行计算。 用户定义的数据分区(UDP)密钥的标签由标记过程生成,以配置原始数据的数据分区。 UDP由标记过程标记,以包含从原始数据中排除的至少一个密钥属性。 数据分区均匀分布,以共同定位和平衡数据分区和计算服务器执行的相应计算。 通过使用UDP密钥执行计算服务器的全部节点并行搜索来检索数据分区的数据记录。

    Dynamic interface between BPSS conversation management and local business management
    6.
    发明授权
    Dynamic interface between BPSS conversation management and local business management 有权
    BPSS对话管理与本地业务管理之间的动态接口

    公开(公告)号:US08655790B2

    公开(公告)日:2014-02-18

    申请号:US13615197

    申请日:2012-09-13

    IPC分类号: G06Q10/00

    摘要: The present invention relates to devices and methods that coordinate an external conversation process between entities with an internal workflow of one of the entities. More particularly, it relates to devices and methods that are compliant with an inter-enterprise conversation process standard for routing electronic commerce documents between enterprises. Particular aspects of the present invention are described in the claims, specification and drawings.

    摘要翻译: 本发明涉及利用其中一个实体的内部工作流来协调实体之间的外部会话处理的设备和方法。 更具体地说,本发明涉及符合企业间企业对话电子商务文档的跨企业对话处理标准的装置和方法。 在权利要求书,说明书和附图中描述了本发明的特定方面。

    VISUALIZING TIME-DENSE EPISODES
    7.
    发明申请
    VISUALIZING TIME-DENSE EPISODES 有权
    可视化时间表感染

    公开(公告)号:US20140040247A1

    公开(公告)日:2014-02-06

    申请号:US13562752

    申请日:2012-07-31

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30551

    摘要: Attributes in data records are identified. Episodes corresponding to the respective attributes include respective data records. The episodes are scored, where scoring of a particular one of the episodes is based on relative time densities between successive data records of the particular episode. A visualization of at least some of the episodes to provide an alert of time-dense episodes.

    摘要翻译: 识别数据记录中的属性。 对应于各个属性的情节包括各自的数据记录。 这些剧集得分,其中特定剧集的得分基于特定剧集的连续数据记录之间的相对时间密度。 至少一些情节的可视化,以提供时间密集的情节的警报。

    GENERATION OF EXPLANATORY SUMMARIES
    8.
    发明申请
    GENERATION OF EXPLANATORY SUMMARIES 有权
    解释性概述的产生

    公开(公告)号:US20130325440A1

    公开(公告)日:2013-12-05

    申请号:US13485730

    申请日:2012-05-31

    IPC分类号: G06F17/27

    摘要: A method for generating sum maries of text is described. The method includes the step of extracting features from text of text lists from summaries. The explanatoriness of the text is then evaluated, wherein evaluating the explanatoriness of text includes evaluating the features of the text, including at least the step of evaluating the discriminativeness of the features of the text by comparing the text to a first text data set, wherein the first text data set is derived from a topic label. The evaluated text is then ranked based on the explanatoriness evaluation.

    摘要翻译: 描述了一种产生文本总结的方法。 该方法包括从摘要文本列表中提取特征的步骤。 然后评估文本的解释性,其中评估文本的解释性包括评估文本的特征,包括至少通过将文本与第一文本数据集进行比较来评估文本的特征的歧视性的步骤,其中 第一个文本数据集是从主题标签派生出来的。 然后根据解释性评估对评估文本进行排名。

    OPEN STATION AS A STREAM ANALYSIS OPERATOR CONTAINER
    9.
    发明申请
    OPEN STATION AS A STREAM ANALYSIS OPERATOR CONTAINER 有权
    开放站作为流动分析操作员集装箱

    公开(公告)号:US20130290554A1

    公开(公告)日:2013-10-31

    申请号:US13457449

    申请日:2012-04-26

    IPC分类号: G06F15/16

    CPC分类号: H04L41/14

    摘要: An open station as a stream analysis operator container is disclosed. In an example, a method is stored as instructions on computer readable media and executable by a processor. The method includes packaging graph-structured stream transformations into a topology of a top-level dataflow process including stream transformation operators (STOs) on open stations. The method also includes sending a tuple from one of the STOs to every other STO in the topology subscribed to a data stream of the tuple.

    摘要翻译: 公开了作为流分析操作者容器的开放站。 在一个示例中,方法作为指令存储在计算机可读介质上并且可由处理器执行。 该方法包括将图形结构化流转换包括在顶层数据流过程的拓扑中,包括开放站上的流转换算子(STO)。 该方法还包括将一个元组从一个STO发送到订阅该元组的数据流的拓扑中的每个其他STO。