公开(公告)号：US09083725B2

公开(公告)日：2015-07-14

申请号：US14531171

申请日：2014-11-03

Applicant: Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

Inventor： Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

IPC: G06F15/16 ,  H04L29/08 ,  G06F7/527 ,  G06F7/78

CPC classification number: H04L67/1097 ,  G06F7/5272 ,  G06F7/785 ,  H04L67/1095

Abstract: The embodiments herein develop a system for providing hierarchical cache for big data processing. The system comprises a caching layer, a plurality of actors in communication with the caching layer, a machine hosting the plurality of actors, a plurality of replication channels in communication with the plurality of actors, a predefined ring structure. The caching layer is a chain of memory and storage capacity elements, configured to store a data from the input stream. The plurality of actors is configured to replicate the input data stream and forward the replicated data to the caching layer. The replication channels are configured to forward the replicated data from a particular actor to another actor. The predefined ring structure maps the input data to the replica actors.

Abstract translation: 本文的实施例开发了一种用于为大数据处理提供分层缓存的系统。 该系统包括缓存层，与缓存层通信的多个角色，承载多个角色的机器，与多个角色通信的多个复制频道，预定义的环形结构。 缓存层是存储器和存储容量元件链，被配置为存储来自输入流的数据。 多个演员被配置为复制输入数据流并将复制的数据转发到缓存层。 复制通道配置为将复制数据从特定演员转发到另一个演员。 预定义的环结构将输入数据映射到副本演员。

公开(公告)号：US20150058438A1

公开(公告)日：2015-02-26

申请号：US14531171

申请日：2014-11-03

Applicant: Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

Inventor： Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

IPC: H04L29/08

CPC classification number: H04L67/1097 ,  G06F7/5272 ,  G06F7/785 ,  H04L67/1095

Abstract: The embodiments herein develop a system for providing hierarchical cache for big data processing. The system comprises a caching layer, a plurality of actors in communication with the caching layer, a machine hosting the plurality of actors, a plurality of replication channels in communication with the plurality of actors, a predefined ring structure. The caching layer is a chain of memory and storage capacity elements, configured to store a data from the input stream. The plurality of actors is configured to replicate the input data stream and forward the replicated data to the caching layer. The replication channels are configured to forward the replicated data from a particular actor to another actor. The predefined ring structure maps the input data to the replica actors.

Abstract translation: 本文的实施例开发了一种用于为大数据处理提供分层缓存的系统。 该系统包括缓存层，与缓存层通信的多个角色，承载多个角色的机器，与多个角色通信的多个复制频道，预定义的环形结构。 缓存层是存储器和存储容量元件链，被配置为存储来自输入流的数据。 多个演员被配置为复制输入数据流并将复制的数据转发到缓存层。 复制通道配置为将复制数据从特定演员转发到另一个演员。 预定义的环结构将输入数据映射到副本演员。

公开(公告)号：US20150052363A1

公开(公告)日：2015-02-19

申请号：US14531116

申请日：2014-11-03

Applicant: Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

Inventor： Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

IPC: G06F9/52 ,  H04L9/32

CPC classification number: H04L9/3263 ,  G06F9/54 ,  H04L9/3247

Abstract: The various embodiments herein provide an actor oriented system and a method for providing communication between a plurality of processes in the actor system. The system uses actor model as the basis for a large scale process distribution. The system abstracts the plurality of processes and adopts a method of process composition and resolution. The method provides binding of different processes in the system to create a multi-functional distributed application.

Abstract translation: 本文的各种实施例提供了一种面向演员的系统和一种用于在演员系统中的多个进程之间提供通信的方法。 该系统使用演员模型作为大规模流程分配的基础。 该系统摘录了多个进程，并采用了过程组合和分辨率的方法。 该方法提供了系统中不同进程的绑定以创建多功能分布式应用程序。

公开(公告)号：US09338226B2

公开(公告)日：2016-05-10

申请号：US14457153

申请日：2014-08-12

Applicant: Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

Inventor： Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

IPC: G06F15/173 ,  H04L29/08 ,  H04L12/24 ,  G06Q10/00 ,  G06F9/50

CPC classification number: H04L67/1002 ,  G06F9/5083 ,  G06Q10/00 ,  H04L41/5019

Abstract: 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.

Abstract translation: 本文的实施例提供了使用actor系统和异步消息中间件akka和scala语言来编写大数据程序的系统架构，应用模型和方法。 该系统包括连接到云网络和分布式虚拟机（DVM）网络的演员网络。 演员根据预定义的协议分别连接到DVM。 提供调度器以将资源调度到actor网络中的actor。 提供停止和启动机制来改变演员和DVM之间的连接。 系统服务器向演员发送消息，以断开连接到一个DVM的演员，并根据每个DVM中存在的进程代理的负载将演员连接到另一个DVM，以平衡演员的负载。 系统服务器对actor系统添加三个基本操作。

公开(公告)号：US20150089626A1

公开(公告)日：2015-03-26

申请号：US14531982

申请日：2014-11-03

Applicant: Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

Inventor： Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

IPC: H04L12/911 ,  G06Q30/06 ,  H04L29/06

CPC classification number: G06Q30/0601 ,  H04L63/02 ,  H04L67/1097

Abstract: The embodiments herein disclose a system and method for providing a marketplace for Big Data applications. The system facilitates a repository of applications, data sets, process compositions and extension modules received from the various vendors. The assets provided by the marketplace are deployed upon receiving the requests on public and private clouds. The marketplace comprises the algorithms, data sets and software systems to generate, share and save the insights for a plurality of cloud users. The system provides Big Data applications on demand from the cloud users and installs the requested application on a dedicated platform adopted for online Big Data processing.

Abstract translation: 本文的实施例公开了一种用于为大数据应用提供市场的系统和方法。 该系统便于从各种供应商接收的应用程序，数据集，过程组合和扩展模块的存储库。 市场提供的资产在接收到公共和私有云的请求时部署。 市场包括用于生成，共享和保存多个云用户的见解的算法，数据集和软件系统。 该系统根据云用户的需求提供大数据应用程序，并将所请求的应用程序安装在用于在线大数据处理的专用平台上。

公开(公告)号：US20140379775A1

公开(公告)日：2014-12-25

申请号：US14457153

申请日：2014-08-12

Applicant: Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

Inventor： Fred Korangy ,  Hamed Ghasemzadeh ,  Mohsen Arjmandi ,  Reza Azmi

IPC: H04L29/08

CPC classification number: H04L67/1002 ,  G06F9/5083 ,  G06Q10/00 ,  H04L41/5019

Abstract: 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.

Abstract translation: 本文的实施例提供了使用actor系统和异步消息中间件akka和scala语言来编写大数据程序的系统架构，应用模型和方法。 该系统包括连接到云网络和分布式虚拟机（DVM）网络的演员网络。 演员根据预定义的协议分别连接到DVM。 提供调度器以将资源调度到actor网络中的actor。 提供停止和启动机制来改变演员和DVM之间的连接。 系统服务器向演员发送消息，以断开连接到一个DVM的演员，并根据每个DVM中存在的进程代理的负载将演员连接到另一个DVM，以平衡演员的负载。 系统服务器对actor系统添加三个基本操作。