Systems and methods for reslicing data in a relational database

A method of splitting a first slice of a representation in a distributed database into a plurality of new slices, the method comprising:

• creating a plurality of write queues, each write queue corresponding to a different one of the new slices;
• copying units of data in the first slice to the new slices according to a distribution function that determines, for each unit of data in the first slice, one of the new slices into which to copy the unit of data;
• asynchronously writing one or more actions of a set of one or more asynchronous database transactions to the first slice, wherein each transaction of the set of asynchronous database transactions is initiated after said creating of the write queues;
• asynchronously genqueuin the one or more actions of the set of asynchronous database transactions in the write queues according to the distribution function;
• replaying the actions in the write queues to the new slices after completing the copying of data in the first slice to the new slices;
• synchronously writing one or more actions of a set of one or more synchronous database transactions to the first slice, wherein each transaction of the set of synchronous database transactions is initiated after the write queues are emptied due to said replaying;
• and
• synchronously enqueuing the one or more actions of the set of synchronous database transactions in the write queues according to the distribution function,
• wherein the method is performed by one or more computing devices.

A distributed database system comprising a reslicing system for splitting a first slice of a representation in the database into a plurality of new slices, and one or more computing devices operative to implement the reslicing system, the reslicing system being configured to:

• create a plurality of new slices;
• create a plurality of write queues, each write queue corresponding to a different one of the new slices;
• copy units of data in the first slice to the new slices according to a distribution function that determines, for each unit of data in the first slice, one of the new slices into which to copy the unit of data;
• asynchronously write one or more actions of a set of one or more asynchronous database transactions to the first slice, wherein each transaction of the set of asynchronous database transactions is initiated after the creation of the write queues;
• asynchronously enqueue the one or more actions of the set of asynchronous database transactions in the write queues according to the distribution function;
• replay the actions in the write queues to the new slices after completing the copying of data in the first slice to the new slices;
• and
• control a speed of the asynchronous enqueuing of the one or more actions of the set of asynchronous database transactions during the replaying of the actions in the write queues, such that the actions in the write queues are dequeued faster than new actions are being enqueued in the write queues, until the write queues are emptied.

A distributed database system comprising a reslicing system for splitting a first slice of a representation in the database into a plurality of new slices, and one or more computing devices operative to implement the reslicing system, the reslicing system being configured to:

• create a plurality of new slices;
• create a plurality of write queues, each write queue corresponding to a different one of the new slices;
• copy units of data in the first slice to the new slices according to a distribution function that determines, for each unit of data in the first slice, one of the new slices into which to copy the unit of data;
• asynchronously write one or more actions of a set of one or more asynchronous database transactions to the first slice, wherein each transaction of the set of asynchronous database transactions is initiated after the creation of the write queues;
• asynchronously enqueue the one or more actions of the set of asynchronous database transactions in the write queues according to the distribution function;
• replay the actions in the write queues to the new slices after completing the copying of data in the first slice to the new slices;
• synchronously write one or more actions of a set of one or more synchronous database transactions to the first slice, wherein each transaction of the set of synchronous database transactions is initiated after the write queues are emptied due to the replaying;
• and
• synchronously enqueue the one or more actions of the set of one or more synchronous database transactions in the write queues according to the distribution function.

A computer-readable non-transitory storage medium comprising code for splitting a first slice of a representation in a database into a plurality of new slices, the code capable of causing one or more computing devices to:

• create a plurality of new slices;
• create a plurality of write queues, each write queue corresponding to a different one of the new slices;
• copy units of data in the first slice to the new slices according to a distribution function that determines, for each unit of data in the first slice, one of the new slices into which to copy the unit of data;
• asynchronously write one or more actions of a set of one or more asynchronous database transactions to the first slice, wherein each transaction of the set of asynchronous database transactions is initiated after the creation of the write queues;
• asynchronously enqueue the one or more actions of the set of asynchronous database transactions in the write queues according to the distribution function;
• replay the actions in the write queues to the new slices after completing the copying of data in the first slice to the new slices;
• and
• control a speed of the asynchronous enqueuing of the one or more actions of the set of asynchronous database transactions during the replaying of the actions in the write queues, such that the actions in the write queues are dequeued faster than new actions are being enqueued in the write queues, until the write queues are emptied.

A computer-readable non-transitory storage medium comprising code for splitting a first slice of a representation in a database into a plurality of new slices, the code capable of causing one or more computing devices to:

• create a plurality of new slices;
• create a plurality of write queues, each write queue corresponding to a different one of the new slices;
• copy units of data in the first slice to the new slices according to a distribution function that determines, for each unit of data in the first slice, one of the new slices into which to copy the unit of data;
• asynchronously write one or more actions of a set of one or more asynchronous database transactions to the first slice, wherein each transaction of the set of asynchronous database transactions is initiated after the creation of the write queues;
• asynchronously enqueue the one or more actions of the set of asynchronous database transactions in the write queues according to the distribution function;
• replay the actions in the write queues to the new slices after completing the copying of data in the first slice to the new slices;
• synchronously write one or more actions of a set of one or more synchronous database transactions to the first slice, wherein each transaction of the set of synchronous database transactions is initiated after the write queues are emptied due to the replaying;
• and
• synchronously enqueue the one or more actions of the first set of one or more synchronous database transactions in the write queues according to the distribution function.

A method of splitting a first slice of a representation in a distributed database into a plurality of new slices, the method comprising:

• creating the new slices;
• creating a plurality of write queues, each write queue corresponding to a different one of the new slices;
• copying units of data in the first slice to the new slices according to a distribution function that determines, for each unit of data in the first slice, one of the new slices into which to copy the unit of data;
• writing one or more actions of one or more database transactions to the first slice after beginning said copying;
• enqueuing the one or more actions of the one or more database transactions in the write queues according to the distribution function;
• replaying the actions in the write queues to the new slices;
• activating the new slices;
• and
• deactivating the first slice,
• wherein the method is performed by one or more computing devices.