Permalink
Browse files

Removed dev class TestRunner.java

Change-Id: I39d093f773cd477cc2de7aa843159725ccb5ccad
  • Loading branch information...
1 parent 1058fcc commit cec115db89cc859a2412bc371545643a47d0f1aa Mike Wiederhold committed Mar 14, 2011
Showing with 0 additions and 57 deletions.
  1. +0 −57 src/com/membase/jtap/TapRunner.java
@@ -1,57 +0,0 @@
-package com.membase.jtap;
-
-import org.apache.http.nio.reactor.IOReactorException;
-
-import com.membase.jtap.exporter.Exporter;
-import com.membase.jtap.exporter.FileExporter;
-import com.membase.jtap.exporter.SolrExporter;
-import com.membase.jtap.exporter.TextExporter;
-import com.membase.jtap.ops.BackfillStream;
-import com.membase.jtap.ops.CustomStream;
-import com.membase.jtap.ops.DumpStream;
-import com.membase.jtap.ops.KeysOnlyStream;
-import com.membase.jtap.ops.ListVBucketsStream;
-import com.membase.jtap.ops.TapStream;
-
-public class TapRunner {
- public static void main(String args[]) {
- int[] vbucketlist = {1, 0};
- //Exporter exporter = new FileExporter("results");
- //Exporter exporter = new TextExporter();
- Exporter exporter = null;
- try {
- exporter = new SolrExporter("http://10.2.1.11:8983");
- } catch (IOReactorException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- //TapStream tapListener = new DumpStream(exporter, "node1");
- //TapStream tapListener = new BackfillStream(exporter, "node1", null);
- /*try {
- exporter.write("key1");
- exporter.write("key2");
- Thread.sleep(10000);
- } catch (Exception e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- System.exit(0);*/
- CustomStream tapListener = new CustomStream(exporter, "node1");
- tapListener.keysOnly();
- tapListener.doDump();
- //tapListener.specifyVbuckets(vbucketlist);
- TapStreamClient client = new TapStreamClient("10.1.5.102", 11210, "default", null);
- //TapStreamClient client = new TapStreamClient("10.2.1.11", 11210, "default", null);
- client.start(tapListener);
-
- // No arrays
- // Don't pass tapStream in start
-
- /*try {
- Thread.sleep(10000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- client.stop();*/
- }
-}

0 comments on commit cec115d

Please sign in to comment.