<commit_before>/*
# Licensed Materials - Property of IBM
# Copyright IBM Corp. 2016
*/
package com.ibm.streamsx.plumbing.zookeeper;

import static com.ibm.streamsx.plumbing.zookeeper.PeCuratorFramework.getZkClient;
import static com.ibm.streamsx.plumbing.zookeeper.PeCuratorFramework.initializeZkClient;

import org.apache.curator.framework.CuratorFramework;

import com.ibm.streams.operator.AbstractOperator;
import com.ibm.streams.operator.OperatorContext;
import com.ibm.streams.operator.OutputTuple;
import com.ibm.streams.operator.StreamSchema;
import com.ibm.streams.operator.StreamingInput;
import com.ibm.streams.operator.Tuple;
import com.ibm.streams.operator.model.InputPortSet;
import com.ibm.streams.operator.model.Libraries;
import com.ibm.streams.operator.model.OutputPortSet;
import com.ibm.streams.operator.model.OutputPortSet.WindowPunctuationOutputMode;
import com.ibm.streams.operator.model.Parameter;
import com.ibm.streams.operator.model.PrimitiveOperator;
import com.ibm.streams.operator.model.SharedLoader;
import com.ibm.streams.operator.types.RString;

/**
 * Take an action against a Znode for each input tuple.
 *
 */
@PrimitiveOperator(description=ZnodeAction.DESC)
@InputPortSet(cardinality = 1)
@OutputPortSet(cardinality = 1, optional = true, windowPunctuationOutputMode = WindowPunctuationOutputMode.Preserving)
@Libraries({ "opt/apache-curator-2.7.1/*", "opt/slf4j-1.7.5/*", "opt/zookeeper-3.4.8.jar", "opt/guava-14.0.1.jar" })
@SharedLoader
public class ZnodeAction extends AbstractOperator {<commit_msg>Fix @Libraries for latest Curator update<commit_after>/*
# Licensed Materials - Property of IBM
# Copyright IBM Corp. 2016
*/
package com.ibm.streamsx.plumbing.zookeeper;

import static com.ibm.streamsx.plumbing.zookeeper.PeCuratorFramework.getZkClient;
import static com.ibm.streamsx.plumbing.zookeeper.PeCuratorFramework.initializeZkClient;

import org.apache.curator.framework.CuratorFramework;

import com.ibm.streams.operator.AbstractOperator;
import com.ibm.streams.operator.OperatorContext;
import com.ibm.streams.operator.OutputTuple;
import com.ibm.streams.operator.StreamSchema;
import com.ibm.streams.operator.StreamingInput;
import com.ibm.streams.operator.Tuple;
import com.ibm.streams.operator.model.InputPortSet;
import com.ibm.streams.operator.model.Libraries;
import com.ibm.streams.operator.model.OutputPortSet;
import com.ibm.streams.operator.model.OutputPortSet.WindowPunctuationOutputMode;
import com.ibm.streams.operator.model.Parameter;
import com.ibm.streams.operator.model.PrimitiveOperator;
import com.ibm.streams.operator.model.SharedLoader;
import com.ibm.streams.operator.types.RString;

/**
 * Take an action against a Znode for each input tuple.
 *
 */
@PrimitiveOperator(description=ZnodeAction.DESC)
@InputPortSet(cardinality = 1)
@OutputPortSet(cardinality = 1, optional = true, windowPunctuationOutputMode = WindowPunctuationOutputMode.Preserving)
@Libraries({"opt/apache-curator/*", "opt/slf4j-1.7.5/*", "opt/zookeeper-3.4.8.jar", "opt/guava-14.0.1.jar"})
@SharedLoader
public class ZnodeAction extends AbstractOperator {
{'fraction_non_alphanumeric': 0.11631663974151858, 'fraction_numerical': 0.011954765751211632, 'mean_word_length': 6.250585480093677, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1699575', 'n_tokens_mistral': 1049, 'n_tokens_neox': 1031, 'n_words': 160}