Efficiency for real-time data processing

Abstract

A computer-implemented method includes receiving a data stream and dividing the data stream into one or more data artefacts for one or more time intervals. The computer-implemented method further includes generating one or more contexts. Each of the one or more contexts are for at least one of the one or more time intervals. The computer-implemented method further includes storing each of the one or more data artefacts in shared storage. The shared storage is accessible for each of the one or more contexts. The computer-implemented method further includes, for each context of the one or more contexts: determining a dependency for the context; monitoring the context for a completion of said dependency; and responsive to the completion, releasing the dependency. The computer-implemented further includes removing those of the one or more data artefacts that do not belong to the dependency for any of the one or more contexts.

What is claimed is: 
     
         1 . A computer-implemented method for real-time data processing, comprising:
 determining, by one or more processors, a first dependency for a first context included in a plurality of contexts, wherein the first dependency comprises a first set of data artifacts stored in storage for determining whether a first average value for a first predetermined time interval exceeds a first predetermined threshold level for a first state of a computing device;   processing, by one or more processors, the first set of data artifacts stored in the storage to generate the first average value for the first predetermined time interval for the first state of the computing device;   determining, by one or more processors, a second dependency for a second context in the plurality of contexts, wherein said second dependency comprises at least a first portion of the first set of data artifacts stored in the storage for determining whether a second average value for a second predetermined time interval exceeds a second predetermined threshold level for a second state of the computing device; and   removing, by one or more processors, a second portion of data artifacts included in the first set of data artifacts from the storage that are not associated with the second dependency for the second context.   
     
     
         2 . The computer-implemented method of  claim 1 , further comprising:
 processing, by one or more processors, in real-time, a data stream of unstructured data received from a wireless sensor network of the computing device into a plurality of data artifacts based, at least in part, on: (i) one or more predetermined time intervals and (ii) a predetermined data storage capacity.   
     
     
         3 . The computer-implemented method of  claim 1 , wherein processing the first set of data artifacts stored in the storage to generate the first average value for the first predetermined time interval for the first state of the computing device further includes:
 executing, by one or more processors, a real-time action trigger.   
     
     
         4 . The computer-implemented method of  claim 3 , wherein executing the real-time action trigger includes:
 generating, by one or more processors, a push notification.   
     
     
         5 . The computer-implemented method of  claim 3 , wherein executing the real-time action trigger includes:
 integrating, by one or more processors, the first average value with the computing device.   
     
     
         6 . The computer-implemented method of  claim 1 , wherein removing the second portion of data artifacts included in the first set of data artifacts from the storage is based, at least in part, on:
 releasing, by one or more processors, a dependency associated with the second portion of data artifacts included in the first set of data artifacts.   
     
     
         7 . The computer-implemented method of  claim 1 , wherein the storage is a distributed shared storage system. 
     
     
         8 . A computer program product, the computer program product comprising one or more computer readable storage media and program instructions stored on the one or more computer readable storage media, the program instructions comprising instructions to:
 determine a first dependency for a first context included in a plurality of contexts, wherein the first dependency comprises a first set of data artifacts stored in storage for determining whether a first average value for a first predetermined time interval exceeds a first predetermined threshold level for a first state of a computing device;   process the first set of data artifacts stored in the storage to generate the first average value for the first predetermined time interval for the first state of the computing device;   determine a second dependency for a second context in the plurality of contexts, wherein said second dependency comprises at least a first portion of the first set of data artifacts stored in the storage for determining whether a second average value for a second predetermined time interval exceeds a second predetermined threshold level for a second state of the computing device; and   remove a second portion of data artifacts included in the first set of data artifacts from the storage that are not associated with the second dependency for the second context.   
     
     
         9 . The computer program product of  claim 8 , further comprising instructions to:
 process, in real-time, a data stream of unstructured data received from a wireless sensor network of the computing device into a plurality of data artifacts based, at least in part, on: (i) one or more predetermined time intervals and (ii) a predetermined data storage capacity.   
     
     
         10 . The computer program product of  claim 8 , wherein the instructions to process the first set of data artifacts stored in the storage to generate the first average value for the first predetermined time interval for the first state of the computing device further includes instructions to:
 execute a real-time action trigger.   
     
     
         11 . The computer program product of  claim 10 , wherein the instructions to execute the real-time action trigger includes instructions to:
 generate a push notification.   
     
     
         12 . The computer program product of  claim 10 , wherein the instructions to execute the real-time action trigger includes instructions to:
 integrate the first average value with the computing device.   
     
     
         13 . The computer program product of  claim 8 , wherein the instructions to remove the second portion of data artifacts included in the first set of data artifacts from the storage is based, at least in part, on instructions to:
 release a dependency associated with the second portion of data artifacts included in the first set of data artifacts.   
     
     
         14 . The computer program product of  claim 8 , wherein the storage is a distributed shared storage system. 
     
     
         15 . A computer system, the computer system comprising:
 one or more computer processors;   one or more computer readable storage media;   computer program instructions;   the computer program instructions being stored on the one or more computer readable storage media;   the computer program instructions comprising instructions to:   determine a first dependency for a first context included in a plurality of contexts, wherein the first dependency comprises a first set of data artifacts stored in storage for determining whether a first average value for a first predetermined time interval exceeds a first predetermined threshold level for a first state of a computing device;   process the first set of data artifacts stored in the storage to generate the first average value for the first predetermined time interval for the first state of the computing device;   determine a second dependency for a second context in the plurality of contexts, wherein said second dependency comprises at least a first portion of the first set of data artifacts stored in the storage for determining whether a second average value for a second predetermined time interval exceeds a second predetermined threshold level for a second state of the computing device; and   remove a second portion of data artifacts included in the first set of data artifacts from the storage that are not associated with the second dependency for the second context.   
     
     
         16 . The computer system of  claim 15 , further comprising instructions to:
 process, in real-time, a data stream of unstructured data received from a wireless sensor network of the computing device into a plurality of data artifacts based, at least in part, on: (i) one or more predetermined time intervals and (ii) a predetermined data storage capacity.   
     
     
         17 . The computer system of  claim 15 , wherein the instructions to process the first set of data artifacts stored in the storage to generate the first average value for the first predetermined time interval for the first state of the computing device further includes instructions to:
 execute a real-time action trigger.   
     
     
         18 . The computer system of  claim 17 , wherein the instructions to execute the real-time action trigger includes at least one of: (i) an instruction to generate a push notification and (ii) an instruction to integrate the first average value with the computing device. 
     
     
         19 . The computer system of  claim 15 , wherein the instructions to remove the second portion of data artifacts included in the first set of data artifacts from the storage is based, at least in part, on instructions to:
 release a dependency associated with the second portion of data artifacts included in the first set of data artifacts.   
     
     
         20 . The computer system of  claim 15 , wherein the storage is a distributed shared storage system.