Distributed real-time computing framework using in-storage processing
First Claim
1. A scheduler computing device comprising:
- a computing task memory configured to store at least one computing task,wherein the computing task is to be executed by a data node of a distributed computing system, wherein the distributed computing system comprises at least one data node, each data node having a central processor and an intelligent storage medium, wherein the intelligent storage medium comprises a controller processor and a non-volatile memory; and
a processor configured to reduce the transmittal of data between elements of the data node by;
deciding whether to assign the computing task to be executed by either the central processor of the data node or the controller processor of the intelligent storage medium based, at least in part, upon an amount of output data associated with the computing task compared to an amount of input data associated with the computing task, wherein;
when the amount of output data is greater than the amount of input data, assigned the computing task to the central processor of the data node; and
when the amount of output data is less than or equal to the amount of input data, assigned the computing task to the controller processor of the intelligent storage medium.
1 Assignment
0 Petitions
Accused Products
Abstract
According to one general aspect, a scheduler computing device may include a computing task memory configured to store at least one computing task. The computing task may be executed by a data node of a distributed computing system, wherein the distributed computing system includes at least one data node, each data node having a central processor and an intelligent storage medium, wherein the intelligent storage medium comprises a controller processor and a memory. The scheduler computing device may include a processor configured to assign the computing task to be executed by either the central processor of a data node or the intelligent storage medium of the data node, based, at least in part, upon an amount of data associated with the computing task.
5 Citations
19 Claims
-
1. A scheduler computing device comprising:
-
a computing task memory configured to store at least one computing task, wherein the computing task is to be executed by a data node of a distributed computing system, wherein the distributed computing system comprises at least one data node, each data node having a central processor and an intelligent storage medium, wherein the intelligent storage medium comprises a controller processor and a non-volatile memory; and a processor configured to reduce the transmittal of data between elements of the data node by; deciding whether to assign the computing task to be executed by either the central processor of the data node or the controller processor of the intelligent storage medium based, at least in part, upon an amount of output data associated with the computing task compared to an amount of input data associated with the computing task, wherein; when the amount of output data is greater than the amount of input data, assigned the computing task to the central processor of the data node; and when the amount of output data is less than or equal to the amount of input data, assigned the computing task to the controller processor of the intelligent storage medium. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A method comprising:
-
receiving a computing task, wherein the computing task includes a plurality of operations; allocating the computing task to a data node, wherein the data node includes a central processor and an intelligent storage medium, and wherein the intelligent storage medium includes a controller processor and a non-volatile memory; dividing the computing task into at least a first chain of operations and a second chain of operations, wherein dividing the computing task includes determining for each chain of operations an amount of output data associated with a respective chain of operations and an amount of input data associated with the respective chain of operations; if, for a respective chain of operations, the amount of output data is less than the amount of input data, assigning the respective chain of operations to the intelligent storage medium of the data node; and if, for a respective chain of operations, the amount of output data is greater than the amount of input data, assigning the respective chain of operations to the central processor of the data node. - View Dependent Claims (8, 9, 10, 11, 12)
-
-
13. A data node comprising:
-
a central processor configured to execute at least one of a first set of operations upon data stored by an intelligent storage medium; the intelligent storage medium comprising; a memory configured to store data in a semi-permanent manner, and a controller processor configured to execute at least one of a second set of operations upon data stored by the intelligent storage medium; and a network interface configured to receive a plurality of operations from a scheduling computing device; and wherein the data node is configured to; divide the computing task into at least the first set of operations and the second set of operations based, at least in part, upon an amount of output data associated with a respective set of operations compared to an amount of input data associated with the respective set of operations, if, for a respective set of operations, the amount of output data is less than the amount of input data, assign the respective set of operations to the central processor for execution, and if, for a respective set of operations, the amount of output data is greater than the amount of input data, assigning the respective set of operations to the intelligent storage medium for execution. - View Dependent Claims (14, 15, 16, 17, 18, 19)
-
Specification