发明名称 |
ACTOR SYSTEM AND METHOD FOR ANALYTICS AND PROCESSING OF BIG DATA |
摘要 |
The embodiments herein provide a system architecture, application model and methods to write Big Data programs using actor systems and asynchronous messaging middleware akka and scala language. The system comprises an actor network connected to a cloud network and to a distributed virtual machine (DVM) network. The actors are connected respectively to the DVMs based on a predefined protocol. A scheduler is provided to schedule the resources to an actor in the actor network. A stop and start mechanism is provided to change a connection between the actors and the DVMs. The system server sends a message to the actor to disconnect an actor connected to one DVM and to connect the actor to another DVM based on a load of a process agent present in each DVM to balance a load on the actor. The system server adds three fundamental operations over actor systems. |
申请公布号 |
US2014379775(A1) |
申请公布日期 |
2014.12.25 |
申请号 |
US201414457153 |
申请日期 |
2014.08.12 |
申请人 |
Korangy Fred;Ghasemzadeh Hamed;Arjmandi Mohsen;Azmi Reza |
发明人 |
Korangy Fred;Ghasemzadeh Hamed;Arjmandi Mohsen;Azmi Reza |
分类号 |
H04L29/08 |
主分类号 |
H04L29/08 |
代理机构 |
|
代理人 |
|
主权项 |
1. A system with actor oriented platform for Big Data processing comprising:
an actor network connected to a cloud server in a cloud network, and wherein the actor network comprises a plurality of actors; a distributed virtual machine (DVM) network connected to the actor network, and wherein the DVM network comprises a plurality of DVMs, and wherein the plurality of actors is connected respectively to the plurality of DVMs based on a predefined protocol; a system server connected to the cloud server, the actor network and the DVM network; a scheduler provided in the system server to schedule the resources connected to an actor in the actor network; a stop and start mechanism provided in the server to change a connection between the plurality of actors and the plurality of DVMs; and a cloud balancer provided in the server and connected to the actor in the actor network; wherein the system server sends a message to the actor to disconnect an actor connected to one DVM and to connect the actor to another DVM based on a load of a process agent present in each DVM to balance a load on the actor. |
地址 |
Annapolis MD US |