MANAGED SERVICE FOR ACQUISITION, STORAGE AND CONSUMPTION OF LARGE-SCALE DATA STREAMS
    2.
    发明申请
    MANAGED SERVICE FOR ACQUISITION, STORAGE AND CONSUMPTION OF LARGE-SCALE DATA STREAMS 有权
    管理的大规模数据流的获取,存储和消费服务

    公开(公告)号:US20150134797A1

    公开(公告)日:2015-05-14

    申请号:US14077173

    申请日:2013-11-11

    Abstract: A control node of a multi-tenant stream management service receives a request to initialize a data stream to be comprised of a plurality of data records. The control node determines, based on a partitioning policy, parameters to be used to configure subsystems for ingestion, storage and retrieval of the records. The control node identifies resources to be used for a node of retrieval subsystem The retrieval node is configured to implement programmatic record retrieval interfaces, including respective interfaces to implement non-sequential and sequential access patterns. The control node configures the retrieval node using the selected resources.

    Abstract translation: 多租户流管理服务的控制节点接收初始化要由多个数据记录组成的数据流的请求。 控制节点基于分区策略确定要用于配置子系统以进行记录的摄取,存储和检索的参数。 控制节点识别要用于检索子系统的节点的资源。检索节点被配置为实现程序化记录检索接口,包括相应的接口以实现非顺序和顺序访问模式。 控制节点使用所选择的资源配置检索节点。

    GENERATING MESSAGE ENVELOPES FOR HETEROGENEOUS EVENTS

    公开(公告)号:US20170085512A1

    公开(公告)日:2017-03-23

    申请号:US14863349

    申请日:2015-09-23

    CPC classification number: H04L51/22 H04L51/12 H04L51/14 H04L51/26

    Abstract: Methods, systems, and computer-readable media for generating message envelopes for heterogeneous events are disclosed. A plurality of events are received. The events are associated with computing resources in a multi-tenant environment. The events comprise an event formatted using a content schema and a different event formatted using a different content schema. A message is generated comprising a message envelope and the event. The message envelope comprises a plurality of field names and one or more field values formatted using an envelope schema. A different message is generated comprising a different message envelope and the different event. The different message envelope comprises the field names and one or more different field values formatted using the envelope schema. The message is filtered based at least in part on the message envelope, and the different message is filtered based at least in part on the different message envelope.

    DYNAMIC PARTITIONING TECHNIQUES FOR DATA STREAMS
    5.
    发明申请
    DYNAMIC PARTITIONING TECHNIQUES FOR DATA STREAMS 有权
    数据流的动态分区技术

    公开(公告)号:US20150134796A1

    公开(公告)日:2015-05-14

    申请号: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.

    Abstract translation: 选择包括流到多个分区的数据记录的初始映射的指示的分区策略,以在流管理服务的多个节点之间分配数据流的数据记录。 数据摄取节点和存储节点根据初始映射进行配置。 响应于确定已经满足用于动态地重新分配数据流的触发标准,生成修改的映射,并且配置不同的摄取和存储节点。 在至少一段时间内,根据修改的映射来存储到达的数据记录,保留根据初始映射存储在第一组存储节点处的数据记录。

    DATA STREAM INGESTION AND PERSISTENCE TECHNIQUES
    7.
    发明申请
    DATA STREAM INGESTION AND PERSISTENCE TECHNIQUES 有权
    数据流入侵和持续技术

    公开(公告)号:US20150134795A1

    公开(公告)日:2015-05-14

    申请号: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.

    Abstract translation: 实现编程接口,使得流管理服务的客户端能够选择数据流的数据摄取策略。 接收到选择至少一次摄取策略的客户端请求。 根据至少一次策略,客户端可以向服务发送一次或多次数据记录的指示,直到接收到肯定的确认。 响应于接收到指示特定数据记录的多个传输,相应的肯定确认被发送给客户端。 基于为流选择的持久性策略,响应于多个传输的一个特定传输,将数据记录的副本存储在一个或多个存储位置。

    PARTITION-BASED DATA STREAM PROCESSING FRAMEWORK
    8.
    发明申请
    PARTITION-BASED DATA STREAM PROCESSING FRAMEWORK 审中-公开
    基于分区的数据流处理框架

    公开(公告)号:US20150134626A1

    公开(公告)日:2015-05-14

    申请号:US14077167

    申请日:2013-11-11

    Abstract: A control node of a multi-tenant stream processing service receives a request indicating an operation to be performed on data records of a particular data stream. Based on a stream partitioning policy, the control node determines an initial number of worker nodes to be used. The control node configures a worker node to perform the operation on received records. In response to a determination that the worker node is in an unhealthy state, the control node configures a replacement worker node.

    Abstract translation: 多租户流处理服务的控制节点接收指示对特定数据流的数据记录执行的操作的请求。 基于流分配策略,控制节点确定要使用的工作节点的初始数量。 控制节点配置工作节点对接收到的记录执行操作。 响应于确定工作节点处于不健康状态,控制节点配置替换工作者节点。

    VIBRATION CANCELLATION FOR DATA STORAGE
    10.
    发明申请
    VIBRATION CANCELLATION FOR DATA STORAGE 审中-公开
    用于数据存储的振动消除

    公开(公告)号:US20150179211A1

    公开(公告)日:2015-06-25

    申请号:US14642301

    申请日:2015-03-09

    Abstract: Methods and apparatus for vibration cancellation are disclosed. Vibration data from one or more vibration detectors associated with a storage device is collected. The vibration data represents vibrations experienced by the storage device. In response to the vibration data from the one or more vibration detectors, one or more movements for respective ones of one or more counter-vibration actuators to at least partially cancel of the vibrations experienced by the storage device is calculated. The one or more counter-vibration actuators perform the one or more movements.

    Abstract translation: 公开了用于减震的方法和装置。 收集与存储装置相关联的一个或多个振动检测器的振动数据。 振动数据表示存储装置所经历的振动。 响应于来自一个或多个振动检测器的振动数据,计算一个或多个反向振动致动器中的相应的一个或多个运动以至少部分地消除由存储装置经历的振动。 一个或多个反振动致动器执行一个或多个运动。

Patent Agency Ranking