-
公开(公告)号：US20160248693A1
公开(公告)日：2016-08-25
申请号：US15145140
申请日：2016-05-03
Applicant: SAS Institute Inc.
Inventor： Michael Thomas , Gerald Donald Baulier
IPC: H04L12/911 , G06F3/06
CPC classification number: H04L67/2852 , G06F3/0608 , G06F3/0619 , G06F3/0661 , G06F3/067 , G06F9/5027 , G06F9/544 , H04L41/509 , H04L47/70 , H04L47/827 , H04L69/03
Abstract: A computer-readable medium is provided that causes a computing device to serve data resources. A received block is compressed with previously compressed blocks to create a new compressed block stored in a pre-allocated block of memory. A reference to the selected pre-allocated block of memory is stored in a tree map using a unique identifier. A second block is received. The pre-allocated block of memory is identified from the tree map using the unique identifier. The received block and at least one of the previously compressed blocks is read from the block of memory. The received second block is compressed with the at least one of the one or more previously compressed blocks to create a second new compressed block stored in the selected second pre-allocated block of memory. A reference to the selected second pre-allocated block of memory is stored in the tree map based on the unique identifier.
Abstract translation: 提供了一种使计算设备提供数据资源的计算机可读介质。 接收的块用先前压缩的块压缩以创建存储在预先分配的存储块中的新的压缩块。 对所选择的预先分配的存储块的引用使用唯一标识符存储在树形图中。 接收到第二个块。 使用唯一标识符从树形图中识别预先分配的存储块。 从存储器块读取所接收的块和至少一个先前压缩的块。 所接收的第二块被一个或多个先前压缩的块中的至少一个压缩，以产生存储在所选择的第二预先分配的存储块中的第二新的压缩块。 基于唯一标识符，将所选择的第二预分配存储块的引用存储在树形图中。
-
公开(公告)号：US09722862B2
公开(公告)日：2017-08-01
申请号：US14806750
申请日：2015-07-23
Applicant: SAS Institute Inc.
Inventor： Gerald Donald Baulier , Vincent L. Deters , Scott J. Kolodzieski
CPC classification number: H04L41/0663 , G06F9/542 , G06F11/2007 , G06F11/2028 , G06F11/2041 , G06F2201/85 , H04L51/18
Abstract: In a system, a first status of a first ESP engine (ESPE) executing at a first computing device is determined as newly active; a last published event block object identifier is determined as an identifier uniquely identifying a last event block object published to an out-messaging network device; a next event block object having an event block object identifier greater than the determined last published event block object identifier is selected from a first computer-readable medium; and the selected next event block object is published to the out-messaging network device. A first event block object is received from a second ESPE executing at a second computing device. A first status of the second ESPE is determined as standby by the second computing device. The received first event block object is stored by the second computing device in a second non-transitory computer-readable medium.
-
3.发明授权公开(公告)号：US09122651B1
公开(公告)日：2015-09-01
申请号：US14662528
申请日：2015-03-19
Applicant: SAS Institute Inc.
Inventor： Gerald Donald Baulier , Vincent L. Deters , Scott J. Kolodzieski
CPC classification number: H04L41/0663 , G06F9/542 , G06F11/2007 , G06F11/2028 , G06F11/2041 , G06F2201/85 , H04L51/18
Abstract: In a computing device supporting a failover in an event stream processing (ESP) system, an event block object is received. A first status of the computing device as active or standby is determined. When the first status is active, a second status of the computing device as newly active or not newly active is determined. Newly active is determined when the computing device is switched from a standby to an active status. When the second status is newly active, a last published event block object identifier that uniquely identifies a last published event block object is determined. A next event block object is selected from a non-transitory computer-readable medium accessible by the computing device. The next event block object has an event block object identifier that is greater than the determined last published event block object identifier. The selected next event block object is published to an out-messaging network device.
Abstract translation: 在支持事件流处理（ESP）系统中的故障转移的计算设备中，接收事件块对象。 确定计算设备作为活动或待机的第一状态。 当第一状态为活动状态时，确定计算设备的第二状态为新活动或新活动。 当计算设备从待机切换到活动状态时，确定新活动。 当第二状态为新活动时，确定唯一地标识最后发布的事件块对象的最后发布的事件块对象标识符。 从计算设备可访问的非暂时计算机可读介质中选择下一个事件块对象。 下一个事件块对象具有大于所确定的最后发布的事件块对象标识符的事件块对象标识符。 所选择的下一个事件块对象被发布到外发消息网络设备。
-
公开(公告)号：US10102028B2
公开(公告)日：2018-10-16
申请号：US13958096
申请日：2013-08-02
Applicant: SAS Institute Inc.
Inventor： Gerald Donald Baulier , Scott J. Kolodzieski , Vincent L. Deters
Abstract: A method of acknowledging receipt of an event block object is provided. First connection information for connecting to an event stream processing (ESP) engine executing at a first computing device is received. A first connection to the ESP engine is established using the received first connection information. Second connection information for connecting to a publishing client executing at a second computing device is received. A second connection to the publishing client is established using the received second connection information, wherein the first connection differs from the second connection. An event block object is received from the ESP engine using the established first connection, wherein the event block object includes a unique identifier for the event block object. Successful processing of the event block object is determined. Responsive to the successful processing determination, an acknowledgment message including the unique identifier is sent to the publishing client using the established second connection.
-
公开(公告)号：US20160006673A1
公开(公告)日：2016-01-07
申请号：US14790563
申请日：2015-07-02
Applicant: SAS Institute Inc.
Inventor： Michael Thomas , Gerald Donald Baulier
IPC: H04L12/911 , G06F9/50
CPC classification number: H04L67/2852 , G06F3/0608 , G06F3/0619 , G06F3/0661 , G06F3/067 , G06F9/5027 , G06F9/544 , H04L41/509 , H04L47/70 , H04L47/827 , H04L69/03
Abstract: A computer-readable medium is provided that causes a computing device to serve data resources. A nozzle is instantiated for a resource based on a media type associated with both the nozzle and the resource and starts a subscriber thread and a rendering thread. The subscriber thread receives a block of streamed data from a publishing device, stores the block in a queue, and receives a request to drain the queue. The block includes a unique identifier of an event associated with the media type. The rendering thread reads the block from the queue, renders the block, and stores the rendered block in a pre-allocated block of memory based on the unique identifier. A reference to the pre-allocated block of memory is stored in a tree map based on the unique identifier. The instantiated nozzle sends the rendered block to a requesting event client system.
Abstract translation: 提供了一种使计算设备提供数据资源的计算机可读介质。 基于与喷嘴和资源两者相关联的媒体类型为资源实例化喷嘴，并启动订阅者线程和呈现线程。 订户线程从发布设备接收流数据块，将该块存储在队列中，并接收到排除队列的请求。 该块包括与媒体类型相关联的事件的唯一标识符。 渲染线程从队列中读取块，呈现块，并基于唯一标识符将渲染块存储在预先分配的存储块中。 基于唯一标识符，将预先分配的存储块的引用存储在树形图中。 实例化的喷嘴将渲染的块发送到请求的事件客户端系统。
-
Patent Agency Ranking
公开(公告)号：US20140280986A1
公开(公告)日：2014-09-18
申请号：US13958096
申请日：2013-08-02
Applicant: SAS Institute Inc.
Inventor： Gerald Donald Baulier , Scott J. Kolodzieski , Vincent L. Deters
IPC: H04L29/08
Abstract: A method of acknowledging receipt of an event block object is provided. First connection information for connecting to an event stream processing (ESP) engine executing at a first computing device is received. A first connection to the ESP engine is established using the received first connection information. Second connection information for connecting to a publishing client executing at a second computing device is received. A second connection to the publishing client is established using the received second connection information, wherein the first connection differs from the second connection. An event block object is received from the ESP engine using the established first connection, wherein the event block object includes a unique identifier for the event block object. Successful processing of the event block object is determined. Responsive to the successful processing determination, an acknowledgment message including the unique identifier is sent to the publishing client using the established second connection.
Abstract translation: 提供了确认事件块对象的接收的方法。 接收用于连接到在第一计算装置执行的事件流处理（ESP）引擎的第一连接信息。 使用接收到的第一连接信息建立到ESP引擎的第一连接。 接收用于连接到在第二计算设备执行的发布客户端的第二连接信息。 使用所接收的第二连接信息建立与发布客户端的第二连接，其中第一连接与第二连接不同。 使用建立的第一连接从ESP引擎接收事件块对象，其中事件块对象包括事件块对象的唯一标识符。 确定事件块对象的成功处理。 响应于成功的处理确定，使用建立的第二连接将包括唯一标识符的确认消息发送到发布客户端。
-
公开(公告)号：US10157213B1
公开(公告)日：2018-12-18
申请号：US15813989
申请日：2017-11-15
Applicant: SAS Institute Inc.
Inventor： Markel Sanz Ausin , Shunping Huang , Gerald Donald Baulier
Abstract: A data streaming environment provides a summary of streaming data. An input interface receives streaming data from a sensor or an input device. The input device includes a user interface. The sensor is an Internet of Things (IOT) device. A processor is communicatively coupled to the input interface for processing the streaming data. A histogram update application is executed with the received data to provide a limited-size summary of the streaming data by fading outdated data by storing distance data and bin data. The processed data includes a plurality of records and variables that describe a characteristic of a physical object. An output interface is communicatively coupled to the processor to provide the processed data to be visually presented in one or more data graphs on a display device.
-
公开(公告)号：US09654586B2
公开(公告)日：2017-05-16
申请号：US15145140
申请日：2016-05-03
Applicant: SAS Institute Inc.
Inventor： Michael Thomas , Gerald Donald Baulier
CPC classification number: H04L67/2852 , G06F3/0608 , G06F3/0619 , G06F3/0661 , G06F3/067 , G06F9/5027 , G06F9/544 , H04L41/509 , H04L47/70 , H04L47/827 , H04L69/03
Abstract: A computing device is provided that supports receipt and processing of blocks of streamed data associated with an event and provision of pre-rendered and compressed events to event client systems with a high-throughput. The computing device includes a compression optimizer module that determines how to make new compressed blocks of the right level of compression as the blocks of streamed data are received from an event publishing system. The compression optimizer module utilizes a tree map and unique identifiers to selectively compress, read, and recompress the blocks of streamed data associated with each event. To prevent duplicate work in compressing the streamed data, compressed blocks are re-used where possible to support requests from the event client systems. Each new block includes a unique identifier defined by the event publishing system that generated the event, so that a previous version of the event in a compressed block can be replaced.
-
公开(公告)号：US09369406B2
公开(公告)日：2016-06-14
申请号：US14790563
申请日：2015-07-02
Applicant: SAS Institute Inc.
Inventor： Michael Thomas , Gerald Donald Baulier
IPC: H04L12/911 , G06F9/50
CPC classification number: H04L67/2852 , G06F3/0608 , G06F3/0619 , G06F3/0661 , G06F3/067 , G06F9/5027 , G06F9/544 , H04L41/509 , H04L47/70 , H04L47/827 , H04L69/03
Abstract: A computer-readable medium is provided that causes a computing device to serve data resources. A nozzle is instantiated for a resource based on a media type associated with both the nozzle and the resource and starts a subscriber thread and a rendering thread. The subscriber thread receives a block of streamed data from a publishing device, stores the block in a queue, and receives a request to drain the queue. The block includes a unique identifier of an event associated with the media type. The rendering thread reads the block from the queue, renders the block, and stores the rendered block in a pre-allocated block of memory based on the unique identifier. A reference to the pre-allocated block of memory is stored in a tree map based on the unique identifier. The instantiated nozzle sends the rendered block to a requesting event client system.
Abstract translation: 提供了一种使计算设备提供数据资源的计算机可读介质。 基于与喷嘴和资源两者相关联的介质类型为资源实例化喷嘴，并启动订户线程和呈现线程。 订户线程从发布设备接收流数据块，将该块存储在队列中，并接收到排除队列的请求。 该块包括与媒体类型相关联的事件的唯一标识符。 渲染线程从队列中读取块，呈现块，并基于唯一标识符将渲染块存储在预先分配的存储块中。 基于唯一标识符，将预先分配的存储块的引用存储在树形图中。 实例化的喷嘴将渲染的块发送到请求的事件客户端系统。
-
10.发明申请公开(公告)号：US20150358196A1
公开(公告)日：2015-12-10
申请号：US14806750
申请日：2015-07-23
Applicant: SAS Institute Inc.
Inventor： Gerald Donald Baulier , Vincent L. Deters , Scott J. Kolodzieski
CPC classification number: H04L41/0663 , G06F9/542 , G06F11/2007 , G06F11/2028 , G06F11/2041 , G06F2201/85 , H04L51/18
Abstract: In a system, a first status of a first ESP engine (ESPE) executing at a first computing device is determined as newly active; a last published event block object identifier is determined as an identifier uniquely identifying a last event block object published to an out-messaging network device; a next event block object having an event block object identifier greater than the determined last published event block object identifier is selected from a first computer-readable medium; and the selected next event block object is published to the out-messaging network device. A first event block object is received from a second ESPE executing at a second computing device. A first status of the second ESPE is determined as standby by the second computing device. The received first event block object is stored by the second computing device in a second non-transitory computer-readable medium.
Abstract translation: 在系统中，在第一计算设备处执行的第一ESP引擎（ESPE）的第一状态被确定为新活动的; 确定最后发布的事件块对象标识符作为唯一地标识发布到外发消息传递网络设备的最后事件块对象的标识符; 从第一计算机可读介质中选择具有大于所确定的最后发布的事件块对象标识符的事件块对象标识符的下一个事件块对象; 并且所选择的下一个事件块对象被发布到外发消息网络设备。 从在第二计算设备处执行的第二ESPE接收第一事件块对象。 第二ESPE的第一状态被第二计算设备确定为待机。 所接收的第一事件块对象由第二计算设备存储在第二非暂时计算机可读介质中。
-
-
-
-
-
-
-
-
-
Search Results
10
records
(took 0.018 seconds)
