-
公开(公告)号：US20230239345A1
公开(公告)日：2023-07-27
申请号：US18194583
申请日：2023-03-31
IPC分类号： H04L67/1029 , G06F16/28
CPC分类号： H04L67/1029 , G06F16/285
摘要： In response to a first programmatic request, metadata indicating that a first isolated read channel of a real-time category has been associated with a first target stream is stored at a stream management service. In response to another request, metadata indicating that a second isolated read channel of a non-real-time category has been associated with a second target stream is stored. In response to a read request indicating the first channel or the second channel, one or more data records of the corresponding target streams are provided.
-
公开(公告)号：US20210021653A1
公开(公告)日：2021-01-21
申请号：US17062435
申请日：2020-10-02
IPC分类号： H04L29/06
摘要： From a stream management service, indications of transmissions of data records of a first data stream via a persistent network connection associated with a subscription are provided to a stream processing application. In response to detecting that a transfer throttling condition associated with the subscription has been met, a delay is introduced before additional data records are transmitted via the same persistent network connection. After a subscription expiration period has elapsed, an indication of the expiration is provided to the application via the persistent connection.
-
公开(公告)号：US10956246B1
公开(公告)日：2021-03-23
申请号：US16143361
申请日：2018-09-26
发明人： Sumeetkumar Bagde , Benjamin Warren Mercier , Sayantan Chakravorty , Rohit Unnikrishnan Nair , Yasemin Avcular , Charlie Paucard
IPC分类号： G06F11/07
摘要： In response to a first programmatic request, metadata indicating that a first isolated read channel associated with a data stream has been established is stored at a stream management service. A read request that indicates the first isolated read channel and the stream is obtained. In response to the read request, contents of data records of the stream are provided.
-
公开(公告)号：US10855754B1
公开(公告)日：2020-12-01
申请号：US16143340
申请日：2018-09-26
IPC分类号： G06F15/173 , H04L29/08 , G06F16/28
摘要： In response to a first programmatic request, metadata indicating that a first isolated read channel of a real-time category has been associated with a first target stream is stored at a stream management service. In response to another request, metadata indicating that a second isolated read channel of a non-real-time category has been associated with a second target stream is stored. In response to a read request indicating the first channel or the second channel, one or more data records of the corresponding target streams are provided.
-
公开(公告)号：US10798140B1
公开(公告)日：2020-10-06
申请号：US16143344
申请日：2018-09-26
摘要： From a stream management service, indications of transmissions of data records of a first data stream via a persistent network connection associated with a subscription are provided to a stream processing application. In response to detecting that a transfer throttling condition associated with the subscription has been met, a delay is introduced before additional data records are transmitted via the same persistent network connection. After a subscription expiration period has elapsed, an indication of the expiration is provided to the application via the persistent connection.
-
公开(公告)号：US11675501B2
公开(公告)日：2023-06-13
申请号：US17013441
申请日：2020-09-04
发明人： Vasudeva Gade , Benjamin Warren Mercier , Sayantan Chakravorty , Yasemin Avcular , Charlie Paucard
IPC分类号： G06F3/06
CPC分类号： G06F3/0617 , G06F3/065 , G06F3/0644 , G06F3/0647 , G06F3/0653 , G06F3/0659 , G06F3/0673
摘要： At a data stream management service, a first set of metadata indicating that a first isolated read channel has been associated with a first data stream is stored. The first isolated read channel has an associated read performance limit setting. A second set of metadata indicating that a second isolated read channel, with its own performance limit setting, has been associated with a data stream is also stored. Based on determining that the difference between a metric of read operations associated with the first channel and the read performance limit setting of the first channel meets a first criterion, the service initiates a throttling operation for reads associated with the first channel. The throttling decision is made independently of read metrics of the second channel.
-
公开(公告)号：US11621999B2
公开(公告)日：2023-04-04
申请号：US17105287
申请日：2020-11-25
IPC分类号： G06F15/173 , H04L67/1029 , G06F16/28
摘要： In response to a first programmatic request, metadata indicating that a first isolated read channel of a real-time category has been associated with a first target stream is stored at a stream management service. In response to another request, metadata indicating that a second isolated read channel of a non-real-time category has been associated with a second target stream is stored. In response to a read request indicating the first channel or the second channel, one or more data records of the corresponding target streams are provided.
-
公开(公告)号：US10768830B1
公开(公告)日：2020-09-08
申请号：US16143341
申请日：2018-09-26
发明人： Vasudeva Gade , Benjamin Warren Mercier , Sayantan Chakravorty , Yasemin Avcular , Charlie Paucard
摘要： At a data stream management service, a first set of metadata indicating that a first isolated read channel has been associated with a first data stream is stored. The first isolated read channel has an associated read performance limit setting. A second set of metadata indicating that a second isolated read channel, with its own performance limit setting, has been associated with a data stream is also stored. Based on determining that the difference between a metric of read operations associated with the first channel and the read performance limit setting of the first channel meets a first criterion, the service initiates a throttling operation for reads associated with the first channel. The throttling decision is made independently of read metrics of the second channel.
-
公开(公告)号：US11509700B2
公开(公告)日：2022-11-22
申请号：US17062435
申请日：2020-10-02
IPC分类号： H04L65/61 , G06F3/06 , H04L67/02 , H04L67/1097 , H04L65/612 , H04L65/75 , H04L65/80 , H04L67/1095 , H04L67/55
摘要： From a stream management service, indications of transmissions of data records of a first data stream via a persistent network connection associated with a subscription are provided to a stream processing application. In response to detecting that a transfer throttling condition associated with the subscription has been met, a delay is introduced before additional data records are transmitted via the same persistent network connection. After a subscription expiration period has elapsed, an indication of the expiration is provided to the application via the persistent connection.
-
公开(公告)号：US11070600B1
公开(公告)日：2021-07-20
申请号：US16143343
申请日：2018-09-26
摘要： At a stream management service, one or more storage servers of a first repository are assigned to store at least a first partition of a first data stream. At the first repository, records of different partitions are interleaved. In response to determining that a set of data records of the first partition meet a first criterion, a rearranged version of the set in which the data records of the first partition are contiguous is stored at a second repository. Using the rearranged version, one or more records of the first partition are provided to an application which meets a lag criterion.
-
-
-
-
-
-
-
-
-
搜索结果
11 条记录 (耗时 0.014 秒)
