Automated compression of data
First Claim
1. A control unit, comprising at least one processor and at least one memory including a computer program code, the at least one memory and the computer program code configured to, with the at least one processor, cause the control unit at least to:
- automatically distribute processing components of an application over processing nodes of a distributed processing service platform;
determine whether a communication channel between two processing components traverses a boundary of a processing node;
if it has been determined that the communication channel traverses a boundary of one of the processing nodes, determine whether an encoding and/or decoding of data to be transferred through the communication channel is required; and
,store information about an established communication channel;
wherein the information comprises a port of a sending component and of a receiving component for the established communication channel.
1 Assignment
0 Petitions
Accused Products
Abstract
The application relates to a system comprising at least two processing nodes (1), wherein the nodes (1) comprise an execution environment (2) and a processing component (3), wherein each execution environment (2) includes an establisher configured to establish a communication channel (4) between an outgoing port of the processing component (3) and an inbound port of a different processing component (3), and wherein the system is configured to determine whether the communication channel (4) traverses a boundary of a node (1), and to determine whether an encoding/decoding of data to be transferred through the communication channel (4) is required.
37 Citations
16 Claims
-
1. A control unit, comprising at least one processor and at least one memory including a computer program code, the at least one memory and the computer program code configured to, with the at least one processor, cause the control unit at least to:
-
automatically distribute processing components of an application over processing nodes of a distributed processing service platform; determine whether a communication channel between two processing components traverses a boundary of a processing node; if it has been determined that the communication channel traverses a boundary of one of the processing nodes, determine whether an encoding and/or decoding of data to be transferred through the communication channel is required; and
,store information about an established communication channel; wherein the information comprises a port of a sending component and of a receiving component for the established communication channel. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A system comprising at least two processing nodes, wherein:
-
at least one of the nodes comprise an execution environment and at least one processing component, the execution environment includes an establisher configured to establish a communication channel between an outgoing port of a processing component and an inbound port of a different processing component, the execution environment is further configured to instantiate, modify and delete distributed processing components on the respective node, and the system further comprises a control unit comprising at least one processor and at least one memory including a computer program code, the at least one memory and the computer program code configured to, with the at least one processor, cause the control unit at least to; automatically distribute processing components of an application over processing nodes of a distributed processing service platform; determine whether a communication channel between two processing components traverses a boundary of a processing node; if it has been determined that the communication channel traverses a boundary of one of the processing nodes, determine whether an encoding and/or decoding of data to be transferred through the communication channel is required; and
,wherein the information comprises a port of a sending component and of a receiving component for the established communication channel. - View Dependent Claims (7, 8, 9)
-
-
10. A sending processing node comprising at least one processor and at least one memory including a computer program code, the at least one memory and the computer program code configured to, with the at least one processor, cause the sending processing node at least to:
-
instantiate, modify and delete distributed processing components of an application on the node; and establish a communication channel between at least one outgoing port of a processing component of said sending processing node with a receiving processing node; send data through the communication channel; wherein the sending processing node comprises a control unit comprising at least one control unit processor and at least one control unit memory including a control unit computer program code, the at least one control unit memory and the control unit computer program code configured to, with the at least one control unit processor, cause the control unit at least to; automatically distribute processing components of an application over processing nodes of a distributed processing service platform; determine whether a communication channel between two processing components traverses a boundary of a processing node; if it has been determined that the communication channel traverses a boundary of one of the processing nodes, determine whether an encoding and/or decoding of data to be transferred through the communication channel is required; and store information about an established communication channel; wherein the information comprises a port of a sending component and of a receiving component for the established communication channel; wherein the sending processing node is configured to, if encoding is determined to be required, to instantiate an encoder and to inform the receiving processing node about a type of encoder being instantiated.
-
-
11. A receiving processing node comprising at least one distributed processing component, at least one processor and at least one memory including a computer program code, the at least one memory and the computer program code configured to, with the at least one processor, cause the receiving processing node at least to:
-
instantiate, modify and delete distributed processing components on the node; and wherein at least one inbound port of a processing component is connectable via a communication channel with a sending processing node for receiving data through the communication channel; wherein the receiving processing node comprises a control unit comprising at least one control unit processor and at least one control unit memory including a control unit computer program code, the at least one control unit memory and the control unit computer program code configured to, with the at least one control unit processor, cause the control unit at least to; automatically distribute processing components of an application over processing nodes of a distributed processing service platform; determine whether a communication channel between two processing components traverses a boundary of a processing node; if it has been determined that the communication channel traverses a boundary of one of the processing nodes, determine whether an encoding and/or decoding of data to be transferred through the communication channel is required; and store information about an established communication channel; wherein the information comprises a port of a sending component and of a receiving component for the established communication channel; wherein the receiving processing node is configured to instantiate a decoder, if encoding is determined to be required, based on information about a type of encoder being instantiated at the sending processing node, the information received from the sending processing node.
-
-
12. A method for data communication within a system having at least two processing nodes, wherein:
-
at least one node is configured to instantiate, modify and delete distributed processing components on the respective node, and further configured to connect an outgoing port of a processing component sending data with an inbound port of a processing component receiving data via a communication channel, and the method comprises; automatically distributing processing components of an application onto the nodes; establishing a communication channel between a sending processing component and a receiving processing component; determining whether the communication channel traverses a boundary of a node; determining whether an encoding/decoding of data to be transferred through the communication channel is required, in response to a determination that a boundary of a node is traversed; instantiating an encoder within the node of a sending component and a decoder within the node of the receiving component, in response to a determination that encoding/decoding is to be required; providing the data to be transferred from the sending component to the encoder and encoding the data within the encoder; sending the encoded data through the communication channel to the receiving node; and storing information about an established communication channel; wherein the information comprises a port of a sending component and of a receiving component for the established communication channel. - View Dependent Claims (13, 14, 15, 16)
-
Specification