Method and apparatus for executing distributed computing task

An apparatus for executing a distributed computing task, the apparatus comprising:

• at least one processor;
• and
• a memory storing instructions, wherein the instructions when executed by the at least one processor, cause the at least one processor to perform operations, the operations comprising:
• parsing an expression of the distributed computing task to obtain an operator keyword;
• and
• executing, by using an operator corresponding to the operator keyword, the distributed computing task based on an input parameter of the operator, the input parameter of the operator comprising at least one of:
• a distributively stored distributed key-value pair set including at least one key-value pair, a value of the key-value pair in the distributed key-value pair set being a distributed dataset or a distributed key-value pair set,
• wherein the parsing an expression of the distributed computing task to obtain an operator keyword comprises:
• parsing the expression of the distributed computing task to obtain a grouping operator keyword, a grouped distributed dataset keyword for representing a distributed dataset operated by a grouping operator corresponding to the grouping operator keyword, and a grouping condition keyword for representing a grouping basis for grouping the distributed dataset represented by the grouped distributed dataset keyword;
• and
• the executing, by using an operator corresponding to the operator keyword, the distributed computing task based on an input parameter of the operator, comprises:
• forming a plurality of new key-value pairs by:
• dividing each of a plurality of numbers by a given number to acquire a remainder of the each number;
• determining, from the plurality of numbers, first numbers having a given first remainder and second numbers having a given second remainder;
• forming a first dataset including the first numbers and forming a second dataset including the second numbers;
• using the first dataset as a first value, using the second dataset as a second value, using the first remainder as a first key and using the second remainder as a second key;
• and forming a first new key-value pair by using the first key and the first value and forming a second new key-value pair by using the second key and the second value.

A non-transitory computer storage medium, storing computer readable instructions executable by a processor, the computer readable instructions, when executed by the processor, cause the processor to perform operations, the operations comprising:

• parsing an expression of the distributed computing task to obtain an operator keyword;
• and
• executing, by using an operator corresponding to the operator keyword, the distributed computing task based on an input parameter of the operator, the input parameter of the operator comprising a distributively stored distributed key-value pair set including at least one key-value pair, a value of the key-value pair in the distributed key-value pair set being a distributed dataset or a distributed key-value pair set,
• wherein the parsing an expression of the distributed computing task to obtain an operator keyword comprises:
• parsing the expression of the distributed computing task to obtain a grouping operator keyword, a grouped distributed dataset keyword for representing a distributed dataset operated by a grouping operator corresponding to the grouping operator keyword, and a grouping condition keyword for representing a grouping basis for grouping the distributed dataset represented by the grouped distributed dataset keyword;
• and
• the executing, by using an operator corresponding to the operator keyword, the distributed computing task based on an input parameter of the operator, comprises:
• forming a plurality of new key-value pairs by:
• dividing each of a plurality of numbers by a given number to acquire a remainder of the each number;
• determining, from the plurality of numbers, first numbers having a given first remainder and second numbers having a given second remainder;
• forming a first dataset including the first numbers and forming a second dataset including the second numbers;
• using the first dataset as a first value, using the second dataset as a second value, using the first remainder as a first key and using the second remainder as a second key;
• and forming a first new key-value pair by using the first key and the first value and forming a second new key-value pair by using the second key and the second value.