public class FlumeSpanReceiver extends SpanReceiver
SpanReceiver.Builder
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_FLUME_BATCHSIZE |
static String |
DEFAULT_FLUME_HOSTNAME |
static int |
DEFAULT_NUM_THREADS |
static String |
FLUME_BATCHSIZE_KEY |
static String |
FLUME_HOSTNAME_KEY |
static String |
FLUME_PORT_KEY |
static String |
NUM_THREADS_KEY |
Constructor and Description |
---|
FlumeSpanReceiver(HTraceConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the receiver and shut down the thread pool.
|
void |
receiveSpan(Span span) |
getId
public static final String NUM_THREADS_KEY
public static final int DEFAULT_NUM_THREADS
public static final String FLUME_HOSTNAME_KEY
public static final String DEFAULT_FLUME_HOSTNAME
public static final String FLUME_PORT_KEY
public static final String FLUME_BATCHSIZE_KEY
public static final int DEFAULT_FLUME_BATCHSIZE
public FlumeSpanReceiver(HTraceConfiguration conf)
public void close() throws IOException
IOException
- On error.public void receiveSpan(Span span)
receiveSpan
in class SpanReceiver
Copyright © 2021 The Apache Software Foundation. All Rights Reserved.