Parallel data stream processing system

    公开(公告)号:US09805101B2

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

    申请号:US13034555

    申请日:2011-02-24

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30539

    摘要: A method and a system process a stream of data in parallel across a plurality of nodes. The log processing system has a log module, a query language module, and a query processing module. The log module receives and organizes the stream of data into a sequential and nested data structure. The query language operator module defines operators that operate on the sequential and nested data structure. The query processing module processes in parallel across a plurality of nodes a query based on an operator on the stream of data.

    CATEGORY MANAGEMENT AND ANALYSIS
    5.
    发明申请
    CATEGORY MANAGEMENT AND ANALYSIS 有权
    类别管理与分析

    公开(公告)号:US20110238665A1

    公开(公告)日:2011-09-29

    申请号:US13072589

    申请日:2011-03-25

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30643 G06Q30/06

    摘要: A method and system analyze data associated with a marketplace category. In some embodiments, a query is received that identifies a marketplace category from multiple marketplace categories associated with an electronic commerce marketplace. Data associated with the marketplace category is accessed and analyzed to identify multiple keywords used to identify listings in the marketplace category. A user interface is generated to display the analysis results, including at least a portion of the multiple keywords used to identify listings in the marketplace category.

    摘要翻译: 方法和系统分析与市场类别相关联的数据。 在一些实施例中,接收到从与电子商务市场相关联的多个市场类别识别市场类别的查询。 与市场类别相关联的数据被访问和分析,以识别用于识别市场类别中的列表的多个关键字。 生成用户界面以显示分析结果,包括用于识别市场类别中的列表的多个关键字中的至少一部分。

    PARALLEL DATA STREAM PROCESSING SYSTEM
    6.
    发明申请
    PARALLEL DATA STREAM PROCESSING SYSTEM 有权
    并行数据流处理系统

    公开(公告)号:US20110213802A1

    公开(公告)日:2011-09-01

    申请号:US13034555

    申请日:2011-02-24

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30539

    摘要: A method and a system process a stream of data in parallel across a plurality of nodes. The log processing system has a log module, a query language module, and a query processing module. The log module receives and organizes the stream of data into a sequential and nested data structure. The query language operator module defines operators that operate on the sequential and nested data structure. The query processing module processes in parallel across a plurality of nodes a query based on an operator on the stream of data.

    摘要翻译: 方法和系统跨多个节点并行处理数据流。 日志处理系统具有日志模块,查询语言模块和查询处理模块。 日志模块接收并将数据流组织成顺序和嵌套的数据结构。 查询语言运算符模块定义对顺序和嵌套数据结构进行操作的运算符。 查询处理模块在多个节点之间并行处理基于数据流上的运算符的查询。

    ANALYZING EVENT STREAMS OF USER SESSIONS
    7.
    发明申请
    ANALYZING EVENT STREAMS OF USER SESSIONS 有权
    用户会话分析事件流程

    公开(公告)号:US20090228474A1

    公开(公告)日:2009-09-10

    申请号:US12263382

    申请日:2008-10-31

    IPC分类号: G06F17/30 G06F7/08

    摘要: In various exemplary embodiments, a system and method is disclosed to analyze event streams of a user session. One embodiment of the method includes logging a plurality of events from an event stream, specifying conditions to sort the plurality of events, applying the conditions to the plurality of events, producing a probability distribution of event nodes after a given node in the event stream, and producing an interactive graphical reduction of a produced graph by determining patterns in a graphical tree and unifying occurrences of the patterns.

    摘要翻译: 在各种示例性实施例中,公开了分析用户会话的事件流的系统和方法。 该方法的一个实施例包括从事件流记录多个事件,指定对多个事件进行排序的条件,将条件应用于多个事件,产生事件流中的给定节点之后的事件节点的概率分布, 以及通过确定图形树中的模式并统一模式的出现来产生生成的图形的交互式图形缩小。

    Distributed steam processing
    8.
    发明授权
    Distributed steam processing 有权
    分布式蒸汽加工

    公开(公告)号:US09178935B2

    公开(公告)日:2015-11-03

    申请号:US12718934

    申请日:2010-03-05

    IPC分类号: G06F15/16 H04L29/08

    摘要: A method and system for forming hybrid cluster to process log files are described. In example embodiments, a method configures a node to execute as a first slave node. The first slave node executes in a first operating environment. The method also adds the first slave node to a Hadoop cluster. The Hadoop cluster includes a second slave node that operates in a second and different operating environment.

    摘要翻译: 描述用于形成混合群集以处理日志文件的方法和系统。 在示例实施例中,一种方法将节点配置为作为第一从节点执行。 第一个从节点在第一个操作环境中执行。 该方法还将第一个从节点添加到Hadoop集群。 Hadoop集群包括在第二和不同的操作环境中操作的第二从属节点。

    Analyzing event streams of user sessions
    10.
    发明授权
    Analyzing event streams of user sessions 有权
    分析用户会话的事件流

    公开(公告)号:US09063979B2

    公开(公告)日:2015-06-23

    申请号:US12263382

    申请日:2008-10-31

    IPC分类号: G06F17/30

    摘要: In various exemplary embodiments, a system and method is disclosed to analyze event streams of a user session. One embodiment of the method includes logging a plurality of events from an event stream, specifying conditions to sort the plurality of events, applying the conditions to the plurality of events, producing a probability distribution of event nodes after a given node in the event stream, and producing an interactive graphical reduction of a produced graph by determining patterns in a graphical tree and unifying occurrences of the patterns.

    摘要翻译: 在各种示例性实施例中,公开了分析用户会话的事件流的系统和方法。 该方法的一个实施例包括从事件流记录多个事件,指定对多个事件进行排序的条件,将条件应用于多个事件,产生事件流中的给定节点之后的事件节点的概率分布, 以及通过确定图形树中的模式并统一模式的出现来产生生成的图形的交互式图形缩小。