Drag the PMML processor the canvas and connect it to the Normalize processor.

Configure the PMML processor like the following by selecting the DriverViolationPredictionModel that you uploaded to the Model Registry earlier. After this processor executes, a new field called ViolationPredicted is added to stream for the result of the prediction. In output fields, select all the contextual fields you want to pass on including the model value result.

Determine if the model predicted if the driver will commit a violation by dragging a rule processor to the canvas and configuring a rule like the following:

If a violation is predicted, send it to a Druid to display on a dashboard. Drag the Druid processor to canvas and configure. Stream the events into a cube called alerts-violation-predictions-cube.