公开(公告)号：US08538954B2

公开(公告)日：2013-09-17

申请号：US13364155

申请日：2012-02-01

申请人： Muthian George ,  Song Wang ,  Ahmed K Ezzat

发明人： Muthian George ,  Song Wang ,  Ahmed K Ezzat

IPC分类号： G06F17/30

CPC分类号： G06F17/30486

摘要： Systems and apparatuses are provided for a distributed aggregate user defined function processing system. A non-transitory computer readable medium stores instructions for a query compiler to identify a call to a distributed aggregate user defined function within a query of the distributed analytical data processing system, retrieve metadata associated with the distributed aggregate user defined function, and validate and resolve respective inputs and outputs of a plurality of function partitions associated with the distributed aggregate user defined function according to the retrieved metadata. A distributed processing engine includes a plurality of processing nodes to execute the plurality of function partitions and organize data flow from the plurality of function partitions to produce an output for the distributed aggregate user defined function.

摘要翻译： 为分布式总体用户定义的功能处理系统提供系统和装置。 非暂时性计算机可读介质存储用于查询编译器的指令以识别对分布式分析数据处理系统的查询内的分布式聚合用户定义函数的调用，检索与分布式聚合用户定义函数相关联的元数据，以及验证和解析 根据检索到的元数据，与分布式聚合用户定义的功能相关联的多个功能分区的相应输入和输出。 分布式处理引擎包括多个处理节点，用于执行多个功能分区并组织来自多个功能分区的数据流，以产生分布式聚合用户定义功能的输出。

公开(公告)号：US20120239612A1

公开(公告)日：2012-09-20

申请号：US13485246

申请日：2012-05-31

申请人： Muthian George ,  Song Wang

发明人： Muthian George ,  Song Wang

IPC分类号： G06F17/30

CPC分类号： G06F16/254

摘要： Data loading with user defined functions is described in various implementations. An example system for data loading may include a structured query language (SQL) compiler to identify a call to a table valued user defined function (TVUDF) within a SQL statement that includes an insert statement; identify metadata associated with the TVUDF; validate and resolve a subclass type of the TVUDF based on the metadata and the insert statement; and generate a data loading plan to retrieve and load data from an external data source into a table of a database based on the subclass type of the TVUDF. The system may also include a data loading engine in the database to execute the data loading plan, the data loading plan including the TVUDF to retrieve data from the external data source, and load the retrieved data into the table of the database in accordance with the data loading plan.

摘要翻译： 在各种实现中描述了用户定义的功能的数据加载。 用于数据加载的示例系统可以包括结构化查询语言（SQL）编译器，以识别在包括插入语句的SQL语句内对表值用户定义函数（TVUDF）的调用; 识别与TVUDF相关的元数据; 基于元数据和插入语句验证并解析TVUDF的子类型; 并根据TVUDF的子类型生成数据加载计划，以从外部数据源检索数据并将数据加载到数据库的表中。 该系统还可以包括数据库中的数据加载引擎，以执行数据加载计划，数据加载计划包括TVUDF以从外部数据源检索数据，并且将检索的数据加载到数据库的表中，根据 数据加载计划

公开(公告)号：US08856151B2

公开(公告)日：2014-10-07

申请号：US13249482

申请日：2011-09-30

申请人： Muthian George

发明人： Muthian George

IPC分类号： G06F17/30

CPC分类号： G06F17/30592

摘要： Systems and apparatuses are provided for analytical data processing. A system includes a processor and a non-transitory computer readable medium, comprising machine readable instructions executable by the processor. The instructions include a query compiler to identify a call to a user defined function and an output expression defining an output field for the user defined function within a query and generate an output table object for the user defined function. The generated output table object contains the defined output field. The instructions further include a processing engine to execute the user defined function and populate the output field in rows into the output table object with the output of the user defined function.

摘要翻译： 提供系统和设备用于分析数据处理。 系统包括处理器和非暂时计算机可读介质，其包括可由处理器执行的机器可读指令。 指令包括查询编译器，用于识别对用户定义函数的调用，以及输出表达式，定义查询中用户定义函数的输出字段，并为用户定义的函数生成输出表对象。 生成的输出表对象包含定义的输出字段。 指令还包括执行用户定义的功能的处理引擎，并且使用用户定义的功能的输出将行中的输出字段填充到输出表对象中。

公开(公告)号：US20130238548A1

公开(公告)日：2013-09-12

申请号：US13885032

申请日：2011-01-25

申请人： Muthian George

发明人： Muthian George

IPC分类号： G06F17/30

CPC分类号： G06F16/2453 ,  G06F16/283

摘要： Systems and apparatuses are provided for integrating user defined functions into an analytical data processing framework. A query compiler (22) identifies a call to a user defined function (28) and one of a GROUP BY expression and a defined online analytics processing (OLAP) window associated with the user defined function. A database engine (24) executes the user defined function (28) with a partition set defined by the one of the GROUP BY expression and the defined OLAP window, such that the user defined function operates on the partition set to produce a function output.

摘要翻译： 系统和设备被提供用于将用户定义的功能集成到分析数据处理框架中。 查询编译器（22）识别对用户定义函数（28）的调用，以及与用户定义的函数相关联的GROUP BY表达式和定义的在线分析处理（OLAP）窗口之一。 数据库引擎（24）使用由GROUP BY表达式和定义的OLAP窗口中的一个定义的分区集执行用户定义的函数（28），使得用户定义的函数在分区集上操作以产生函数输出。

公开(公告)号：US09229984B2

公开(公告)日：2016-01-05

申请号：US13272598

申请日：2011-10-13

申请人： Muthian George

发明人： Muthian George

IPC分类号： G06F17/30

CPC分类号： G06F17/30471

摘要： Systems and apparatuses are provided for analytical data processing. A system includes a processor and a non-transitory computer readable medium, comprising machine readable instructions executable by the processor. The instructions include a query compiler to identify a call to a user defined function within a query. The call to a user defined function includes an input argument and a parameter expression defining a parameter value for the user defined function. A processing engine executes the user defined function to provide a function output according to the input argument and the defined parameter value.

摘要翻译： 提供系统和设备用于分析数据处理。 系统包括处理器和非暂时计算机可读介质，其包括可由处理器执行的机器可读指令。 该指令包括查询编译器，用于标识对查询中用户定义函数的调用。 对用户定义函数的调用包括输入参数和定义用户定义函数的参数值的参数表达式。 处理引擎执行用户定义的功能，以根据输入参数和定义的参数值提供功能输出。

公开(公告)号：US09355145B2

公开(公告)日：2016-05-31

申请号：US13240582

申请日：2011-09-22

申请人： Muthian George

发明人： Muthian George

IPC分类号： G06F17/30

CPC分类号： G06F17/30448 ,  G06F17/30463

摘要： Systems and apparatuses are provided for integrating user defined functions into an analytical data processing framework. The system includes a plurality of user defined functions (28), each having metadata defining an associated class type. A query compiler (22) identifies a call to a user defined function (28) within a query of an associated data table (26), retrieves the associated class type of the user defined function from the metadata, and provides a query plan according to a plurality of processing instructions derived from the retrieved class type.

摘要翻译： 系统和设备被提供用于将用户定义的功能集成到分析数据处理框架中。 该系统包括多个用户定义的功能（28），每个功能都具有定义相关类型的元数据。 查询编译器（22）识别在关联数据表（26）的查询内对用户定义函数（28）的调用，从元数据中检索用户定义函数的关联类类型，并根据 从所检索的类型导出的多个处理指令。