Automatic selection of cut-point connections for dynamically-cut stream processing systems

A system for connecting graph processing cut endpoints of a stream processing system, the system comprising:

• a first determination unit adapted for determining a first capability matrix comprising, for each pairing of one side of the cut endpoint, capability values;
• and
• an applying module adapted for applying weights to the capability values of the first capability matrix resulting in a first weighted capability matrix;
• a second determination unit adapted determining a second capability matrix comprising, for each pairing of another side of the cut endpoint, capability;
• a third determination unit for determining a joint weighted capability matrix for two corresponding cut endpoints of a cut by multiplying corresponding capability matrix values of the first weighted capability matrix and the second capability matrix;
• and
• a selection module adapted for selecting a preferred connection for the cut endpoints by determining the highest matrix field of the joint weighted capability matrix.

A computer program product for connecting graph processing cut endpoints of a stream processing system, the computer program product comprising a computer readable storage medium having program instructions embodied therewith, the program instructions being executable by one or more computing systems to cause the one or more computing systems to:

• applying weights to capability values of a first capability matrix resulting in a first weighted capability matrix;
• determine a joint weighted capability matrix for two corresponding cut endpoints of a cut by multiplying corresponding capability matrix values of the first weighted capability matrix and the second capability matrix;
• and
• select a preferred connection for the cut endpoints by determining the highest matrix field of the joint weighted capability matrix.