Grid topology change in a distributed data grid when iterating on the contents of the data grid

Patent metadata

Field	Value
Publication number	US-10970285-B2
Application number	US-201514633031-A
Country	US
Kind code	B2
Filing date	Feb 26, 2015
Priority date	Feb 26, 2015
Publication date	Apr 6, 2021
Grant date	Apr 6, 2021

Abstract

A method of communicating data in a data grid. The method includes receiving a first search request defined by search criteria of a search query. The method includes communicating the first search request to search for data segments at the first node that match the search criteria. The method includes receiving one or more data segments matching the search criteria. The method includes receiving rebalance information. The method further includes identifying a second node storing rebalance data segments of the plurality of rebalance data segments based on the rebalance information. The method further includes communicating a second search request to search for the rebalance data segments matching the search criteria. The method further includes receiving one or more rebalance data segments matching the search criteria. The method further includes determining search result data using the data segments from the first node and the rebalance data segments from the second node.

First claim

The invention claimed is:

1. A non-transitory machine-readable storage medium storing instructions which when executed cause a processing device to:
receive, from an application, search criteria of a search query;
determine that a plurality of data segments matching the search criteria of the search query are located at a first node;
communicate, to the first node, a first search request to search for data segments matching the search criteria;
receive, from the first node, a first data segment of the plurality of data segments matching the search criteria and located at the first node;
receive an indication that a second data segment of the plurality of data segments matching the search criteria and previously located at the first node is no longer stored at the first node;
receive an information indicating that the first node transferred the second data segment to a second node, wherein transferring the second data segment to the second node is subsequent to receiving the search criteria of the search query;
communicate, responsive to receiving the information indicating the second node as a new location for the second data segment, a second search request to search for the data segments matching the search criteria of the search query;
receive, from the second node, the second data segment;
determine search result data of the search query, wherein the search result data comprises the first data segment received from the first node and the second data segment received from the second node; and
send the search result data of the search query to the application.

2. The non-transitory machine-readable storage medium of claim 1 , wherein the instructions further cause the processing device to receive data location information, wherein the data location information indicates where the search result data is located at a plurality of nodes.

3. The non-transitory machine-readable storage medium of claim 1 , wherein the instructions to cause the processing device to send, to the application, the search result data are to be executed in response to determining the search result data of the search query.

4. The non-transitory machine-readable storage medium of claim 1 , wherein the instructions to cause the processing device to communicate to the second node the second search request are to be executed in response to not receiving the second data segment from the first node.

5. The non-transitory machine-readable storage medium of claim 1 , wherein the communicate and the determine the search result data occur during the search query.

6. The non-transitory machine-readable storage medium of claim 1 , wherein the first node and the second node are in the data grid.

7. The non-transitory machine-readable storage medium of claim 6 , wherein the second data segment is transferred from the first node to the second node when the second node joins the data grid.

8. A method comprising:
receiving, from an application, search criteria of a search query;
determining that a plurality of data segments matching the search criteria of the search query are located at a first node;
communicating, to the first node, a first search request to search for data segments matching the search criteria;
receiving, from the first node, a first data segment of the plurality of data segments matching the search criteria and located at the first node;
receiving an indication that a second data segment of the plurality of data segments matching the search criteria and previously located at the first node is no longer stored at the first node;
receive an information indicating that the first node transferred the second data segment to a second node, wherein transferring the second data segment to the second node is subsequent to receiving the search criteria of the search query;
communicating, responsive to receiving the information indicating the second node as a new location for the second data segment, a second search request to search for the data segments matching the search criteria of the search query;
receiving, from the second node, one or more rebalance data segments matching the search criteria;
determining search result data of the search query, wherein the search result data comprises the first data segment received from the first node and the second data segment received from the second node; and
sending the search result data of the search query to the application.

9. The method of claim 8 , further comprising receiving data location information, wherein the data location information indicates where the search result data is located at a plurality of nodes.

10. The method of claim 8 , wherein sending the search result data of the search query to the application is responsive to determining the search result data of the search query.

11. The method of claim 8 , wherein communicating to the second node the second search request is in response to not receiving the second data segment from the first node.

12. The method of claim 8 , wherein the communicating and the determining the search result data occur during the search query.

13. The method of claim 8 , wherein the first node and the second node are in the data grid.

14. The method of claim 13 , wherein the second data segment is transferred from the first node to the second node when the second node joins the data grid.

15. A first node, comprising:
a memory to store data of the first node;
a processing device coupled to the memory; and
an iterator, executed from the memory by the processing device, to:
receive, from an application, search criteria of a search query;
determine that a plurality of data segments matching the search criteria of the search query are located at a second node;
communicate, to the second node, a first search request to search for data segments at the first node that match the search criteria;
receive, from the second node, a first data segment of the plurality of data segments matching the search criteria and located at the second node;
receive an indication that a second data segment of the plurality of data segments matching the search criteria and previously located at the second node is no longer available at the second node;
receive an information indicating that the second node transferred the second data segment to a third node, wherein transferring the second data segment to the third node is subsequent to receiving the search criteria of the search query;
communicate, responsive to receiving the information indicating the third node as a new location for the second data segment, a second search request to search for the data segments matching the search criteria of the search query;
receive, from the third node, the second data segment;
determine search result data of the search query, wherein the search result data comprises the first data segment received from the second node and the second data segment received from the third node; and
send the search result data of the search query to the application.

16. The first node of claim 15 , the processing device further to receive data location information, wherein the data location information indicates where the search result data is located at a plurality of nodes.

17. The first node of claim 15 , wherein the processing device is to send the search result data to the application in response to determining the search result data of the search query.

18. The first node of claim 15 , wherein the processing device is to communicate to the third node the second search request in response to not receiving the s

Assignees

• Red Hat Inc

Inventors

• Burns William Rosenquist

Classifications

• H04L67/565

  Conversion or adaptation of application format or content (adding application control or application functional data H04L67/561) · CPC title

• H04L67/52

  specially adapted for the location of the user terminal · CPC title

• H04L67/125

  involving control of end-device applications over a network · CPC title

• H04L67/1097

  for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS] · CPC title

• G06F16/9577

  Optimising the visualization of content, e.g. distillation of HTML documents · CPC title