Efficient data backflow processing for data warehouse
First Claim
Patent Images
1. A method for processing backflow data, comprising:
- obtaining backflow data from a data warehouse;
determining, according to a backflow rule for the backflow data, a respective destination table in a production system for each data item in the backflow data; and
sending the data item according to the determined respective destination table in the production system, wherein sending the data item includes grouping backflow data to the determined destination tables in the production system, wherein data items in the backflow data associated with the same destination table are included in the same group, and sending the backflow data according to the grouping using a plurality of threads, wherein data items in each group are sent to the same destination table in the production system by the same thread;
wherein sending the data item according to the determined respective destination table in the production system further comprises distributing groups of backflow data to the plurality of threads based at least in part on an amount of data associated with at least one of the groups of backflow data.
1 Assignment
0 Petitions
Accused Products
Abstract
Processing backflow data includes obtaining backflow data from a data warehouse, determining, according to a backflow rule for the backflow data, a respective destination table in a production system for each data item in the backflow data, and sending the data item according to the determined respective destination table in the production system.
15 Citations
10 Claims
-
1. A method for processing backflow data, comprising:
-
obtaining backflow data from a data warehouse; determining, according to a backflow rule for the backflow data, a respective destination table in a production system for each data item in the backflow data; and sending the data item according to the determined respective destination table in the production system, wherein sending the data item includes grouping backflow data to the determined destination tables in the production system, wherein data items in the backflow data associated with the same destination table are included in the same group, and sending the backflow data according to the grouping using a plurality of threads, wherein data items in each group are sent to the same destination table in the production system by the same thread; wherein sending the data item according to the determined respective destination table in the production system further comprises distributing groups of backflow data to the plurality of threads based at least in part on an amount of data associated with at least one of the groups of backflow data. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A backflow processing system, comprising:
-
a processor configured to; obtain backflow data from a data warehouse; determine, according to a backflow rule for the backflow data, a respective destination table in a production system for each data item in the backflow data; and send the data item according to the determined respective destination table in the production system, wherein sending the data item includes grouping backflow data to the determined destination tables in the production system, wherein data items in the backflow data associated with the same destination table are included in the same group, and sending the backflow data according to the grouping using a plurality of threads, wherein data items in each group are sent to the same destination table in the production system by the same threat wherein sending the data item according to the determined respective destination table in the production system further comprises distributing groups of backflow data to the plurality of threads based at least in part on an amount of data associated with at least one of the groups of backflow data; and a memory coupled to the processor, configured to provide the processor with instructions. - View Dependent Claims (7, 8, 9, 10)
-
Specification