Analytic model execution engine with instrumentation for granular performance analysis for metrics and diagnostics for troubleshooting

1. A system, comprising:

a processor configured to:

receive at an interface an analytic model for processing data;

inspect the analytic model to determine a language, an action, an input type, and an output type; and

generate a virtualized execution environment for an analytic engine that includes executable code to implement the analytic model for processing an input data stream, wherein the analytic model includes an input configuration schema that specifies an input type, an output configuration schema that specifies an output type, and a stream configuration descriptor that specifies a stream type, and wherein the generating of the virtualized execution environment comprises to:

route, based on a first analytic language, the executable code to implement the analytic model for processing the input data stream to one of a plurality of runtime engines;

bind, using the virtualized execution environment, the analytic model and a stream descriptor based on a schema shared by the analytic model and the stream descriptor;

process the input data stream using the executable code, wherein a stream processor enforces the input type; and

generate an output data stream using the stream processor based on the output type; and

a memory coupled to the processor and configured to provide the processor with instructions.

2. The system recited in claim 1 , wherein the analytic model is implemented using a container to provide the virtualized execution environment for the analytic engine.

3. The system recited in claim 1 , wherein the analytic model is implemented using a container to provide the virtualized execution environment for the analytic engine, and wherein the container is a portable and independently executable microservice.

4. The system recited in claim 1 , wherein the analytic model includes an input configuration schema that specifies an input type, an output configuration schema that specifies an output type, and an I/O descriptor abstraction that specifies a stream type.

5. The system recited in claim 1 , wherein the virtualized execution environment for the analytic engine includes a plurality of runtime engines that each supports a distinct analytic model programming language.

6. The system recited in claim 1 , wherein the interface for receiving the analytic model for processing data includes an Application Programming Interface (API), a Command Line Interface (CLI), and/or a dashboard interface.

7. The system recited in claim 1 , wherein the processor is further configured to:

add a sensor to instrument the virtualized execution environment for the analytic engine, wherein the sensor provides metrics for monitoring, testing, statistically analyzing, and/or debugging a performance of the analytic model.

8. The system recited in claim 1 , wherein the processor is further configured to:

inspect the analytic model to determine code points for one or more of the following: state initialization, concurrency controls, state management, safety and reliability controls, beginning and end of model execution framework for input and output of data, and post-execution clean-up.

9. A method, comprising:

receiving at an interface an analytic model for processing data;

inspecting the analytic model to determine a language, an action, an input type, and an output type; and

generating a virtualized execution environment for an analytic engine that includes executable code to implement the analytic model for processing an input data stream, wherein the analytic model includes an input configuration schema that specifies an input type, an output configuration schema that specifies an output type, and a stream configuration descriptor that specifies a stream type, and wherein the generating of the virtualized execution environment comprises:

routing, based on a first analytic language, the executable code to implement the analytic model for processing the input data stream to one of a plurality of runtime engines;

binding, using the virtualized execution environment, the analytic model and a stream descriptor based on a schema shared by the analytic model and the stream descriptor;

processing the input data stream using the executable code, wherein a stream processor enforces the input type; and

generating an output data stream using the stream processor based on the output type.

10. The method of claim 9 , wherein the analytic model is implemented using a container to provide the virtualized execution environment for the analytic engine.

11. The method of claim 9 , wherein the analytic model is implemented using a container to provide the virtualized execution environment for the analytic engine, and wherein the container is a portable and independently executable microservice.

12. The method of claim 9 , wherein the analytic model includes an input configuration schema that specifies an input type, an output configuration schema that specifies an output type, and a stream configuration descriptor that specifies a stream type.

13. The method of claim 9 , wherein the virtualized execution environment for the analytic engine includes a plurality of runtime engines that each supports a distinct analytic model language.

14. A computer program product, the computer program product being embodied in a tangible non-transitory computer readable storage medium and comprising computer instructions for:

receiving at an interface an analytic model for processing data;

inspecting the analytic model to determine a language, an action, an input type, and an output type; and

generating a virtualized execution environment for an analytic engine that includes executable code to implement the analytic model for processing an input data stream, wherein the analytic model includes an input configuration schema that specifies an input type, an output configuration schema that specifies an output type, and a stream configuration descriptor that specifies a stream type, and wherein the generating of the virtualized execution environment comprises:

routing, based on a first analytic language, the executable code to implement the analytic model for processing the input data stream to one of a plurality of runtime engines;

binding, using the virtualized execution environment, the analytic model and a stream descriptor based on a schema shared by the analytic model and the stream descriptor;

processing the input data stream using the executable code, wherein a stream processor enforces the input type; and

generating an output data stream using the stream processor based on the output type.

15. The computer program product recited in claim 14 , wherein the analytic model is implemented using a container to provide the virtualized execution environment for the analytic engine.

16. The computer program product recited in claim 14 , wherein the analytic model is implemented using a container to provide the virtualized execution environment for the analytic engine, and wherein the container is a portable and independently executable microservice.

17. The computer program product recited in claim 14 , wherein the analytic model includes an input configuration schema that specifies an input type, an output configuration schema that specifies an output type, and a stream configuration descriptor that specifies a stream type.

18. The computer program product recited in claim 14 , wherein the virtualized execution environment for the analytic engine includes a plurality of runtime engines that each supports a distinct analytic model language.