Data summarization recovery
First Claim
1. A method for recovering a failed data summarization instance of a plurality of data summarization instances, the method comprising:
- processing one or more existing data summarization instances of the plurality of data summarization instances identified as an instance for which a new data summarization instance needs to wait;
upon a completion or a timeout of each of the one or more existing data summarization instances identified as instances for which the new data summarization instance needs to wait, acquiring an exclusive lock on a table storing scope information for the plurality of data summarization instances;
processing one or more existing data summarization instances of the plurality of data summarization instances that match the new data summarization instance or that have an overlapping scope with the new data summarization instance;
defining remaining tasks to be performed by the new data summarization instance;
releasing the exclusive lock; and
performing the remaining tasks to be performed by the new data summarization instance.
1 Assignment
0 Petitions
Accused Products
Abstract
Embodiments of the invention provide systems and methods for recovering a failed data summarization. According to one embodiment, recovering a failed instance can comprise processing existing summarization instances identified as instances for which a new data summarization instance needs to wait. Upon a completion or a timeout of each of the instances identified as instances for which the new data summarization instance needs to wait, an exclusive lock can be acquired on a table storing scope information for the plurality of data summarization instances. One or more existing data summarization instances that match the new data summarization instance or that have an overlapping scope with the new data summarization instance can be processed, remaining tasks to be performed by the new data summarization instance can be defined, the exclusive lock can be released, and the remaining tasks to be performed by the new data summarization instance can be performed.
-
Citations
20 Claims
-
1. A method for recovering a failed data summarization instance of a plurality of data summarization instances, the method comprising:
-
processing one or more existing data summarization instances of the plurality of data summarization instances identified as an instance for which a new data summarization instance needs to wait; upon a completion or a timeout of each of the one or more existing data summarization instances identified as instances for which the new data summarization instance needs to wait, acquiring an exclusive lock on a table storing scope information for the plurality of data summarization instances; processing one or more existing data summarization instances of the plurality of data summarization instances that match the new data summarization instance or that have an overlapping scope with the new data summarization instance; defining remaining tasks to be performed by the new data summarization instance; releasing the exclusive lock; and performing the remaining tasks to be performed by the new data summarization instance. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A system comprising:
-
a processor; and a memory communicatively coupled with and readable by the processor and having stored therein a sequence of instructions which, when executed by the processor, cause the processor to recover a failed data summarization instance of a plurality of data summarization instances by; processing one or more existing data summarization instances of the plurality of data summarization instances identified as an instance for which a new data summarization instance needs to wait; upon a completion or a timeout of each of the one or more existing data summarization instances identified as instances for which the new data summarization instance needs to wait, acquiring an exclusive lock on a table storing scope information for the plurality of data summarization instances; processing one or more existing data summarization instances of the plurality of data summarization instances that match the new data summarization instance or that have an overlapping scope with the new data summarization instance; defining remaining tasks to be performed by the new data summarization instance; releasing the exclusive lock; and performing the remaining tasks to be performed by the new data summarization instance. - View Dependent Claims (12, 13, 14, 15)
-
-
16. A computer-readable memory device having stored therein a sequence of instructions which, when executed by a processor, cause the processor to recover a failed data summarization instance of a plurality of data summarization instances by:
-
processing one or more existing data summarization instances of the plurality of data summarization instances identified as an instance for which a new data summarization instance needs to wait; upon a completion or a timeout of each of the one or more existing data summarization instances identified as instances for which the new data summarization instance needs to wait, acquiring an exclusive lock on a table storing scope information for the plurality of data summarization instances; processing one or more existing data summarization instances of the plurality of data summarization instances that match the new data summarization instance or that have an overlapping scope with the new data summarization instance; defining remaining tasks to be performed by the new data summarization instance; releasing the exclusive lock; and performing the remaining tasks to be performed by the new data summarization instance. - View Dependent Claims (17, 18, 19, 20)
-
Specification