Systems and methods for staging of data updates to database system in a multi-tenant system

1 . A multi-tenant system, comprising:

one or more hardware processors; and

memory storing computer instructions, wherein the computer instructions, when executed by the one or more hardware processors, cause the one or more hardware processors to perform operations comprising:

extracting one or more standard fields from one or more objects stored in one or more source database systems, the standard fields defining standard subscription attributes;

mapping the one or more standard fields to one or more records within a destination database system, wherein the one or more records comprise columns or rows within a table, and wherein mapping the one or more standard fields to the one or more records comprises selecting a particular table within the destination database system into which a particular standard field of the standard fields is ingested based on a classification of the particular standard field, wherein the classification is indicative of a vesting status corresponding to the standard field, the vesting status indicating whether the particular standard field corresponds to a vesting event;

obtaining one or more customized fields, the one or more customized fields defining tenant-selected subscription attributes;

obtaining a mapping of the one or more customized fields to the one or more records;

appending the one or more standard fields to the one or more customized fields to form appended fields;

scheduling a pipeline to ingest the appended fields into the one or more records within the destination database system; and

ingesting the appended fields into the one or more records within the destination database system in order to stage the appended fields into the destination database system.

2 . The multi-tenant system of claim 1 , wherein the mapping of the one or more standard fields to the one or more records based on the classification comprises mapping a standard field to a staging table if the standard field corresponds to a vesting event and mapping the standard field to a pre-staging table if the standard field corresponds to a nonvesting event.

3 . The multi-tenant system of claim 1 , wherein the one or more standard fields comprise one or more first standard fields, the one or more customized fields comprise one or more first customized fields, the one or more first standard fields corresponding to a first event of a first event type, the one or more records comprises one or more first records; and the computer instructions when executed by the one or more hardware processors are further configured to perform:

extracting one or more second standard fields corresponding to a second event from one or more source database systems, the second event being of a second event type; and

mapping the one or more second standard fields to one or more second records within the destination database system, and

wherein the scheduling of the pipeline comprises partitioning the appended first fields and the one or more second standard fields based on different event types.

4 . The multi-tenant system of claim 3 , wherein the scheduling of the pipeline comprises partitioning the appended first fields into a separate partition as the one or more second standard fields.

5 . The multi-tenant system of claim 1 , wherein the one or more records comprise a row or a column.

6 . The multi-tenant system of claim 1 , wherein the instructions when executed by the one or more hardware processors are further configured to perform:

normalizing the extracted one or more standard fields and the obtained one or more customized fields according to a standardized format compatible with the destination database system.

7 . The multi-tenant system of claim 1 , wherein the destination database system is configured to recognize events based on the ingested appended fields and perform workflow operations based on the recognized events.

8 . The multi-tenant system of claim 7 , wherein the one or more customized fields are included in an output of the performed workflow operations.

9 . A method implemented by a multi-tenant system comprising a plurality of computers, the method comprising:

extracting one or more standard fields from one or more objects stored in one or more source database systems, the standard fields defining standard subscription attributes;

mapping the one or more standard fields to one or more records within a destination database system, wherein the one or more records comprises columns or rows within a table, and wherein mapping the one or more standard fields to the one or more records comprises selecting a particular table within the destination database system into which a particular standard field of the standard fields is ingested based on a classification of the particular standard field, wherein the classification is indicative of a vesting status corresponding to the standard field, the vesting status indicating whether the particular standard field corresponds to a vesting event;

obtaining one or more customized fields, the one or more customized fields defining tenant-selected subscription attributes;

obtaining a mapping of the one or more customized fields to the one or more records;

appending the one or more standard fields to the one or more customized fields to form appended fields;

scheduling a pipeline to ingest the appended fields into the one or more records within the destination database system; and

ingesting the appended fields into the one or more records within the destination database system in order to stage the appended fields into the destination database system.

10 . The method of claim 9 , wherein the mapping of the one or more standard fields to the one or more records based on the classification comprises mapping a standard field to a staging table if the standard field corresponds to a vesting event and mapping the standard field to a pre-staging table if the standard field corresponds to a nonvesting event.

11 . The method of claim 9 , wherein the one or more standard fields comprise one or more first standard fields, the one or more customized fields comprise one or more first customized fields, the one or more first standard fields corresponding to a first event of a first event type, the one or more records comprises one or more first records; and the method further comprises:

extracting one or more second standard fields corresponding to a second event from one or more source database systems, the second event being of a second event type; and

mapping the one or more second standard fields to one or more second records within the destination database system, and

wherein the scheduling of the pipeline comprises partitioning the appended first fields and the one or more second standard fields based on different event types.

12 . The method of claim 11 , wherein the scheduling of the pipeline comprises partitioning the appended first fields into a separate partition as the one or more second standard fields.

13 . The method of claim 9 , wherein the one or more records comprise a row or a column.

14 . The method of claim 9 , further comprising:

normalizing the extracted one or more standard fields and the obtained one or more customized fields according to a standardized format compatible with the destination database system.

15 . The method of claim 9 , further comprising:

recognizing, by the destination database system, events based on the ingested appended fields and performing workflow operations based on the recognized events.

16 . The method of claim 15 , wherein the one or more customized fields are included in an output of the performed workflow operations.

17 . A multi-tenant system, comprising:

one or more hardware processors; and

memory storing computer instructions, wherein the computer instructions, when executed by the one or more hardware processors, cause the one or more hardware processors to perform operations comprising:

extracting one or more standard fields from one or more objects stored in one or more source database systems, the standard fields defining standard subscription attributes;

mapping the one or more standard fields to one or more records within a destination database system;

obtaining one or more customized fields, the one or more customized fields defining tenant-selected subscription attributes;

obtaining a mapping of the one or more customized fields to the one or more records;

appending the one or more standard fields to the one or more customized fields to form appended fields;

scheduling a pipeline to ingest the appended fields into the one or more records within the destination database system; and

ingesting the appended fields into the one or more records within the destination database system in order to stage the appended fields into the destination database system, wherein the destination database system is configured to recognize events based on the ingested appended fields and to perform workflow operations based on the recognized events.

18 . A method implemented by a multi-tenant system comprising a plurality of computers, the method comprising:

extracting one or more standard fields from one or more objects stored in one or more source database systems, the standard fields defining standard subscription attributes;

mapping the one or more standard fields to one or more records within a destination database system;

obtaining one or more customized fields, the one or more customized fields defining tenant-selected subscription attributes;

obtaining a mapping of the one or more customized fields to the one or more records;

appending the one or more standard fields to the one or more customized fields to form appended fields;

scheduling a pipeline to ingest the appended fields into the one or more records within the destination database system;

ingesting the appended fields into the one or more records within the destination database system in order to stage the appended fields into the destination database system; and

recognizing, by the destination database system, events based on the ingested appended fields and performing workflow operations based on the recognized events.