DATA STREAM PROCESSING BASED ON A BOUNDARY PARAMETER
    12.
    发明申请
    DATA STREAM PROCESSING BASED ON A BOUNDARY PARAMETER 审中-公开
    基于边界参数的数据流处理

    公开(公告)号:US20160253219A1

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

    申请号:US15032884

    申请日:2013-12-13

    CPC classification number: G06F9/52 G06F17/18

    Abstract: In one implementation, a system for processing a data stream can comprise a station engine, an execution engine, and a synchronize engine. A station engine can provide a stream operator to receive application logic, punctuate the data stream, and determine a number of input channels for parallel processing. The execution engine can perform a behavior of the application logic during a process operation. The synchronize engine can hold data of the data stream associated with a window until each input channel has reached a data boundary based on a boundary parameter.

    Abstract translation: 在一个实现中,用于处理数据流的系统可以包括站引擎,执行引擎和同步引擎。 站引擎可以提供流操作者来接收应用逻辑,标记数据流,并确定用于并行处理的多个输入通道。 执行引擎可以在进程操作期间执行应用程序逻辑的行为。 同步引擎可以保持与窗口相关联的数据流的数据,直到每个输入通道基于​​边界参数到达数据边界。

    DATABASE COMPARISON OPERATION TO IDENTIFY AN OBJECT

    公开(公告)号:US20180293311A1

    公开(公告)日:2018-10-11

    申请号:US15570878

    申请日:2015-05-19

    Abstract: Examples disclosed herein relate to a database comparison operation to identify an object. For example, a processor may enroll a set of object templates in a storage based on objects within input content and enroll a target object template in the storage based on a target object in target content. The processor may identify an object within the input content associated with the target object based on a database comparison operation of the stored set of object templates to the stored target object template. The processor may output object recognition information related to the identified object.

    Distributed computing in R
    14.
    发明授权

    公开(公告)号:US09992256B2

    公开(公告)日:2018-06-05

    申请号:US15230050

    申请日:2016-08-05

    CPC classification number: H04L41/14 G06F9/3017 H04L67/10

    Abstract: Examples disclosed herein relate to distributed computing in R. Some examples disclosed herein may include identifying a distributed multivariate apply (dmapply) operation and an invocation of a distributed computing backend and determining a function referenced in the dmapply operation. A distributed backend driver associated with the invoked distributed computing backend may translate the determined function to a function native to an R application programming interface (API) of the invoked distributed computing backend and may provide the translated function to the invoked distributed computing backend to perform the translated function on a distributed data set referenced in the dmapply operation.

    SINGULAR VALUE DECOMPOSITIONS
    15.
    发明申请

    公开(公告)号:US20180121527A1

    公开(公告)日:2018-05-03

    申请号:US15340218

    申请日:2016-11-01

    Abstract: In one example in accordance with the present disclosure, a system comprises a computing node. The computing node comprises: a memory, and a processor to: execute a database in the memory, and invoke, with the database, singular value decomposition (SVD) on a data set. To invoke SVD, the processor may sparsify, with the database, the data set to produce a sparse data set, iteratively decompose, with the database, the data set to produce a set of eigenvalues, solve, with the database a linear system to produce a set of eigenvectors, and multiply, with the database, the eigenvectors with the data set to produce a data set of reduced dimension.

    Parallelizing SQL user defined transformation functions

    公开(公告)号:US10885031B2

    公开(公告)日:2021-01-05

    申请号:US15114913

    申请日:2014-03-10

    Abstract: Example embodiments relate to parallelizing structured query language (SQL) user defined transformation functions. In example embodiments, a subquery of a query is received from a query engine, where each of the subqueries is associated with a distinct magic number in a magic table. A user defined transformation function that includes local, role-based functionality may then be executed, where the magic number triggers parallel execution of the user defined transformation function. At this stage, the results of the user defined transformation function are sent to the query engine, where the query engine unions the results with other results that are obtained from the other database nodes.

    BASE USER DEFINED FUNCTIONS
    19.
    发明申请

    公开(公告)号:US20180046659A1

    公开(公告)日:2018-02-15

    申请号:US15555634

    申请日:2015-03-20

    CPC classification number: G06F16/2291 G06F16/245

    Abstract: Methods, devices, and techniques for base user defined functions in a database management system are discussed herein. For example, in one aspect, a query request is received from a computer device. The query request may include a query operator representing a specialized user defined function (SUDF). The SUDF may then be executed. Executing the SUDF may include executing a base operation of a base user defined function (BUDF). The base operation may interact with an application programming interface (API) of the query engine to obtain a tuple stored in the database. Executing the SUDF may further include executing a specialized operation that processes the tuple according to an analytics function. The specialized operation may generate a result. Then, a query result may be returned to the computer device. The query result can include the result.

    ACCESSING ELECTRONIC DATABASES
    20.
    发明申请

    公开(公告)号:US20180011905A1

    公开(公告)日:2018-01-11

    申请号:US15202636

    申请日:2016-07-06

    CPC classification number: G06F16/24554 G06F16/21 G06F16/2433

    Abstract: Examples disclosed herein relate to accessing electronic databases. Some examples disclosed herein may include partitioning a computation task into subtasks. A processing node of a computation engine may generate a database query for retrieving an electronic data segment associated with at least one of the subtasks from a database. The database query may include pre-processing instructions for a database management system (DBMS) associated with the database to pre-process the electronic data segment before providing the electronic data segment to the processing node. The pre-processing instructions may include at least one of: filtering, projection, join, aggregation, count, and user-defined instructions. The generated query may be provided to the DBMS.

Patent Agency Ranking