// Path: src/main/java/net/pixelcop/sewer/Event.java
// public interface Event extends Writable {
// 
// }
// 
// Path: src/main/java/net/pixelcop/sewer/node/NodeConfig.java
// public class NodeConfig extends Configuration {
// 
//   public static final String SOURCE = "sewer.source";
//   public static final String SINK = "sewer.sink";
//   public static final String WAL_PATH = "sewer.wal.path";
//   public static final String PLUGINS = "sewer.plugins";
// 
//   public static final String GRAPHITE_HOST = "sewer.metrics.graphite.host";
//   public static final String GRAPHITE_PORT = "sewer.metrics.graphite.port";
//   public static final String GRAPHITE_PREFIX = "sewer.metrics.graphite.prefix";
// 
//   public NodeConfig() {
//     super();
//   }
// 
//   public NodeConfig(boolean loadDefaults) {
//     super(loadDefaults);
//   }
// 
//   public NodeConfig(Configuration other) {
//     super(other);
//   }
// 
//   /**
//    * Add the properties contained in file into this configuration
//    * @param props
//    */
//   public void addResource(Properties props) {
// 
//     for (Enumeration<?> e = props.propertyNames(); e.hasMoreElements();) {
//       String name = (String) e.nextElement();
//       set(name, props.getProperty(name));
//     }
// 
//   }
// 
// }


import static org.junit.Assert.*;
import java.io.File;
import java.io.FilenameFilter;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import net.pixelcop.sewer.Event;
import net.pixelcop.sewer.node.NodeConfig;
import org.apache.commons.lang3.RandomStringUtils;
import org.apache.hadoop.fs.FileUtil;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.SequenceFile;
import org.apache.hadoop.io.SequenceFile.Reader;
import org.apache.hadoop.io.VLongWritable;
package net.pixelcop.sewer.sink.durable;





public class TxTestHelper {

  private static final List<TxTestHelper> helpers = new ArrayList<TxTestHelper>();

  private final String tmpWalPath;
  private NodeConfig conf;

  private TransactionManager txMan;

// Path: src/main/java/net/pixelcop/sewer/Event.java
// public interface Event extends Writable {
// 
// }
// 
// Path: src/main/java/net/pixelcop/sewer/node/NodeConfig.java
// public class NodeConfig extends Configuration {
// 
//   public static final String SOURCE = "sewer.source";
//   public static final String SINK = "sewer.sink";
//   public static final String WAL_PATH = "sewer.wal.path";
//   public static final String PLUGINS = "sewer.plugins";
// 
//   public static final String GRAPHITE_HOST = "sewer.metrics.graphite.host";
//   public static final String GRAPHITE_PORT = "sewer.metrics.graphite.port";
//   public static final String GRAPHITE_PREFIX = "sewer.metrics.graphite.prefix";
// 
//   public NodeConfig() {
//     super();
//   }
// 
//   public NodeConfig(boolean loadDefaults) {
//     super(loadDefaults);
//   }
// 
//   public NodeConfig(Configuration other) {
//     super(other);
//   }
// 
//   /**
//    * Add the properties contained in file into this configuration
//    * @param props
//    */
//   public void addResource(Properties props) {
// 
//     for (Enumeration<?> e = props.propertyNames(); e.hasMoreElements();) {
//       String name = (String) e.nextElement();
//       set(name, props.getProperty(name));
//     }
// 
//   }
// 
// }


// Path: src/test/java/net/pixelcop/sewer/sink/durable/TxTestHelper.java
import static org.junit.Assert.*;
import java.io.File;
import java.io.FilenameFilter;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import net.pixelcop.sewer.Event;
import net.pixelcop.sewer.node.NodeConfig;
import org.apache.commons.lang3.RandomStringUtils;
import org.apache.hadoop.fs.FileUtil;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.SequenceFile;
import org.apache.hadoop.io.SequenceFile.Reader;
import org.apache.hadoop.io.VLongWritable;

package net.pixelcop.sewer.sink.durable;





public class TxTestHelper {

  private static final List<TxTestHelper> helpers = new ArrayList<TxTestHelper>();

  private final String tmpWalPath;
  private NodeConfig conf;

  private TransactionManager txMan;

  public TxTestHelper(NodeConfig conf, String tmpWalPath) throws IOException {