You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by bi...@apache.org on 2012/03/02 16:59:53 UTC
svn commit: r1296267 [7/7] - in /incubator/accumulo/branches/1.4/src:
core/src/main/java/org/apache/accumulo/core/client/impl/
core/src/main/java/org/apache/accumulo/core/client/impl/thrift/
core/src/main/java/org/apache/accumulo/core/gc/thrift/ core/s...
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/DistributedTrace.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/DistributedTrace.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/DistributedTrace.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/DistributedTrace.java Fri Mar 2 15:59:50 2012
@@ -20,13 +20,13 @@ import java.io.IOException;
import java.net.InetAddress;
import java.net.UnknownHostException;
+import org.apache.accumulo.cloudtrace.instrument.Tracer;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.Instance;
import org.apache.accumulo.core.zookeeper.ZooReader;
import org.apache.accumulo.core.zookeeper.ZooUtil;
import org.apache.zookeeper.KeeperException;
-import cloudtrace.instrument.Tracer;
public class DistributedTrace {
public static void enable(Instance instance, ZooReader zoo, String application, String address) throws IOException, KeeperException, InterruptedException {
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTree.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTree.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTree.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTree.java Fri Mar 2 15:59:50 2012
@@ -23,8 +23,9 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
-import cloudtrace.instrument.Span;
-import cloudtrace.thrift.RemoteSpan;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
+
public class SpanTree {
final Map<Long,List<Long>> parentChildren = new HashMap<Long,List<Long>>();
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTreeVisitor.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTreeVisitor.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTreeVisitor.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/SpanTreeVisitor.java Fri Mar 2 15:59:50 2012
@@ -18,7 +18,8 @@ package org.apache.accumulo.core.trace;
import java.util.Collection;
-import cloudtrace.thrift.RemoteSpan;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
+
public interface SpanTreeVisitor {
void visit(int level, RemoteSpan parent, RemoteSpan node, Collection<RemoteSpan> children);
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceDump.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceDump.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceDump.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceDump.java Fri Mar 2 15:59:50 2012
@@ -28,6 +28,7 @@ import java.util.List;
import java.util.Map.Entry;
import java.util.Set;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Scanner;
import org.apache.accumulo.core.client.ZooKeeperInstance;
@@ -40,7 +41,6 @@ import org.apache.commons.cli.Option;
import org.apache.commons.cli.Options;
import org.apache.hadoop.io.Text;
-import cloudtrace.thrift.RemoteSpan;
public class TraceDump {
static final long DEFAULT_TIME_IN_MILLIS = 10 * 60 * 1000l;
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceFormatter.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceFormatter.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceFormatter.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/TraceFormatter.java Fri Mar 2 15:59:50 2012
@@ -21,6 +21,7 @@ import java.util.Date;
import java.util.Iterator;
import java.util.Map.Entry;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
import org.apache.accumulo.core.data.Key;
import org.apache.accumulo.core.data.Value;
import org.apache.accumulo.core.util.format.DefaultFormatter;
@@ -31,7 +32,6 @@ import org.apache.thrift.TException;
import org.apache.thrift.protocol.TCompactProtocol;
import org.apache.thrift.transport.TMemoryInputTransport;
-import cloudtrace.thrift.RemoteSpan;
/**
* A formatter than can be used in the shell to display trace information.
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/ZooTraceClient.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/ZooTraceClient.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/ZooTraceClient.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/trace/ZooTraceClient.java Fri Mar 2 15:59:50 2012
@@ -22,13 +22,13 @@ import java.util.List;
import java.util.Map;
import java.util.Random;
+import org.apache.accumulo.cloudtrace.instrument.receivers.SendSpansViaThrift;
import org.apache.accumulo.core.zookeeper.ZooReader;
import org.apache.log4j.Logger;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
-import cloudtrace.instrument.receivers.SendSpansViaThrift;
/**
* Find a Span collector via zookeeper and push spans there via Thrift RPC
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java Fri Mar 2 15:59:50 2012
@@ -18,6 +18,7 @@ package org.apache.accumulo.core.util;
import java.net.InetSocketAddress;
+import org.apache.accumulo.cloudtrace.instrument.thrift.TraceWrap;
import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
import org.apache.accumulo.core.client.impl.ClientExec;
@@ -37,7 +38,6 @@ import org.apache.thrift.transport.TTran
import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.transport.TTransportFactory;
-import cloudtrace.instrument.thrift.TraceWrap;
public class ThriftUtil {
private static final Logger log = Logger.getLogger(ThriftUtil.class);
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/TraceCommand.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/TraceCommand.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/TraceCommand.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/TraceCommand.java Fri Mar 2 15:59:50 2012
@@ -19,6 +19,7 @@ package org.apache.accumulo.core.util.sh
import java.io.IOException;
import java.util.Map;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.accumulo.core.client.Scanner;
import org.apache.accumulo.core.conf.Property;
import org.apache.accumulo.core.data.Range;
@@ -31,7 +32,6 @@ import org.apache.accumulo.core.util.she
import org.apache.commons.cli.CommandLine;
import org.apache.hadoop.io.Text;
-import cloudtrace.instrument.Trace;
public class TraceCommand extends DebugCommand {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/BulkImporter.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/BulkImporter.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/BulkImporter.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/BulkImporter.java Fri Mar 2 15:59:50 2012
@@ -32,6 +32,7 @@ import java.util.concurrent.ExecutorServ
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
+import org.apache.accumulo.cloudtrace.instrument.TraceRunnable;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
@@ -68,7 +69,6 @@ import org.apache.hadoop.io.Text;
import org.apache.log4j.Logger;
import org.apache.thrift.TServiceClient;
-import cloudtrace.instrument.TraceRunnable;
public class BulkImporter {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/ClientServiceHandler.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/ClientServiceHandler.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/ClientServiceHandler.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/client/ClientServiceHandler.java Fri Mar 2 15:59:50 2012
@@ -24,6 +24,7 @@ import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.Callable;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloSecurityException;
import org.apache.accumulo.core.client.Instance;
@@ -50,7 +51,6 @@ import org.apache.accumulo.start.classlo
import org.apache.log4j.Logger;
import org.apache.thrift.TException;
-import cloudtrace.thrift.TInfo;
public class ClientServiceHandler implements ClientService.Iface {
private static final Logger log = Logger.getLogger(ClientServiceHandler.class);
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java Fri Mar 2 15:59:50 2012
@@ -28,6 +28,8 @@ import java.util.concurrent.ExecutorServ
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.conf.Property;
import org.apache.accumulo.core.gc.thrift.GCStatus;
@@ -52,8 +54,6 @@ import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransportException;
import org.apache.zookeeper.KeeperException;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
public class GarbageCollectWriteAheadLogs {
private static final Logger log = Logger.getLogger(GarbageCollectWriteAheadLogs.class);
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java Fri Mar 2 15:59:50 2012
@@ -31,6 +31,12 @@ import java.util.concurrent.ExecutorServ
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
+import org.apache.accumulo.cloudtrace.instrument.CountSampler;
+import org.apache.accumulo.cloudtrace.instrument.Sampler;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.instrument.thrift.TraceWrap;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
@@ -89,12 +95,6 @@ import org.apache.hadoop.io.Text;
import org.apache.log4j.Logger;
import org.apache.zookeeper.KeeperException;
-import cloudtrace.instrument.CountSampler;
-import cloudtrace.instrument.Sampler;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
-import cloudtrace.instrument.thrift.TraceWrap;
-import cloudtrace.thrift.TInfo;
public class SimpleGarbageCollector implements Iface {
private static final Text EMPTY_TEXT = new Text();
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogService.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogService.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogService.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogService.java Fri Mar 2 15:59:50 2012
@@ -32,6 +32,8 @@ import java.util.HashSet;
import java.util.List;
import java.util.Set;
+import org.apache.accumulo.cloudtrace.instrument.thrift.TraceWrap;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloSecurityException;
import org.apache.accumulo.core.conf.AccumuloConfiguration;
@@ -76,8 +78,6 @@ import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.Watcher.Event.KeeperState;
-import cloudtrace.instrument.thrift.TraceWrap;
-import cloudtrace.thrift.TInfo;
/**
* A Mutation logging service.
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogWriter.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogWriter.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogWriter.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/logger/LogWriter.java Fri Mar 2 15:59:50 2012
@@ -40,6 +40,9 @@ import java.util.concurrent.ConcurrentHa
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.conf.AccumuloConfiguration;
import org.apache.accumulo.core.conf.Property;
@@ -71,9 +74,6 @@ import org.apache.hadoop.io.WritableName
import org.apache.hadoop.io.compress.DefaultCodec;
import org.apache.thrift.TException;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
-import cloudtrace.thrift.TInfo;
/**
* Write log operations to open {@link org.apache.hadoop.io.SequenceFile}s referenced by log id's.
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/Master.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/Master.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/Master.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/Master.java Fri Mar 2 15:59:50 2012
@@ -38,6 +38,8 @@ import java.util.TreeSet;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
+import org.apache.accumulo.cloudtrace.instrument.thrift.TraceWrap;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
@@ -175,8 +177,6 @@ import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Stat;
-import cloudtrace.instrument.thrift.TraceWrap;
-import cloudtrace.thrift.TInfo;
/**
* The Master is responsible for assigning and balancing tablets and loggers to tablet servers.
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/BulkImport.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/BulkImport.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/BulkImport.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/BulkImport.java Fri Mar 2 15:59:50 2012
@@ -32,6 +32,7 @@ import java.util.concurrent.ThreadFactor
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
+import org.apache.accumulo.cloudtrace.instrument.TraceExecutorService;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Instance;
@@ -71,7 +72,6 @@ import org.apache.hadoop.io.MapFile;
import org.apache.log4j.Logger;
import org.apache.thrift.TException;
-import cloudtrace.instrument.TraceExecutorService;
/*
* Bulk import makes requests of tablet servers, and those requests can take a
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/TraceRepo.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/TraceRepo.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/TraceRepo.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/master/tableOps/TraceRepo.java Fri Mar 2 15:59:50 2012
@@ -16,12 +16,12 @@
*/
package org.apache.accumulo.server.master.tableOps;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.instrument.Tracer;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.server.fate.Repo;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
-import cloudtrace.instrument.Tracer;
-import cloudtrace.thrift.TInfo;
/**
*
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ListType.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ListType.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ListType.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ListType.java Fri Mar 2 15:59:50 2012
@@ -22,6 +22,7 @@ import java.util.Map.Entry;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
import org.apache.accumulo.core.client.Scanner;
import org.apache.accumulo.core.data.Key;
import org.apache.accumulo.core.data.Range;
@@ -32,7 +33,6 @@ import org.apache.accumulo.server.monito
import org.apache.accumulo.server.monitor.util.celltypes.StringType;
import org.apache.hadoop.io.Text;
-import cloudtrace.thrift.RemoteSpan;
public class ListType extends Basic {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ShowTrace.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ShowTrace.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ShowTrace.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/ShowTrace.java Fri Mar 2 15:59:50 2012
@@ -25,6 +25,7 @@ import java.util.Set;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
import org.apache.accumulo.core.client.Scanner;
import org.apache.accumulo.core.data.Key;
import org.apache.accumulo.core.data.Range;
@@ -36,7 +37,6 @@ import org.apache.accumulo.core.trace.Tr
import org.apache.accumulo.server.monitor.servlets.BasicServlet;
import org.apache.hadoop.io.Text;
-import cloudtrace.thrift.RemoteSpan;
public class ShowTrace extends Basic {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/Summary.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/Summary.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/Summary.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/monitor/servlets/trace/Summary.java Fri Mar 2 15:59:50 2012
@@ -23,6 +23,7 @@ import java.util.TreeMap;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
import org.apache.accumulo.core.client.Scanner;
import org.apache.accumulo.core.data.Key;
import org.apache.accumulo.core.data.Range;
@@ -35,7 +36,6 @@ import org.apache.accumulo.server.monito
import org.apache.accumulo.server.monitor.util.celltypes.StringType;
import org.apache.hadoop.io.Text;
-import cloudtrace.thrift.RemoteSpan;
public class Summary extends Basic {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Compactor.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Compactor.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Compactor.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Compactor.java Fri Mar 2 15:59:50 2012
@@ -25,6 +25,8 @@ import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.Callable;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.accumulo.core.conf.AccumuloConfiguration;
import org.apache.accumulo.core.data.ByteSequence;
import org.apache.accumulo.core.data.Key;
@@ -54,8 +56,6 @@ import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.log4j.Logger;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
public class Compactor implements Callable<CompactionStats> {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java Fri Mar 2 15:59:50 2012
@@ -46,6 +46,8 @@ import java.util.concurrent.atomic.Atomi
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.locks.ReentrantLock;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.impl.ScannerImpl;
@@ -127,8 +129,6 @@ import org.apache.log4j.Logger;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.KeeperException.NoNodeException;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
/**
*
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java Fri Mar 2 15:59:50 2012
@@ -62,6 +62,10 @@ import java.util.concurrent.atomic.Atomi
import javax.management.ObjectName;
import javax.management.StandardMBean;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.instrument.thrift.TraceWrap;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
@@ -196,10 +200,6 @@ import org.apache.thrift.server.TServer;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.KeeperException.NoNodeException;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
-import cloudtrace.instrument.thrift.TraceWrap;
-import cloudtrace.thrift.TInfo;
enum ScanRunState {
QUEUED, RUNNING, FINISHED
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java Fri Mar 2 15:59:50 2012
@@ -35,6 +35,7 @@ import java.util.concurrent.ThreadPoolEx
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
+import org.apache.accumulo.cloudtrace.instrument.TraceExecutorService;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.conf.AccumuloConfiguration;
import org.apache.accumulo.core.conf.Property;
@@ -53,7 +54,6 @@ import org.apache.hadoop.conf.Configurat
import org.apache.hadoop.fs.FileSystem;
import org.apache.log4j.Logger;
-import cloudtrace.instrument.TraceExecutorService;
/**
* ResourceManager is responsible for managing the resources of all tablets within a tablet server.
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java Fri Mar 2 15:59:50 2012
@@ -21,6 +21,7 @@ import java.util.Arrays;
import java.util.Random;
import java.util.TreeSet;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
@@ -62,7 +63,6 @@ import org.apache.hadoop.io.Text;
import org.apache.log4j.Level;
import org.apache.log4j.Logger;
-import cloudtrace.instrument.Trace;
public class TestIngest {
public static final Authorizations AUTHS = new Authorizations("L1", "L2", "G1", "GROUP2");
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/VerifyIngest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/VerifyIngest.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/VerifyIngest.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/VerifyIngest.java Fri Mar 2 15:59:50 2012
@@ -21,6 +21,7 @@ import java.util.Iterator;
import java.util.Map.Entry;
import java.util.Random;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Instance;
@@ -38,7 +39,6 @@ import org.apache.accumulo.server.test.T
import org.apache.hadoop.io.Text;
import org.apache.log4j.Logger;
-import cloudtrace.instrument.Trace;
public class VerifyIngest {
private static String username = "root";
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousIngest.java Fri Mar 2 15:59:50 2012
@@ -23,6 +23,10 @@ import java.util.UUID;
import java.util.zip.CRC32;
import java.util.zip.Checksum;
+import org.apache.accumulo.cloudtrace.instrument.CountSampler;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.instrument.Tracer;
+import org.apache.accumulo.cloudtrace.instrument.receivers.ZooSpanClient;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.BatchWriter;
import org.apache.accumulo.core.client.Connector;
@@ -39,10 +43,6 @@ import org.apache.log4j.Level;
import org.apache.log4j.Logger;
import org.apache.log4j.PatternLayout;
-import cloudtrace.instrument.CountSampler;
-import cloudtrace.instrument.Trace;
-import cloudtrace.instrument.Tracer;
-import cloudtrace.instrument.receivers.ZooSpanClient;
public class ContinuousIngest {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousWalk.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousWalk.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousWalk.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousWalk.java Fri Mar 2 15:59:50 2012
@@ -22,6 +22,10 @@ import java.util.Map.Entry;
import java.util.Random;
import java.util.zip.CRC32;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.instrument.Tracer;
+import org.apache.accumulo.cloudtrace.instrument.receivers.ZooSpanClient;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Instance;
@@ -39,10 +43,6 @@ import org.apache.log4j.Level;
import org.apache.log4j.Logger;
import org.apache.log4j.PatternLayout;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
-import cloudtrace.instrument.Tracer;
-import cloudtrace.instrument.receivers.ZooSpanClient;
public class ContinuousWalk {
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/performance/thrift/NullTserver.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/performance/thrift/NullTserver.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/performance/thrift/NullTserver.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/performance/thrift/NullTserver.java Fri Mar 2 15:59:50 2012
@@ -25,6 +25,7 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
import org.apache.accumulo.core.client.ZooKeeperInstance;
import org.apache.accumulo.core.client.impl.Tables;
import org.apache.accumulo.core.data.KeyExtent;
@@ -60,7 +61,6 @@ import org.apache.accumulo.server.zookee
import org.apache.hadoop.io.Text;
import org.apache.thrift.TException;
-import cloudtrace.thrift.TInfo;
/**
* The purpose of this class is to server as fake tserver that is a data sink like /dev/null. NullTserver modifies the !METADATA location entries for a table to
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFSDataInputStream.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFSDataInputStream.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFSDataInputStream.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFSDataInputStream.java Fri Mar 2 15:59:50 2012
@@ -18,10 +18,10 @@ package org.apache.accumulo.server.trace
import java.io.IOException;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.hadoop.fs.FSDataInputStream;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
public class TraceFSDataInputStream extends FSDataInputStream {
@Override
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFileSystem.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFileSystem.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFileSystem.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceFileSystem.java Fri Mar 2 15:59:50 2012
@@ -19,6 +19,8 @@ package org.apache.accumulo.server.trace
import java.io.IOException;
import java.net.URI;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.apache.accumulo.core.util.ArgumentChecker;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.BlockLocation;
@@ -33,8 +35,6 @@ import org.apache.hadoop.fs.PathFilter;
import org.apache.hadoop.fs.permission.FsPermission;
import org.apache.hadoop.util.Progressable;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
// If FileSystem was an interface, we could use a Proxy, but it's not, so we have to override everything manually
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceServer.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceServer.java?rev=1296267&r1=1296266&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceServer.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/trace/TraceServer.java Fri Mar 2 15:59:50 2012
@@ -21,6 +21,9 @@ import java.net.ServerSocket;
import java.nio.channels.ServerSocketChannel;
import java.util.TimerTask;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
+import org.apache.accumulo.cloudtrace.thrift.SpanReceiver;
import org.apache.accumulo.core.Constants;
import org.apache.accumulo.core.client.BatchWriter;
import org.apache.accumulo.core.client.Connector;
@@ -55,9 +58,6 @@ import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.Watcher.Event.KeeperState;
-import cloudtrace.instrument.Span;
-import cloudtrace.thrift.RemoteSpan;
-import cloudtrace.thrift.SpanReceiver;
public class TraceServer implements Watcher {
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/CountSampler.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/CountSampler.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/CountSampler.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/CountSampler.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/CountSampler.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/CountSampler.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/CountSampler.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import java.util.Random;
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Sampler.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Sampler.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Sampler.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Sampler.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Sampler.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Sampler.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Sampler.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
/**
* Extremely simple callback to determine the frequency that an action should be performed.
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Span.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Span.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Span.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Span.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Span.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Span.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Span.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import java.util.Map;
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Trace.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Trace.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Trace.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Trace.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Trace.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Trace.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Trace.java Fri Mar 2 15:59:50 2012
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
-import cloudtrace.thrift.TInfo;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
/**
* A Trace allows a user to gather global, distributed, detailed performance information while requesting a service. The general usage for a user is to do
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceCallable.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceCallable.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceCallable.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceCallable.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceCallable.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceCallable.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceCallable.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import java.util.concurrent.Callable;
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceExecutorService.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceExecutorService.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceExecutorService.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceExecutorService.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceExecutorService.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceExecutorService.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceExecutorService.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import java.util.ArrayList;
import java.util.Collection;
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceProxy.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceProxy.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceProxy.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceProxy.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceProxy.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceProxy.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceProxy.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceRunnable.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceRunnable.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceRunnable.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceRunnable.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceRunnable.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/TraceRunnable.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/TraceRunnable.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
/**
* Wrap a Runnable with a Span that survives a change in threads.
Copied: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Tracer.java (from r1296227, incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Tracer.java)
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Tracer.java?p2=incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Tracer.java&p1=incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Tracer.java&r1=1296227&r2=1296267&rev=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/cloudtrace/instrument/Tracer.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/Tracer.java Fri Mar 2 15:59:50 2012
@@ -14,17 +14,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import java.security.SecureRandom;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
-import cloudtrace.instrument.impl.NullSpan;
-import cloudtrace.instrument.impl.RootMilliSpan;
-import cloudtrace.instrument.receivers.SpanReceiver;
-import cloudtrace.thrift.TInfo;
+import org.apache.accumulo.cloudtrace.instrument.impl.NullSpan;
+import org.apache.accumulo.cloudtrace.instrument.impl.RootMilliSpan;
+import org.apache.accumulo.cloudtrace.instrument.receivers.SpanReceiver;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
+
/**
* A Tracer provides the implementation for collecting and distributing Spans within a process.
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/MilliSpan.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/MilliSpan.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/MilliSpan.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/MilliSpan.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.impl;
+package org.apache.accumulo.cloudtrace.instrument.impl;
import java.security.SecureRandom;
import java.util.Collections;
@@ -22,8 +22,9 @@ import java.util.HashMap;
import java.util.Map;
import java.util.Random;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Tracer;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Tracer;
+
/**
* A Span implementation that stores its information in milliseconds since the epoch.
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/NullSpan.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/NullSpan.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/NullSpan.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/NullSpan.java Fri Mar 2 15:59:50 2012
@@ -14,12 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.impl;
+package org.apache.accumulo.cloudtrace.instrument.impl;
import java.util.Collections;
import java.util.Map;
-import cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+
/**
* A Span that does nothing. Used to avoid returning and checking for nulls when we are not tracing.
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/RootMilliSpan.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/RootMilliSpan.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/RootMilliSpan.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/impl/RootMilliSpan.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.impl;
+package org.apache.accumulo.cloudtrace.instrument.impl;
/**
* Span that roots the span tree in a process, but perhaps not the whole trace.
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/AsyncSpanReceiver.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/AsyncSpanReceiver.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/AsyncSpanReceiver.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/AsyncSpanReceiver.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.receivers;
+package org.apache.accumulo.cloudtrace.instrument.receivers;
import java.util.AbstractQueue;
import java.util.HashMap;
@@ -23,9 +23,9 @@ import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.ConcurrentLinkedQueue;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
import org.apache.log4j.Logger;
-import cloudtrace.thrift.RemoteSpan;
/**
* Deliver Span information periodically to a destination.
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/LogSpans.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/LogSpans.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/LogSpans.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/LogSpans.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.receivers;
+package org.apache.accumulo.cloudtrace.instrument.receivers;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SendSpansViaThrift.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SendSpansViaThrift.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SendSpansViaThrift.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SendSpansViaThrift.java Fri Mar 2 15:59:50 2012
@@ -14,19 +14,19 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.receivers;
+package org.apache.accumulo.cloudtrace.instrument.receivers;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.Map;
+import org.apache.accumulo.cloudtrace.thrift.RemoteSpan;
+import org.apache.accumulo.cloudtrace.thrift.SpanReceiver.Client;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
-import cloudtrace.thrift.RemoteSpan;
-import cloudtrace.thrift.SpanReceiver.Client;
/**
* Send Span data to a destination using thrift.
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SpanReceiver.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SpanReceiver.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SpanReceiver.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/SpanReceiver.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.receivers;
+package org.apache.accumulo.cloudtrace.instrument.receivers;
import java.util.Map;
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/ZooSpanClient.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/ZooSpanClient.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/ZooSpanClient.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/receivers/ZooSpanClient.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.receivers;
+package org.apache.accumulo.cloudtrace.instrument.receivers;
import java.io.IOException;
import java.util.ArrayList;
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/thrift/TraceWrap.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/thrift/TraceWrap.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/thrift/TraceWrap.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/instrument/thrift/TraceWrap.java Fri Mar 2 15:59:50 2012
@@ -14,17 +14,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument.thrift;
+package org.apache.accumulo.cloudtrace.instrument.thrift;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
-import cloudtrace.instrument.Span;
-import cloudtrace.instrument.Trace;
-import cloudtrace.instrument.Tracer;
-import cloudtrace.thrift.TInfo;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.instrument.Tracer;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
+
/**
* To move trace data from client to server, the RPC call must be annotated to take a TInfo object as its first argument. The user can simply pass null, so long
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/RemoteSpan.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/RemoteSpan.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/RemoteSpan.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/RemoteSpan.java Fri Mar 2 15:59:50 2012
@@ -3,7 +3,7 @@
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
*/
-package cloudtrace.thrift;
+package org.apache.accumulo.cloudtrace.thrift;
public class RemoteSpan implements org.apache.thrift.TBase<RemoteSpan, RemoteSpan._Fields>, java.io.Serializable, Cloneable {
private static final long serialVersionUID = 1L;
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/SpanReceiver.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/SpanReceiver.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/SpanReceiver.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/SpanReceiver.java Fri Mar 2 15:59:50 2012
@@ -3,7 +3,7 @@
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
*/
-package cloudtrace.thrift;
+package org.apache.accumulo.cloudtrace.thrift;
public class SpanReceiver {
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TInfo.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TInfo.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TInfo.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TInfo.java Fri Mar 2 15:59:50 2012
@@ -3,7 +3,7 @@
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
*/
-package cloudtrace.thrift;
+package org.apache.accumulo.cloudtrace.thrift;
public class TInfo implements org.apache.thrift.TBase<TInfo, TInfo._Fields>, java.io.Serializable, Cloneable {
private static final long serialVersionUID = 1L;
Modified: incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TestService.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TestService.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TestService.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/main/java/org/apache/accumulo/cloudtrace/thrift/TestService.java Fri Mar 2 15:59:50 2012
@@ -3,7 +3,7 @@
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
*/
-package cloudtrace.thrift;
+package org.apache.accumulo.cloudtrace.thrift;
public class TestService {
Modified: incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/CountSamplerTest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/CountSamplerTest.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/CountSamplerTest.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/CountSamplerTest.java Fri Mar 2 15:59:50 2012
@@ -14,10 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import junit.framework.Assert;
+import org.apache.accumulo.cloudtrace.instrument.CountSampler;
import org.junit.Test;
public class CountSamplerTest {
Modified: incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/PerformanceTest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/PerformanceTest.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/PerformanceTest.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/PerformanceTest.java Fri Mar 2 15:59:50 2012
@@ -14,8 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
import org.junit.Test;
public class PerformanceTest {
Modified: incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/TracerTest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/TracerTest.java?rev=1296267&r1=1296227&r2=1296267&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/TracerTest.java (original)
+++ incubator/accumulo/branches/1.4/src/trace/src/test/java/org/apache/accumulo/cloudtrace/instrument/TracerTest.java Fri Mar 2 15:59:50 2012
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package cloudtrace.instrument;
+package org.apache.accumulo.cloudtrace.instrument;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
@@ -28,6 +28,13 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import org.apache.accumulo.cloudtrace.instrument.Span;
+import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.cloudtrace.instrument.Tracer;
+import org.apache.accumulo.cloudtrace.instrument.receivers.SpanReceiver;
+import org.apache.accumulo.cloudtrace.instrument.thrift.TraceWrap;
+import org.apache.accumulo.cloudtrace.thrift.TInfo;
+import org.apache.accumulo.cloudtrace.thrift.TestService;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
@@ -37,10 +44,6 @@ import org.apache.thrift.transport.TSock
import org.apache.thrift.transport.TTransport;
import org.junit.Test;
-import cloudtrace.instrument.receivers.SpanReceiver;
-import cloudtrace.instrument.thrift.TraceWrap;
-import cloudtrace.thrift.TInfo;
-import cloudtrace.thrift.TestService;
public class TracerTest {
static class SpanStruct {