org.apache.accumulo.cloudtrace.instrument.receivers
Class ZooSpanClient
java.lang.Object
org.apache.accumulo.cloudtrace.instrument.receivers.AsyncSpanReceiver<String,SpanReceiver.Client>
org.apache.accumulo.cloudtrace.instrument.receivers.SendSpansViaThrift
org.apache.accumulo.cloudtrace.instrument.receivers.ZooSpanClient
- All Implemented Interfaces:
- SpanReceiver
public class ZooSpanClient
- extends SendSpansViaThrift
Find a Span collector via zookeeper and push spans there via Thrift RPC
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ZooSpanClient
public ZooSpanClient(String keepers,
String path,
String host,
String service,
long millis)
throws IOException,
org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
IOException
org.apache.zookeeper.KeeperException
InterruptedException
flush
public void flush()
- Specified by:
flush
in interface SpanReceiver
- Overrides:
flush
in class AsyncSpanReceiver<String,SpanReceiver.Client>
getSpanKey
protected String getSpanKey(Map<String,String> data)
- Overrides:
getSpanKey
in class SendSpansViaThrift
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.