Patent ID: 9679033
Date: 2017-06-13
CPC Classifications: G06F

Claim:
1. A method for insertion, in a data warehouse process, of a buffer operator between an upstream data operator and a downstream data operator, the method comprising: processing, by a processor, a data record for the upstream data operator to pass to the downstream data operator via a direct data communication link; determining whether the downstream data operator is ready to accept the data record based on a response signal by the downstream data operator, wherein the response signal includes an acknowledgment that the downstream data operator is ready to accept the data record; in response to determining, by the processor, that the downstream data operator is not ready to accept the data record from the upstream data operator based on the downstream data operator failing to provide the response signal within a specified time interval, inserting, by the processor, a buffer operator between the upstream data operator and the downstream data operator, wherein the buffer operator is inserted using at least one additional data communication link apart from the direct data communication link between the upstream data operator and the downstream data operator, and wherein the direct data communication link is unused until the buffer operator is removed; passing, by the processor, the data record processed by the upstream data operator to the buffer operator for storing into a buffer allocated for use by the buffer operator; passing, by the processor, the data record stored into the buffer to the downstream data operator when the downstream data operator is ready to accept data; and in response to determining, by the processor, that a buffer utilization of the buffer allocated to the buffer operator decreases to a threshold value: