Class TestTransactionalState

java.lang.Object
org.apache.storm.trident.topology.state.TransactionalState
org.apache.storm.trident.topology.state.TestTransactionalState

public class TestTransactionalState extends TransactionalState
Facilitates testing of non-public methods in the parent class.
  • Constructor Details

    • TestTransactionalState

      protected TestTransactionalState(Map<String,Object> conf, String id, String subroot)
      Matching constructor in absence of a default constructor in the parent class.
  • Method Details

    • createNode

      public static void createNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework curator, String rootDir, byte[] data, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, org.apache.storm.shade.org.apache.zookeeper.CreateMode mode) throws Exception
      Throws:
      Exception