Operator ZnodeAction

com.ibm.streamsx.plumbing > com.ibm.streamsx.plumbing 1.0.0 > com.ibm.streamsx.plumbing.zookeeper > ZnodeAction

Take an action against a znode path for each tuple. Each input tuple results in an action against a znode defined by the parameters path and action. The actions are:
  • Create - The znode path will be created with the contents of the data attribute from the input tuple. If the znode already exists than an exception is thrown.
  • Get - The znode path will be read and its contents set to the data attribute of the output tuple. At operator initialization time the znode is created if it does not exist.
  • Set - The znode path will be set to the contents of the data attribute from the input tuple. At operator initialization time the znode is created if it does not exist.
  • Delete - The znode path will be deleted.
The data attribute is set to data if it exists, otherwise jsonString. The data attribute must be of type rstring.

If an output port exists an output tuple is submitted for each input tuple after thesuccessful znode action has occurred. Matching input atttributes are copied to output attributes, if the action is Get then the data attribute contains the contents of the znode. The ZooKeeper instance is the one that the IBM Streams instance is configured to use through its domain.

Summary

Ports
This operator has 1 input port and 1 output port.
Windowing
This operator does not accept any windowing configurations.
Parameters
This operator supports 2 parameters.

Required: action, path

Metrics
This operator does not report any metrics.

Properties

Implementation
Java

Input Ports

Ports (0)
Properties

Output Ports

Assignments
Java operators do not support output assignments.
Ports (0)

Properties

Parameters

This operator supports 2 parameters.

Required: action, path

action

Znode action to be applied for each input tuple.

Properties
path

Znode path to be actioned. The path must start with a /, for example /app1/p_1.

Properties

Libraries

Operator class library
Library Path: ../../impl/lib/com.ibm.streamsx.plumbing.jar, ../../opt/apache-curator/*, ../../opt/slf4j-1.7.5/*, ../../opt/zookeeper-3.4.8.jar, ../../opt/guava-14.0.1.jar