IP Library Granted Patent US 11,048,665
Granted Patent B2
US 11,048,665 · App. 15/935,690 · Granted Jun 29, 2021

Data replication in a distributed file system

Inventors: Teodora S. Buda (Dublin, IE); Hitham Ahmed Assem Aly Salama (Dublin, IE); Lei Xu (Dublin, IE); Patrick J. O'Sullivan (Dublin, IE); Christina Thorpe (Dublin, IE); Leandro Almeida (Dublin, IE)
Assignee: INTERNATIONAL BUSINESS MACHINES CORPORATION
G06F16/178G06F16/148G06F16/1844
View Patent ↗
Loading inventors, assignments & file history…
Monitor This Case
Get email alerts when status or documents change.
Order Certified Copies
Most orders are placed with the USPTO same day — all within 24 business hours.
Order via The Patent Place →
Pre-filled with this patent's details
Quick Facts
Patent No.
US 11,048,665
App. No.
15/935,690
Granted
Jun 29, 2021
Kind
B2
Abstract

Embodiments for data replication in a distributed file system environment by a processor. Data replication of one or more files that are more frequently used as compared to other files in a plurality of files may be increased according to hot data detected from one or more queries to a distributed file system.

Claims (32)

1. A method, by a processor, for data replication in a distributed file system environment, comprising:

storing a plurality of files in a distributed file system having data stored on a plurality of distributed nodes;

receiving one or more queries to the plurality of files, wherein the one or more queries comprise structured query language (SQL) queries;

decomposing the one or more queries to the plurality of files into terms relating to the plurality of files, wherein the terms are from one or more fields in query filters and ranges of values within the query filters; and

increasing data replication of an identified those of the plurality of files having activity greater than a predetermined threshold detected from the one or more queries, wherein the activity greater than the predetermined threshold is defined as identifying those of the plurality of files having been accessed over the predetermined threshold during an observed time window by determining which of the one or more fields in the query filters are most frequently searched and which of the ranges of values within the query filters are most frequently used.

2. The method of claim 1 , further including monitoring usage of each of the plurality of files and the one or more queries received by the distributed file system.

3. The method of claim 1 , further including analyzing the one or more queries and historical queries to identify those of the plurality of files having activity greater than the predetermined threshold.

4. The method of claim 1 , further including detecting those of the plurality of files having activity greater than the predetermined threshold using an application sensor.

5. The method of claim 1 , further including selecting one or more data partitioning strategies to separate data partitions into different files for those of the plurality of files having activity greater than the predetermined threshold.

6. The method of claim 1 , further including replicating those of the plurality of files having activity greater than the predetermined threshold in a maximum number of nodes.

7. A system for data replication in a distributed file system environment, comprising:

one or more computers with executable instructions that when executed cause the system to:

store a plurality of files in a distributed file system having data stored on a plurality of distributed nodes;

receive one or more queries to the plurality of files, wherein the one or more queries comprise structured query language (SQL) queries;

decompose the one or more queries to the plurality of files into terms relating to the plurality of files, wherein the terms are from one or more fields in query filters and ranges of values within the query filters; and

increase data replication of an identified those of the plurality of files having activity greater than a predetermined threshold detected from the one or more queries, wherein the activity greater than the predetermined threshold is defined as identifying those of the plurality of files having been accessed over the predetermined threshold during an observed time window by determining which of the one or more fields in the query filters are most frequently searched and which of the ranges of values within the query filters are most frequently used.

8. The system of claim 7 , wherein the executable instructions that when executed cause the system to monitor usage of each of the plurality of files and the one or more queries received by the distributed file system.

9. The system of claim 7 , wherein the executable instructions that when executed cause the system to analyze the one or more queries and historical queries to identify those of the plurality of files having activity greater than the predetermined threshold.

10. The system of claim 7 , wherein the executable instructions that when executed cause the system to detect those of the plurality of files having activity greater than the predetermined threshold using an application sensor.

11. The system of claim 7 , wherein the executable instructions that when executed cause the system to select one or more data partitioning strategies to separate data partitions into different files for those of the plurality of files having activity greater than the predetermined threshold.

12. The system of claim 7 , wherein the executable instructions that when executed cause the system to replicate those of the plurality of files having activity greater than the predetermined threshold in a maximum number of nodes.

13. A computer program product for, by a processor, data replication in a distributed file system environment, the computer program product comprising a non-transitory computer-readable storage medium having computer-readable program code portions stored therein, the computer-readable program code portions comprising:

an executable portion that stores a plurality of files in a distributed file system having data stored on a plurality of distributed nodes;

an executable portion that receives one or more queries to the plurality of files, wherein the one or more queries comprise structured query language (SQL) queries;

an executable portion that decomposes the one or more queries to the plurality of files into terms relating to the plurality of files, wherein the terms are from one or more fields in query filters and ranges of values within the query filters; and

an executable portion that increases data replication of an identified those of the plurality of files having activity greater than a predetermined threshold detected from the one or more queries, wherein the activity greater than the predetermined threshold is defined as identifying those of the plurality of files having been accessed over the predetermined threshold during an observed time window by determining which of the one or more fields in the query filters are most frequently searched and which of the ranges of values within the query filters are most frequently used.

14. The computer program product of claim 13 , further including an executable portion that monitors usage of each of the plurality of files and the one or more queries received by the distributed file system.

15. The computer program product of claim 13 , further including an executable portion that analyzes the one or more queries and historical queries to identify those of the plurality of files having activity greater than the predetermined threshold.

16. The computer program product of claim 13 , further including an executable portion that detects those of the plurality of files having activity greater than the predetermined threshold using an application sensor.

17. The computer program product of claim 13 , further including an executable portion that:

selects one or more data partitioning strategies to separate data partitions into different files for those of the plurality of files having activity greater than the predetermined threshold; and

replicates those of the plurality of files having activity greater than the predetermined threshold in a maximum number of nodes.

Assignments (2)
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Mar 28, 2018
From: BUDA, TEODORA S.; SALAMA, HITHAM AHMED ASSEM ALY; XU, LEI; O'SULLIVAN, PATRICK J.
To: INTERNATIONAL BUSINESS MACHINES CORPORATION
Reel/Frame 045370/0055 →
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Mar 28, 2018
From: THORPE, CHRISTINA; ALMEIDA, LEANDRO
To: UNIVERSITY COLLEGE DUBLIN
Reel/Frame 045370/0173 →
Continuity (1)
Related Publication 20190294701A1 · Sep 26, 2019