org.apache.accumulo.trace.instrument.receivers
public class SendSpansViaThrift extends AsyncSpanReceiver<String,SpanReceiver.Client>
host, service
Constructor and Description |
---|
SendSpansViaThrift(String host,
String service,
long millis) |
Modifier and Type | Method and Description |
---|---|
protected SpanReceiver.Client |
createDestination(String destination) |
protected String |
getSpanKey(Map<String,String> data) |
protected void |
send(SpanReceiver.Client client,
RemoteSpan s) |
flush, span
protected SpanReceiver.Client createDestination(String destination) throws Exception
createDestination
in class AsyncSpanReceiver<String,SpanReceiver.Client>
Exception
protected void send(SpanReceiver.Client client, RemoteSpan s) throws Exception
send
in class AsyncSpanReceiver<String,SpanReceiver.Client>
Exception
protected String getSpanKey(Map<String,String> data)
getSpanKey
in class AsyncSpanReceiver<String,SpanReceiver.Client>
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.