公开(公告)号：US10275281B2

公开(公告)日：2019-04-30

申请号：US15281559

申请日：2016-09-30

Applicant: salesforce.com, inc.

Inventor： Aakash Pradeep ,  Abhishek Sreenivasa ,  Adam Torman ,  Alex Warshavsky ,  Samarpan Jain ,  Soumen Bandyopadhyay

IPC: G06F9/46 ,  G06F9/48 ,  G06F16/16

Abstract: Disclosed are some examples of systems, methods, apparatus and computer program products for scheduling jobs to process log files. In some implementations, a scheduler can be configured to identify a final state of a previously scheduled first job as a failure in execution by one or more processors. For instance, the first job may have been defined to process a first input log file saved to a database during a first timeframe of a sequence of timeframes of a designated interval. The scheduler can detect a second input log file saved to the database. The scheduler can then define a second job to process the first input log file and the second input log file and schedule the second job in association with a second timeframe of the sequence.

公开(公告)号：US20170060741A1

公开(公告)日：2017-03-02

申请号：US15236195

申请日：2016-08-12

Applicant: salesforce.com, inc.

Inventor： Aakash Pradeep ,  Adam Torman ,  Alex Warshavsky ,  Samarpan Jain ,  Soumen Bandyopadhyay ,  Thomas William D'Silva ,  Abhishek Bangalore Sreenivasa

IPC: G06F12/0804 ,  G06F9/54

CPC classification number: G06F12/0804 ,  G06F5/14 ,  G06F9/542 ,  G06F9/544 ,  G06F2205/126 ,  G06F2212/1041 ,  G06F2212/281 ,  G06F2212/311 ,  H04L67/28

Abstract: A capture service running on an application server receives events from a client application running on an application server to be stored in a data store and stores the events in an in-memory bounded buffer on the application server, the in-memory bounded buffer comprising a plurality of single-threaded segments, the capture service to write events to each segment in parallel. The in-memory bounded buffer provides a notification to a buffer flush regulator when a number of events stored in the in-memory bounded buffer reaches a predefined limit. The in-memory bounded buffer receive a request to flush the events in the in-memory bounded buffer from a consumer executor service. The consumer executor service consumes the events in the in-memory bounded buffer using a dynamically sized thread pool of consumer threads to read the segments of the bounded buffer in parallel, wherein consuming the events comprises writing the events directly to the data store.

Abstract translation: 在应用服务器上运行的捕获服务从在应用服务器上运行的客户端应用程序接收要存储在数据存储中的事件，并将事件存储在应用服务器上的内存有界缓冲区中，内存有界缓冲区包括 多个单线程段，捕获服务将事件并行写入每个段。 当存储在内存有界缓冲区中的多个事件达到预定义的限制时，内存有界缓冲区向缓冲区清除调节器提供通知。 内存有界缓冲区接收到从消费者执行器服务刷新内存有界缓冲区中的事件的请求。 消费者执行器服务使用动态大小的消费者线程的线程池来消耗内存有界缓冲器中的事件，以并行读取有界缓冲器的片段，其中消耗事件包括将事件直接写入数据存储器。

公开(公告)号：US10339126B2

公开(公告)日：2019-07-02

申请号：US14717848

申请日：2015-05-20

Applicant: salesforce.com, inc.

Inventor： Aakash Pradeep ,  Adam Torman ,  Alex Warshavsky ,  Derrill Dabkoski ,  Samarpan Jain ,  Soumen Bandyopadhyay ,  Thomas William D'Silva

IPC: G06F16/00 ,  G06F16/23 ,  G06Q30/02

Abstract: Disclosed are some examples of database systems, methods, and computer program products for processing log files. In some implementations, a server of a database system accesses a log file having a release version. The log file includes data entries identifying system events corresponding to user activity. The server generates or updates, based on the release version of the log file, a metadata file indicating approved entry types and approved data. The server also generates or updates, based on the log file and the metadata file, customer-facing log files. Each customer-facing log file is associated with a corresponding customer entity capable of being serviced by the database system. Each customer-facing log file includes a subset of the entries and a subset of the data items of at least one of the entries.

公开(公告)号：US09767040B2

公开(公告)日：2017-09-19

申请号：US14841503

申请日：2015-08-31

Applicant: SALESFORCE.COM, INC.

Inventor： Aakash Pradeep ,  Adam Torman ,  Samarpan Jain ,  Alex Warshavsky

IPC: G06F12/12 ,  G06F12/02

CPC classification number: G06F12/12 ,  G06F9/5077 ,  G06F9/5088 ,  G06F12/023 ,  G06F2212/1044

Abstract: In an example, a processing system of a database system may categorize event data taken from logged interactions of users with a multi-tenant information system to provide a metric. Event roll-up aggregate metrics used to provide the metric may be generated in connection with event capture. The processing system of the database system may periodically calculate the metric for a particular one of the tenants, and electronically store the periodically calculated metrics for accessing responsive to a query of the particular tenant.

公开(公告)号：US09767022B2

公开(公告)日：2017-09-19

申请号：US15236195

申请日：2016-08-12

Applicant: salesforce.com, inc.

Inventor： Aakash Pradeep ,  Adam Torman ,  Alex Warshavsky ,  Samarpan Jain ,  Soumen Bandyopadhyay ,  Thomas William D'Silva ,  Abhishek Bangalore Sreenivasa

IPC: G06F12/08 ,  G06F5/14 ,  G06F12/0804 ,  H04L29/08 ,  G06F9/54

CPC classification number: G06F12/0804 ,  G06F5/14 ,  G06F9/542 ,  G06F9/544 ,  G06F2205/126 ,  G06F2212/1041 ,  G06F2212/281 ,  G06F2212/311 ,  H04L67/28

Abstract: A capture service running on an application server receives events from a client application running on an application server to be stored in a data store and stores the events in an in-memory bounded buffer on the application server, the in-memory bounded buffer comprising a plurality of single-threaded segments, the capture service to write events to each segment in parallel. The in-memory bounded buffer provides a notification to a buffer flush regulator when a number of events stored in the in-memory bounded buffer reaches a predefined limit. The in-memory bounded buffer receive a request to flush the events in the in-memory bounded buffer from a consumer executor service. The consumer executor service consumes the events in the in-memory bounded buffer using a dynamically sized thread pool of consumer threads to read the segments of the bounded buffer in parallel, wherein consuming the events comprises writing the events directly to the data store.

公开(公告)号：US20160078120A1

公开(公告)日：2016-03-17

申请号：US14688989

申请日：2015-04-16

Applicant: salesforce.com, inc.

Inventor： Aakash Pradeep ,  Adam Torman ,  Alex Warshavsky ,  Samarpan Jain ,  Soumen Bandyopadhyay ,  Thomas William D'Silva

IPC: G06F17/30

CPC classification number: H04L67/10 ,  G06F11/00 ,  G06F11/3006 ,  G06F11/3438 ,  G06F11/3452 ,  G06F11/3476 ,  G06F16/173 ,  G06F16/2428 ,  G06F2201/80 ,  G06F2201/86 ,  H04L67/02

Abstract: In an example, a processing system of a database system may categorize event data taken from logged interactions of users with a multi-tenant information system to provide a metric. The processing system of the database system may periodically calculate the metric for a particular one of the tenants, and electronically store the periodically calculated metrics for accessing responsive to a query of the particular tenant.

Abstract translation: 在一个示例中，数据库系统的处理系统可以将从用户的记录交互获取的事件数据与多租户信息系统分类以提供度量。 数据库系统的处理系统可以周期性地计算特定租户的度量，并且电子地存储响应于特定租户的查询的周期性计算的用于访问的度量。

公开(公告)号：US20190236169A1

公开(公告)日：2019-08-01

申请号：US15885489

申请日：2018-01-31

Applicant: salesforce.com, inc.

Inventor： Gopi Krishnan Nambiar ,  Siddhi Mehta ,  Aakash Pradeep ,  Shangkar Meitei Mayanglambam

IPC: G06F17/30

CPC classification number: G06F16/211 ,  G06F16/182 ,  G06F16/221 ,  G06F16/2445 ,  G06F16/27

Abstract: Systems and methods are described for registering a new column in an existing table on a distributed file system as a partition. In response to receiving a request to add a new column to a selected table, a new table may be created that includes all fields of the selected table, the new column, and a new partition, and the selected table may be renamed within the distributed file system. A view may then be created that points to data in the new table and the renamed selected table, the created view being a virtual table that receives and processes queries. All data from the renamed selected table may be transferred the new table. When the transfer is complete, the new table may be renamed to an original name of the selected table, and any data received after the renaming may be included in the renamed new table.

公开(公告)号：US20170168880A1

公开(公告)日：2017-06-15

申请号：US15443219

申请日：2017-02-27

Applicant: salesforce.com, inc.

Inventor： Aakash Pradeep ,  Adam Torman ,  Alex Warshavsky ,  Samarpan Jain

IPC: G06F9/54 ,  H04L29/06 ,  H04L29/08 ,  G06F17/30 ,  G06F3/06

CPC classification number: G06F9/542 ,  G06F3/061 ,  G06F3/0619 ,  G06F3/0643 ,  G06F3/0656 ,  G06F3/067 ,  G06F17/30091 ,  G06F17/30115 ,  G06F17/30203 ,  G06F17/30876 ,  H04L47/50 ,  H04L67/02 ,  H04L67/06 ,  H04L67/1004 ,  H04L67/2842 ,  H04L67/42

Abstract: Computer-implemented methods and systems are provided for writing events to a data store. An application server generates events, the data store that stores the events, and a temporary events file storage system (TEFSS) temporarily stores groups of events as events files. When events are unable to be written directly to the data store, an indirect events writer is invoked that includes event capture threads each being configured to generate a particular events file, and write it to the TEFSS. Each events file includes a plurality of events flushed from an in-memory buffer service. An events file uploader service reads the events file(s) from the TEFSS, and then writes the events from each of the events files to the data store.

公开(公告)号：US09658801B2

公开(公告)日：2017-05-23

申请号：US14976125

申请日：2015-12-21

Applicant: salesforce.com, inc.

Inventor： Aakash Pradeep ,  Adam Torman ,  Alex Warshavsky ,  Samarpan Jain

IPC: G06F3/00 ,  G06F9/44 ,  G06F9/46 ,  G06F13/00 ,  G06F3/06 ,  H04L29/08

CPC classification number: G06F9/542 ,  G06F3/061 ,  G06F3/0619 ,  G06F3/0643 ,  G06F3/0656 ,  G06F3/067 ,  G06F17/30091 ,  G06F17/30115 ,  G06F17/30203 ,  G06F17/30876 ,  H04L47/50 ,  H04L67/02 ,  H04L67/06 ,  H04L67/1004 ,  H04L67/2842 ,  H04L67/42

Abstract: Computer-implemented methods and systems are provided. The system includes a data store that is configured to store events in an event table, a temporary events file storage system (TEFSS), and a cluster of application servers. The cluster includes a first application server that generates events, and a second application server that includes an events file uploader service. When the first application server is unable to directly write events to the data store, an indirect events writer generates events file(s), and writes the events file(s) to the TEFSS. Each events file includes a plurality of events flushed from an in-memory buffer service at the first application server. When the events file uploader service determines that the first application server is inactive, it reads the events file(s) from the TEFSS, and writes the events from each of the events files to the data store.

公开(公告)号：US20170075922A1

公开(公告)日：2017-03-16

申请号：US15097090

申请日：2016-04-12

Applicant: salesforce.com, inc.

Inventor： Adam Torman ,  Ivan Daya Weiss ,  Aakash Pradeep ,  Abhishek Bangalore Sreenivasa ,  Alex Warshavsky ,  Soumen Bandyopadhyay ,  Choapet Oravivattanakul ,  Samarpan Jain

IPC: G06F17/30

CPC classification number: G06F16/1805 ,  G06F16/164 ,  G06F16/2358

Abstract: Disclosed are some examples of database systems, methods, and computer program products for processing log files. In some implementations, a server of a database system accesses a metadata file indicating algorithms that can be applied to data of log files. The server generates customer-facing log files using the log file and metadata file. The customer-facing log files include new data derived from using the algorithms and the data of the log files.

Abstract translation: 公开了用于处理日志文件的数据库系统，方法和计算机程序产品的一些示例。 在一些实现中，数据库系统的服务器访问指示可应用于日志文件的数据的算法的元数据文件。 服务器使用日志文件和元数据文件生成面向客户的日志文件。 面向客户的日志文件包括从使用算法和日志文件的数据导出的新数据。