Method and system for spilling from a queue to a persistent store
AssigneeOracle International Corporation
InventorsHoyong Park, Namit Jain, Anand Srinivasan, Shailendra Mishra
Life of this patent
Estimating the term…
Abstract
Techniques for managing memory usage of a processing system by spilling data from a memory to a persistent store based upon an evict policy are provided. A triggering event is detected. In response to the triggering event and based on the evict policy, it is determined whether data from the memory of the processing system is to be spilled to the persistent storage. The determination is made by comparing a level of free memory of the processing system with a threshold specified by the evict policy. The data is evicted from the memory.
Claims19
A method performed by a data stream processing system for managing memory usage of the data stream processing system, the method comprising:
- detecting a triggering event;
- responsive to the triggering event, determining, based upon an evict policy, whether data from a memory of the data stream processing system is to be spilled to a persistent storage, wherein the memory includes a plurality of buffer queues, and wherein the determining comprises:
- determining a threshold from a plurality of thresholds associated with a current state of the data stream processing system based upon the evict policy;
- and
- comparing the threshold with a level of free memory of the data stream processing system;
- and
- evicting the data from the memory.
A computer-readable storage medium storing a computer program product for managing memory usage of a data stream processing system, the computer program product comprising:
- computer code for detecting a triggering event;
- computer code for responsive to the triggering event, determining, based upon an evict policy, whether data from a memory of the data stream processing system is to be spilled to a persistent storage, wherein the memory includes a plurality of buffer queues, and wherein the determining comprises:
- determining a threshold from a plurality of thresholds associated with a current state of the data stream processing system based upon the evict policy;
- and
- comparing the threshold with a level of free memory of the data stream processing system;
- and
- computer code for evicting the data from the memory.
A system comprising:
- a processor configured to:
- detect a triggering event;
- responsive to the triggering event, determine, based upon an evict policy, whether data from a memory of a data stream processing system is to be spilled to a persistent storage, wherein the memory includes a plurality of buffer queues, and wherein the determining comprises:
- determining a threshold from a plurality of thresholds associated with a current state of the data stream processing system based upon the evict policy;
- and
- comparing the threshold with a level of free memory of the data stream processing system;
- and
- evict the data from the memory.
Dependencies are inferred from the claim text.