Method for streaming transactions in database cluster

A method for use in a database cluster, wherein the database cluster comprises a plurality of nodes, the method comprising:

• receiving a fragment at a second node of the database cluster, the fragment being associated with a transaction, the fragment comprising one or more replication events;
• identifying a set of fragment-specific parameters associated with the fragment;
• determining, from the set of fragment-specific parameters, whether or not a streaming transaction to which the fragment belongs exists in a transaction pool;
• and
• applying the one or more replication events of the fragment at the second node whilst addressing the streaming transaction to which the fragment belongs.

A computing apparatus comprising:

• a processor;
• a memory coupled to the processor;
• and
• a network interface coupled to the processor,
• wherein the processor is configured to:
• receive a transaction;
• execute the transaction, wherein the transaction produces a plurality of replication events;
• divide the plurality of replication events of the transaction into a plurality of fragments, wherein each of the plurality of fragments comprises one or more replication events;
• assign a set of fragment-specific parameters to each of the plurality of fragments;
• and
• communicate the plurality of fragments to one or more nodes of a database cluster.

A computing apparatus comprising:

• a processor;
• a memory coupled to the processor;
• and
• a network interface coupled to the processor,
• wherein the processor is configured to:
• receive a fragment, the fragment being associated with a transaction, the fragment comprising one or more replication events;
• identify a set of fragment-specific parameters associated with the fragment;
• determine, from the set of fragment-specific parameters, whether or not a streaming transaction to which the fragment belongs exists in a transaction pool;
• and
• apply the one or more replication events of the fragment whilst addressing the streaming transaction to which the fragment belongs.

A computer program product comprising a non-transitory machine-readable data storage medium having stored thereon program instructions that, when accessed by a processing device, cause the processing device to:

• receive a transaction;
• execute the transaction, wherein the transaction produces a plurality of replication events;
• divide the plurality of replication events of the transaction into a plurality of fragments, wherein each of the plurality of fragments comprises one or more replication events;
• assign a set of fragment-specific parameters to each of the plurality of fragments;
• and
• communicate the plurality of fragments to one or more nodes of a database cluster.