1. An apparatus for preparing a consumable beverage with a fine-bubbled foam layer, such as coffee or milk with a fine-bubbled foam layer, comprising;
a beverage unit for dispensing the beverage under pressure;
at least one nozzle which is in fluid communication with the beverage unit for supplying the beverage to the nozzle for generating a jet of the beverage; and
a collecting unit into which the jet spouts to obtain the beverage with the fine-bubbled foam layer,
wherein the collecting unit comprises a chamber defining an inner wall and having at least one outflow opening for dispensing the beverage with the fine-bubbled foam layer and a jet impact element included in the chamber with a top, which is substantially free of the inner wall of the chamber,
wherein the nozzle, jet impact element, and the at least one outflow opening are arranged substantially vertical relative to each other such that the jet impact element is located below the nozzle and the at least one outflow opening is located below and at least partially surrounds the jet impact element;
wherein the nozzle and the jet impact element are positioned relative to each other such that the jet spouts against at least a part of the top of the jet impact element,
wherein downward is directed toward the at least one outflow opening and upward is directed toward the nozzle;
wherein the chamber is dimensioned relative to the top of the jet impact element to enable the beverage, after impact on the jet impact element, to form a mist directed upward that then flows downward against the inner wall of the chamber between the inner wall and the jet impact element and then leaves the chamber via the at least one outflow opening as the beverage with the fine-bubbled foam layer,
wherein the at least one outflow opening for dispensing the beverage faces downwardly.
2. An apparatus according to claim 1, wherein the chamber is further provided with at least one air supply opening for supplying air to the chamber.
3. An apparatus according to claim 2, wherein the top of the jet impact element is positioned between the air supply opening and the at least one outflow opening.
4. An apparatus according to claim 3, wherein the top is directed toward the nozzle.
5. An apparatus according to claim 4, wherein the chamber is further provided with a product supply opening for supplying the jet to the chamber.
6. An apparatus according to claim 5, wherein the air supply opening and the product supply opening coincide.
7. An apparatus according to claim 6, wherein the top of the jet impact element is positioned between the product supply opening and the outflow opening.
8. An apparatus according to claim 7, wherein the top is directed toward the product supply opening.
9. An apparatus according to claim 8, wherein a surface of the top is made convex or flat.
10. An apparatus according to claim 9, wherein a normal at the middle of the surface of the top is directed substantially toward the product supply opening.
11. An apparatus according to claim 9, wherein a normal at the middle of the surface of the top is directed substantially in a longitudinal direction of the chamber.
12. An apparatus according to claim 9, wherein a normal at the middle of the surface of the top is directed substantially toward the nozzle.
13. An apparatus according to claim 12, wherein a normal from a surface of the top at a position where the jet impacts on the top is directed substantially parallel to the jet.
14. An apparatus according to claim 13, wherein a normal from a surface of the top at a position where the jet impacts on the top is directed substantially to the nozzle.
15. An apparatus according to claim 6, wherein a normal from a surface of the top at a position where the jet impacts on the top is directed substantially to the product supply opening.
16. An apparatus according to claim 15, wherein the top is positioned in a middle of the chamber.
17. An apparatus according to claim 16, wherein an axial direction of the jet impact element extends in a longitudinal direction of the chamber.
18. An apparatus according to claim 17, wherein the jet impact element is connected with the chamber by at least one cross arm.
19. An apparatus according to claim 18, wherein the inner wall of the chamber is made at least substantially rotation symmetrical.
20. An apparatus according to claim 19, wherein the inner wall of the chamber is made at least substantially rotation symmetrical about a rotation axis which extends in the longitudinal direction of the chamber.
21. An apparatus according to claim 20, wherein the rotation axis extends through the top.
22. An apparatus according to claim 21, wherein the inner wall of the chamber is made at least partly cylindrical.
23. An apparatus according to claim 22, wherein the jet, after impact on the jet impact element, forms a mist of the beverage which flows against andor along the inner wall of the chamber and then leaves the chamber via the at least one outflow opening as the beverage with the fine-bubbled foam layer.
24. A unit comprising a collecting unit and a nozzle of the apparatus according to claim 23 and a container for receiving a pad which comprises an envelope of filtering paper and which, for instance, is filled with a product to be extracted, such as ground coffee, whereby the container and the collecting unit are mechanically connected with each other and whereby the container comprises at least one outlet which is in fluid communication with an inlet of the nozzle.
25. A unit according to claim 24, wherein the container comprises a bottom and an upright side wall which extends around the bottom.
26. An assembly of a unit according to claim 25 and a pad which comprises an envelope of filtering paper and which is filled with a product to be extracted, such as ground coffee, whereby the pad is received in the container and thereby extends over a bottom of the container to upright side walls of the container.
27. An apparatus according to claim 1, wherein the inner wall of the chamber has opposite sections facing a perimeter edge of the top of the jet impact element in at least one diametrical direction that are spaced from one another at less than five times an extent of the top between confronting opposite sections of the perimeter edge of the top of the jet impact element in the same diametrical direction.
28. An apparatus according to claim 1, wherein the jet impact element is substantially horizontal to direct the mist upward and toward the inner wall of the chamber after impacting the top of the jet impact element.
29. An apparatus according to claim 1, wherein the chamber comprises a product supply opening for supplying air and the beverage jet to the chamber, wherein the jet impact element is positioned directly between the product supply opening and the outflow opening.
30. An apparatus according to claim 29, wherein the distance (H1) from the product supply opening to the top of the jet impact element is greater than the distance (H2) from the top of the jet impact element to the outflow opening.
31. A method for preparing a consumable beverage with a fine-bubbled foam layer, such as coffee or milk, comprising:
providing a collecting unit having a chamber and a jet impact element located in the chamber vertically below a nozzle, the chamber defining an inner wall having at least one downwardly-facing outflow opening vertically below the jet impact element, the jet impact element having a substantially horizontally extending convex top surface that is spaced apart from the inner wall of the chamber, the at least one outflow opening substantially surrounding the jet impact element, wherein downward is directed toward the at least one outflow opening and upward is directed toward the nozzle;
supplying the beverage to the nozzle;
generating a liquid jet which comprises the beverage; and
supplying the liquid jet to the collecting unit so that the jet spouts into the collecting unit to obtain the beverage with the fine-bubbled foam layer;
directing the jet against the convex top surface of the jet impact element so that the beverage, after impact on the jet impact element, forms a mist that travels upward and sideward and then flows downward against the inner wall of the chamber and then;
dispensing the beverage with the fine-bubbled foam layer downwardly from the chamber between the inner wall and the jet impact element via the at least one outflow opening.
32. A method according to claim 31, wherein air is supplied to the chamber.
33. A method according to claim 32, wherein the collecting unit comprises at least one air supply opening for supplying air to the chamber.
34. A method according to claim 33, wherein the chamber further comprises a product supply opening via which the jet is supplied to the chamber.
35. A method according to claim 33, wherein the product supply opening and the air supply opening coincide.
36. A method according to claim 35, wherein the top of the jet impact element is positioned between the product supply opening and the outflow opening.
37. A method according to claim 36, wherein the jet is directed on top of the top.
38. A method according to claim 37, wherein the jet is directed such that a normal from the surface of the top at a position where the jet impacts on the top is substantially parallel to the direction of the jet at the top.
39. A method according to claim 36, wherein the jet is directed such that a normal from the surface of the top at a position where the jet impacts on the top is directed substantially to the product supply opening.
40. A method according to claim 39, wherein a surface of the top is made convex or flat.
41. A method according to claim 40, wherein a normal at the middle of the surface of the top is directed substantially toward the product supply opening.
42. A method according to claim 39, wherein a normal at the middle of the surface of the top is directed substantially in a longitudinal direction of the chamber.
43. A method according to claim 40, wherein a normal at the middle of the surface of the top is directed substantially parallel to the jet.
44. A method according to claim 43, wherein the top is positioned in a middle of the chamber.
45. A method according to claim 44, wherein an axial direction of the jet impact element extends in a longitudinal direction of the chamber.
46. A method according to claim 45, wherein the jet impact element is connected with the chamber by means of at least one cross arm.
47. A method according to claim 46, wherein the inner wall of the chamber is made at least substantially rotation symmetrical.
48. A method according to claim 47, wherein the inner wall of the chamber is made at least substantially rotation symmetrical around a rotation axis which extends in the longitudinal direction of the chamber.
49. A method according to claim 48, wherein the rotation axis extends through the top.
50. A method according to claim 49, wherein the inner wall of the chamber is made at least partly cylindrical.
51. A method according to claim 50, wherein the jet of beverage is generated by supplying the beverage under pressure to a nozzle.
52. A method according to claim 51, wherein the air supply opening is positioned between the nozzle and the top of the jet impact element.
53. A method according to claim 52, wherein the jet, after impact on the impact element, forms a mist of the beverage which flows against andor along the inner wall and then leaves the chamber via the at least one outflow opening as the beverage with the fine-bubbled foam layer.
54. A method according to claim 31, further comprising directing the mist upward and toward the inner wall of the chamber after impacting the jet impact element.
The claims below are in addition to those above.
All refrences to claim(s) which appear below refer to the numbering after this setence.
1. A method for dynamically processing an event including a dataset that is streamed from a source to a sink via nodes, the method comprising:
recording, at a respective node, the event including the dataset in a memory of the respective node using a data model; and
annotating the event by adding or updating one or more attributes associated with the event in the data model based on analyzing the dataset, the data model being extensible to add additional attributes to the event by a subsequent node configured to further process the dataset as the event is streamed from the source to the sink,
wherein said annotating includes specifying, based on the dataset, one or more fields of the event in the data model, wherein the dataset includes at least one of: a timestamp, a source machine, a body, or a priority.
2. The method of claim 1, wherein the one or more attributes include: (1) a map from a string attribute name to an array of bytes, (2) a route to one or more storage locations for the event, or (3) one or more formats for outputting of the dataset at the sink.
3. The method of claim 1, wherein specifying one or more fields includes specifying, based on the timestamp, a priority of the event in a priority field of the event in the data model.
4. The method of claim 1, further comprising:
bucketing the event with other events based on the dataset.
5. The method of claim 1, wherein a field in the data model corresponds to a key and stores a value.
6. A method for dynamically processing an event including a dataset that is streamed from a source to a sink via nodes, the method comprising:
recording, at a respective node, the event including the dataset in a memory of the respective node using a data model; and
annotating the event by adding or updating one or more attributes associated with the event in the data model based on analyzing the dataset, the data model being extensible to add additional attributes to the event by a subsequent node configured to further process the dataset as the event is streamed from the source to the sink,
wherein the one or more attributes include: (1) a map from a string attribute name to an array of bytes, (2) a route to one or more storage locations for the event, or (3) one or more formats for outputting of the dataset at the sink.
7. The method of claim 6, wherein said annotating includes specifying, based on the dataset, one or more fields of the event in the data model, wherein the dataset includes at least one of: a timestamp, a source machine, a body, or a priority.
8. The method of claim 6, wherein a field in the data model corresponds to a key and stores a value.
9. A non-transitory computer readable medium storing a plurality of instructions which, upon execution by a processor, cause the processor to perform a method for dynamically processing an event including a dataset that is streamed from a source to a sink via nodes, the method comprising:
recording, at a respective node, the event including the dataset in a memory of the respective node using a data model; and
annotating the event by adding or updating one or more attributes associated with the event in the data model based on analyzing the dataset, the data model being extensible to add additional attributes to the event by a subsequent node which is configured to further process the dataset as the event is streamed from the source to the sink,
wherein said annotating includes specifying, based on the dataset, one or more fields of the event in the data model, wherein the dataset includes at least one of: a timestamp, a source machine, a body, or a priority.
10. The medium of claim 9, wherein the one or more attributes include: (1) a map from a string attribute name to an array of bytes, (2) a route to one or more storage locations for the event, or (3) one or more formats for outputting of the dataset at the sink.
11. The medium of claim 9, wherein specifying one or more fields includes specifying, based on the timestamp, a priority of the event in a priority field of the event in the data model.
12. The medium of claim 9, wherein the method performed by the processor further comprises:
bucketing the event with other events based on the dataset.
13. The medium of claim 9, wherein a field in the data model corresponds to a key and stores a value.
14. A system having a processor and a memory, the memory storing a plurality of instructions which, when executed by the processor, cause the processor to perform a method for dynamically processing an event including a dataset that is streamed from a source to a sink via nodes, the method comprising:
recording, at a respective node, the event including the dataset in a memory of the respective node using a data model; and
annotating the event by adding or updating one or more attributes associated with the event in the data model based on analyzing the dataset, the data model being extensible to add additional attributes to the event by a subsequent node configured to further process the dataset as the event is streamed from the source to the sink,
wherein said annotating includes specifying, based on the dataset, one or more fields of the event in the data model, wherein the dataset includes at least one of: a timestamp, a source machine, a body, or a priority.
15. The system of claim 14, wherein the one or more attributes include: (1) a map from a string attribute name to an array of bytes, (2) a route to one or more storage locations for the event, or (3) one or more formats for outputting of the dataset at the sink.
16. The system of claim 14, wherein specifying one or more fields includes specifying, based on the timestamp, a priority of the event in a priority field of the event in the data model.
17. The system of claim 14, wherein the method performed by the processor further comprises:
bucketing the event with other events based on the dataset.
18. A computer system configured for collecting and aggregating datasets for storage in a file system with fault tolerance, the file system including an agent node, a collector node, and a master node, the computer system having a processor configured to perform a method comprising:
collecting the datasets via an agent node operating in a remote machine, wherein the datasets include a batch of messages written by the remote machine, and wherein the batch of messages are processed by the agent node when the a size or a lapsed time of the batch of messages reaches a select threshold;
generating, by the agent node, a batch identifier (ID) for the batch of messages;
assigning, by the agent node, an event tag to the batch of messages;
computing, by the agent node, a checksum for the batch of messages;
writing, by the agent node, the batch of messages along with the batch ID, the event tag, and the checksum as an entry in a write-ahead-log (WAL) storage maintained by the agent node on the remote machine;
transmitting, by the agent node, the datasets to a collector machine, wherein the datasets are transmitted in a data model as an event, the data model being extensible to add additional attributes to the event by a subsequent node which is configured to further process the dataset as the event is streamed from a source to a sink;
verifying the checksum by a collector node operating in the collector machine;
if the checksum is verified, adding, by the collector node, a tag to a map of tags, wherein the map of tags are associated with multiple tags assigned to multiple batches of messages from the datasets;
writing, by the collector node, the datasets to a destination location; and
if the batch of messages has been successfully written to the destination location, publishing, by the collector node, the tag to the master node.
19. The computer system of claim 18, the method further comprising:
querying, by the master node, for an acknowledgement message confirming that the batch of messages has been successfully written to the destination location; and
if the batch of messages has been successfully written based on the acknowledgement message, causing, by the master node, the agent node to delete the batch of messages from the WAL storage.
20. The computer system of claim 18, the method further comprising:
querying, by the master node, for an acknowledgement message confirming that the batch of messages has been successfully written to the destination location; and
if the batch of messages has not been successfully written based on the acknowledgement message, causing, by the master node, the collector node to rewrite the datasets to the destination location.