SPL File control.spl

com.ibm.streamsx.plumbing > com.ibm.streamsx.plumbing 1.0.0 > com.ibm.streamsx.plumbing.control > control.spl

Content

Operators

• ControlVariableChange: Control variable change notifications.

Functions

• getControlVariableObjectName(rstring): Get the object name in the Job Control Plane for a shared control variable.

Composites

composite ControlVariableChange(output stream<MBeanNotificationBase> CVN)

Control variable change notifications. Issues a tuple for each attribute changed notification issued by a control variable.

Parameters

• name: Name of the control variable.

Output Ports

• CVN: Control variable notifications, must be type spl.control::MBeanNotification.

SPL Source Code

 public composite ControlVariableChange(output stream<MBeanNotificationBase> CVN) {
    param expression<rstring> $name;
    graph
     stream<MBeanNotificationBase> CVN = ControlNotificationSource()
     {
        param
 	objectNames : getControlVariableObjectName($name);
 	filters : "jmx.attribute.change";
     }
 }

   

Functions

rstring getControlVariableObjectName(rstring name)

Get the object name in the Job Control Plane for a shared control variable.

Parameters

• name: Name of the control variable.

Returns

• rstring

SPL Source Code

 public rstring getControlVariableObjectName(rstring name) {
     return "com.ibm.streams.control:type=controlvariable,name=\""
         + name + "\"";  
 }