Search

Yingwu Zhao Phones & Addresses

  • 1017 2Nd St APT 3, Lafayette, CA 94549
  • Austin, TX

Publications

Us Patents

Optimal Strategy For Data Replay In A Complex Multiplexing Network

View page
US Patent:
20190166177, May 30, 2019
Filed:
Nov 30, 2017
Appl. No.:
15/827998
Inventors:
- San Francisco CA, US
Yingwu Zhao - Lafayette CA, US
Assignee:
salesforce.com, inc. - San Francisco CA
International Classification:
H04L 29/06
G06F 12/0811
H04L 5/02
H04W 4/00
G06F 17/30
Abstract:
The technology disclosed relates to accelerating replay access to numerous streams via a channel aggregation hierarchy, muxing events from input buffers that receive event streams, into a physically aggregated stream in memory. A subscriber accesses events from the streams via the channel hierarchy; demuxing the physical aggregated stream and caching the events from the physical aggregated stream into event cache memory; caching references to selected events, which belong to active channels that have subscribers, in a caching structure including channel cache lists of the references, the caching structure including stream level channel cache lists, intermediate level channel cache lists, and, if the physical aggregate channel has subscribers, a physical aggregate channel cache list; and receiving a replay access request that specifies a channel and that specifies a starting point for the replay, and responsively delivering events from the event cache memory using a cache list corresponding to the specified channel.

Techniques And Architectures For Non-Blocking Parallel Batching

View page
US Patent:
20180039513, Feb 8, 2018
Filed:
Aug 2, 2016
Appl. No.:
15/226685
Inventors:
- San Francisco CA, US
Yingwu Zhao - Lafayette CA, US
International Classification:
G06F 9/48
G06F 9/54
Abstract:
In an event-based data management system, an event having an associated identifier is received. A mapping operation is performed using the identifier to map the event to a selected one of a plurality of topic partitions. Queues for each of the plurality of topic partitions are managed. The queues for each of the plurality of topic partitions are managed independently of each other. The event is allocated to the selected topic partition based on the mapping operation. The event is placed into the queue for the selected topic partition. A batch of events is sent from the queue for the selected topic partition in response to one or more thresholds being reached.

Cache Based Efficient Access Scheduling For Super Scaled Stream Processing Systems

View page
US Patent:
20170242889, Aug 24, 2017
Filed:
Feb 24, 2016
Appl. No.:
15/052806
Inventors:
- San Francisco CA, US
Yingwu ZHAO - Lafayette CA, US
Assignee:
salesforce.com, inc. - San Francisco CA
International Classification:
G06F 17/30
Abstract:
The technology disclosed relates to discovering a previously unknown attribute of stream processing systems according to which client offsets or client subscription queries for a streaming data store rapidly converge to a dynamic tip of a data stream that includes the most recent messages or events. In particular, it relates to grouping clients into bins to reduce a number of queries to the streaming data store by several orders of magnitude when servicing tens, hundreds, thousands or millions of clients. The bin count is further reduced by coalescing bins that have overlapping offsets. It also relates to establishing separate caches only for the current tips of data streams and serving the bins from the caches instead of the backend data store using group queries. Further, the caches are periodically updated to include the most recent messages or events appended to the dynamic tips of the data streams.
Yingwu Zhao from Lafayette, CA, age ~41 Get Report