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
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