DYNAMIC PARTITIONING TECHNIQUES FOR DATA STREAMS

    公开(公告)号:US20170357703A1

    公开(公告)日:2017-12-14

    申请号:US15665103

    申请日:2017-07-31

    Abstract: A partitioning policy, comprising an indication of an initial mapping of data records of a stream to a plurality of partitions, is selected to distribute data records of a data stream among a plurality of nodes of a stream management service. Data ingestion nodes and storage nodes are configured according to the initial mapping. In response to a determination that a triggering criterion for dynamically repartitioning the data stream has been met, a modified mapping is generated, and a different set of ingestion and storage nodes are configured. For at least some time during which arriving data records are stored in accordance with the modified mapping, data records stored at the first set of storage nodes in accordance with the initial mapping are retained.

    Data stream ingestion and persistence techniques

    公开(公告)号:US09858322B2

    公开(公告)日:2018-01-02

    申请号:US14077162

    申请日:2013-11-11

    CPC classification number: G06F17/30563 G06F17/30073

    Abstract: A programmatic interface is implemented, enabling a client of a stream management service to select a data ingestion policy for a data stream. A client request selecting an at-least-once ingestion policy is received. In accordance with the at-least-once policy, a client may transmit an indication of a data record one or more times to the service until a positive acknowledgement is received. In response to receiving a plurality of transmissions indicating a particular data record, respective positive acknowledgements are sent to the client. Based on a persistence policy selected for the stream, copies of the data record are stored at one or more storage locations in response to one particular transmission of the plurality of transmissions.

    Data stream ingestion and persistence techniques

    公开(公告)号:US10795905B2

    公开(公告)日:2020-10-06

    申请号:US15858480

    申请日:2017-12-29

    Abstract: A programmatic interface is implemented, enabling a client of a stream management service to select a data ingestion policy for a data stream. A client request selecting an at-least-once ingestion policy is received. In accordance with the at-least-once policy, a client may transmit an indication of a data record one or more times to the service until a positive acknowledgement is received. In response to receiving a plurality of transmissions indicating a particular data record, respective positive acknowledgements are sent to the client. Based on a persistence policy selected for the stream, copies of the data record are stored at one or more storage locations in response to one particular transmission of the plurality of transmissions.

    DATA STREAM INGESTION AND PERSISTENCE TECHNIQUES

    公开(公告)号:US20180189367A1

    公开(公告)日:2018-07-05

    申请号:US15858480

    申请日:2017-12-29

    CPC classification number: G06F16/254 G06F16/113

    Abstract: A programmatic interface is implemented, enabling a client of a stream management service to select a data ingestion policy for a data stream. A client request selecting an at-least-once ingestion policy is received. In accordance with the at-least-once policy, a client may transmit an indication of a data record one or more times to the service until a positive acknowledgement is received. In response to receiving a plurality of transmissions indicating a particular data record, respective positive acknowledgements are sent to the client. Based on a persistence policy selected for the stream, copies of the data record are stored at one or more storage locations in response to one particular transmission of the plurality of transmissions.

    Multitenant monitoring system storing monitoring data supporting flexible pivot querying
    7.
    发明授权
    Multitenant monitoring system storing monitoring data supporting flexible pivot querying 有权
    多重监控系统存储监控数据,支持灵活的查询

    公开(公告)号:US09104392B1

    公开(公告)日:2015-08-11

    申请号:US13917595

    申请日:2013-06-13

    CPC classification number: G06F17/30528

    Abstract: Monitoring data can be received and managed in a multi-tenant environment. Monitoring data can be received for multiple tenants. The received monitoring data can be sorted. Sorting can be performed based on various criteria, such as by tenant. The sorted monitoring data can be written to data files. Each data file can store monitoring data for a plurality of tenants. Receiving, sorting, and writing monitoring data can be performed within a multi-tenant monitoring system.

    Abstract translation: 监控数据可以在多租户环境中接收和管理。 可以为多个租户收到监控数据。 收到的监控数据可以进行排序。 可以根据各种标准进行排序,例如租户。 排序的监视数据可以写入数据文件。 每个数据文件可以存储多个租户的监视数据。 接收,分拣和写入监控数据可以在多租户监控系统内进行。

    Dynamic partitioning techniques for data streams

    公开(公告)号:US10691716B2

    公开(公告)日:2020-06-23

    申请号:US15665103

    申请日:2017-07-31

    Abstract: A partitioning policy, comprising an indication of an initial mapping of data records of a stream to a plurality of partitions, is selected to distribute data records of a data stream among a plurality of nodes of a stream management service. Data ingestion nodes and storage nodes are configured according to the initial mapping. In response to a determination that a triggering criterion for dynamically repartitioning the data stream has been met, a modified mapping is generated, and a different set of ingestion and storage nodes are configured. For at least some time during which arriving data records are stored in accordance with the modified mapping, data records stored at the first set of storage nodes in accordance with the initial mapping are retained.

    Dynamic partitioning techniques for data streams

    公开(公告)号:US09720989B2

    公开(公告)日:2017-08-01

    申请号:US14077171

    申请日:2013-11-11

    CPC classification number: G06F17/30569 G06F17/30

    Abstract: A partitioning policy, comprising an indication of an initial mapping of data records of a stream to a plurality of partitions, is selected to distribute data records of a data stream among a plurality of nodes of a stream management service. Data ingestion nodes and storage nodes are configured according to the initial mapping. In response to a determination that a triggering criterion for dynamically repartitioning the data stream has been met, a modified mapping is generated, and a different set of ingestion and storage nodes are configured. For at least some time during which arriving data records are stored in accordance with the modified mapping, data records stored at the first set of storage nodes in accordance with the initial mapping are retained.

Patent Agency Ranking