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
    2.
    发明申请
    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
    3.
    发明授权
    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
    4.
    发明授权
    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
    5.
    发明申请
    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
    6.
    发明申请
    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
    7.
    发明申请
    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。

    Deriving a Nested Chain of Densest Subgraphs from a Graph
    9.
    发明申请
    Deriving a Nested Chain of Densest Subgraphs from a Graph 有权
    从图中衍生出一个嵌套的致密子图链

    公开(公告)号:US20130226840A1

    公开(公告)日:2013-08-29

    申请号:US13406843

    申请日:2012-02-28

    申请人: Bin Zhang Meichun Hsu

    发明人: Bin Zhang Meichun Hsu

    IPC分类号: G06F15/18

    CPC分类号: G06F17/30958

    摘要: A nested chain of densest subgraphs is derived by a computer from a given graph that has multiple vertices and edges. The two ends of each edge are assigned with respective incident weights, and each vertex is given a vertex weight. A weight balancing process is carried out by the computer to iteratively go through the edges to adjust the incident weights of each edge and the vertex weights of the vertices connected by that edge to reduce a difference between the vertex weights of the two vertices. After the balancing, the vertex weights are put in an ordered sequence according to their values, and a nested chain of densest subgraphs is derived from the ordered sequence.

    摘要翻译: 密集子图的嵌套链由计算机从具有多个顶点和边的给定图导出。 每个边缘的两端被分配有相应的事件权重,并且每个顶点被赋予顶点权重。 计算机进行权重平衡处理,以迭代地遍历边缘,以调整每个边缘的入射权重和由该边连接的顶点的顶点权重,以减少两个顶点的顶点权重之间的差异。 在平衡之后,顶点权重根据它们的值被置于有序序列中,并且从有序序列导出嵌套的密集子图链。

    System and Method for Querying a Data Stream
    10.
    发明申请
    System and Method for Querying a Data Stream 审中-公开
    用于查询数据流的系统和方法

    公开(公告)号:US20130191370A1

    公开(公告)日:2013-07-25

    申请号:US13825019

    申请日:2010-10-11

    IPC分类号: G06F17/30

    CPC分类号: G06F16/24542 G06F16/24568

    摘要: There is provided a method (200) for querying a data stream. The method includes receiving a query plan based on a query specifying the data stream and a window. The method (200) further includes receiving one or more stream elements from the data stream during the window. Additionally, the method (200) includes applying the query to the one or more stream elements by passing the one or more stream elements from a scan operator at a leaf of the query plan to an upper layer of the query plan on a tuple-by-tuple basis. The method (200) also includes committing a result of the query based on the one or more stream elements.

    摘要翻译: 提供了一种用于查询数据流的方法(200)。 该方法包括基于指定数据流和窗口的查询来接收查询计划。 方法(200)还包括在窗口期间从数据流接收一个或多个流元素。 另外,方法(200)包括通过将来自查询计划的叶的扫描运算符的一个或多个流元素传递到元组的查询计划的上层来将查询应用于一个或多个流元素 元组基础 所述方法(200)还包括基于所述一个或多个流元素提交所述查询的结果。