Skip to main content

Apply Model on Stream

Synopsis​

This operator makes the application of RapidMiner models on supported data streaming platforms available.

Description​

The model will be applied on every single record arriving from the input stream.

This is a streaming operator and needs to be placed inside a Streaming Nest operator. The operator defines the logical functionality and can be used in all streaming analytic workflow for any supported streaming platform (currently Flink and Spark). The actual implementation used depends on the type of connection connected to the Streaming Nest operator in which this operator is placed.

Keep in mind, that the cluster needs to be properly set up in advance (e.g.: RapidMiner on Flink), and you need to take the implications of running RapidMiner models, potentially in parallel, into account. This operation is on a best effort basis!

Input​

input stream​

The input of this streaming operation. It needs to receive the output of a preceding streaming operator, to define the flow of data events in the streaming analytic workflow.

model​

The model to apply on the stream records.

Output​

output stream​

The output of this streaming operation. Connect it to the next streaming operator to define the flow of the data events in the designed streaming analytic workflow.

Parameters​

Rapidminer home​

This parameter allows you to configure the location of the RapidMiner installation for RaaP (RapidMiner-as-a-Plugin) on the used cluster. Notice this is cluster dependant and might change with different connections used.

Rapidminer user home​

This parameter allows you to set the user-home (.RapidMiner) for RaaP (RapidMiner-as-a-Plugin), for example for additional extensions to be used. Notice this is cluster dependant and might change with different connections used.