Operator `SparkDecisionTree`

Specialized toolkits - release 4.3.1.0-prod20190605 > com.ibm.streamsx.sparkmllib 1.2.0 > com.ibm.streamsx.sparkmllib.tree > SparkDecisionTree

This operator provides support for analysis of incoming tuple data against Apache Spark's decision tree machine learning library.

Summary

Ports

This operator has 2 input ports and 1 output port.

Windowing

This operator does not accept any windowing configurations.

Parameters

This operator supports 4 parameters.

Required: modelPath, testDataAttr

Optional: params, sparkMaster

Metrics

This operator does not report any metrics.

Properties

Implementation: Java

Input Ports

Ports (0)

This input port is required. The operator expects an attribute of type list<float64> that will be used as input to the decision tree algorithm.

Properties

Optional: false

ControlPort: false
WindowingMode: NonWindowed
WindowPunctuationInputMode: Oblivious

Ports (1)

This input control port is optional. The port expects a single attribute of type rstring and the value must be a string in JSON format. For example, to reload the spark model, the attribute value must be set to '{"reloadModel":true}'.

Properties

Optional: true

ControlPort: true
WindowingMode: NonWindowed
WindowPunctuationInputMode: Oblivious

Output Ports

Assignments: Java operators do not support output assignments.

Ports (0)

This output port is required. The operator passes through all attributes on the input port as-is to the output port. In addition, it expects an attribute called 'analysisResult' of type float64.

Properties