org.apache.accumulo.trace.instrument.receivers
Class SendSpansViaThrift

java.lang.Object
  extended by org.apache.accumulo.trace.instrument.receivers.AsyncSpanReceiver<String,SpanReceiver.Client>
      extended by org.apache.accumulo.trace.instrument.receivers.SendSpansViaThrift
All Implemented Interfaces:
SpanReceiver
Direct Known Subclasses:
ZooSpanClient, ZooTraceClient

public class SendSpansViaThrift
extends AsyncSpanReceiver<String,SpanReceiver.Client>

Send Span data to a destination using thrift.


Field Summary
 
Fields inherited from class org.apache.accumulo.trace.instrument.receivers.AsyncSpanReceiver
host, service
 
Constructor Summary
SendSpansViaThrift(String host, String service, long millis)
           
 
Method Summary
protected  SpanReceiver.Client createDestination(String destination)
           
protected  String getSpanKey(Map<String,String> data)
           
protected  void send(SpanReceiver.Client client, RemoteSpan s)
           
 
Methods inherited from class org.apache.accumulo.trace.instrument.receivers.AsyncSpanReceiver
flush, span
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SendSpansViaThrift

public SendSpansViaThrift(String host,
                          String service,
                          long millis)
Method Detail

createDestination

protected SpanReceiver.Client createDestination(String destination)
                                         throws Exception
Specified by:
createDestination in class AsyncSpanReceiver<String,SpanReceiver.Client>
Throws:
Exception

send

protected void send(SpanReceiver.Client client,
                    RemoteSpan s)
             throws Exception
Specified by:
send in class AsyncSpanReceiver<String,SpanReceiver.Client>
Throws:
Exception

getSpanKey

protected String getSpanKey(Map<String,String> data)
Specified by:
getSpanKey in class AsyncSpanReceiver<String,SpanReceiver.Client>


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.