Development environment for real-time dataflow programming language

Abstract

A dataflow programming language can be used to express reactive dataflow programs that can be used in pattern-driven real-time data analysis. One or more tools are provided for the dataflow programming language for checking syntactic and semantic correctness, checking logical correctness, debugging, translation of source code into a secure, portable format (e.g., packaged code), translation of source code (or packaged code) into platform-specific code, batch-mode interpretation, interactive interpretation, simulation and visualization of the dataflow environment, remote execution, monitoring, or any combination of these. These tools embody a method of developing, debugging, and deploying a dataflow graph device.

The invention claimed is: 
     
         1 - 26 . (canceled) 
     
     
         27 . A method comprising:
 providing a development environment allowing a user to select a data stream and a reactive function corresponding to a pattern of data in the data stream;   creating a dataflow program based on the data stream and the reactive function;   translating the dataflow program into translated program statements and generating platform-specific hardware instructions corresponding to the translated program statements for execution on a hardware platform.   
     
     
         28 . The method of  claim 27 , wherein translating the data flow program comprises translating the dataflow program into the translated program statements in a first phase and generating the platform-specific hardware instructions in a second phase. 
     
     
         29 . The method of  claim 27 , wherein the development environment further allows the user to identify a timed event for comparison with the pattern of the data in the data stream. 
     
     
         30 . The method of  claim 27 , wherein providing the development environment comprises providing a graphical user interface comprising a selectable blocks comprising an input block corresponding to the data stream. 
     
     
         31 . The method of  claim 27 , wherein the selectable blocks further comprises compute blocks corresponding to state machines. 
     
     
         32 . The method of  claim 27 , further comprising generating an emulation of a hardware platform and executing the platform-specific hardware instructions using the emulation. 
     
     
         33 . The method of  claim 27 , further comprising providing a simulation of the data flow as an input to the emulation of the hardware platform and inspecting performance of the emulation in executing the platform-specific hardware instructions responsive to the simulation of the data flow. 
     
     
         34 . The method of  claim 27 , further comprising providing the platform-specific hardware instructions to edge computing hardware of a smart building. 
     
     
         35 . The method of  claim 27 , wherein the reactive function is configured to process the data stream without backtracking. 
     
     
         36 . A computer-readable medium storing instructions that, when executed by one or more processors, cause the one or more processors to perform operations comprising:
 providing a development environment allowing a user to select a data stream and a reactive function corresponding to a pattern of data in the data stream;   creating a dataflow program based on the data stream and the reactive function;   translating the dataflow program into translated program statements and generating platform-specific hardware instructions corresponding to the translated program statements for execution on a hardware platform.   
     
     
         37 . The computer-readable medium of  claim 36 , wherein the development environment further allows the user to identify a timed event for comparison with the pattern of the data in the data stream. 
     
     
         38 . The computer-readable medium of  claim 36 , wherein providing the development environment comprises providing a graphical user interface comprising a selectable blocks comprising an input block corresponding to the data stream. 
     
     
         39 . The computer-readable medium of  claim 36 , wherein the selectable blocks further comprises compute blocks corresponding to state machines. 
     
     
         40 . The computer-readable medium of  claim 36 , the operations further comprising generating an emulation of a hardware platform and executing the platform-specific hardware instructions using the emulation. 
     
     
         41 . The computer-readable medium of  claim 36 , the operations further comprising providing a simulation of the data flow as an input to the emulation of the hardware platform. 
     
     
         42 . The computer-readable medium of  claim 41 , the operations further comprising inspecting performance of the emulation in executing the platform-specific hardware instructions responsive to the simulation of the data flow. 
     
     
         43 . The computer-readable medium of  claim 36 , wherein the reactive function is configured to process the data stream without backtracking. 
     
     
         44 . A system, comprising:
 an industrial machine comprising hardware; and   a computing system programmed to perform operations comprising:
 providing a development environment allowing a user to select a data stream and a reactive function corresponding to a pattern of data in the data stream; 
 creating a dataflow program based on the data stream and the reactive function; 
 translating the dataflow program into translated program statements and generating platform-specific hardware instructions corresponding to the translated program statements for execution on the hardware. 
   
     
     
         45 . The system of  claim 44 , wherein the industrial machine is associated with a smart building. 
     
     
         46 . The system of  claim 44 , wherein the hardware is edge computing hardware of the industrial machine.