io.druid.java.util.emitter.core

Class HttpPostEmitter

java.lang.Object

io.druid.java.util.emitter.core.HttpPostEmitter

All Implemented Interfaces:

Emitter, Closeable, Flushable, AutoCloseable

public class HttpPostEmitter
extends Object
implements Flushable, Closeable, Emitter

Constructor Summary

Constructors

Constructor and Description
HttpPostEmitter(HttpEmitterConfig config, org.asynchttpclient.AsyncHttpClient client)
HttpPostEmitter(HttpEmitterConfig config, org.asynchttpclient.AsyncHttpClient client, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
void	close()
void	emit(Event event)
void	flush()
ConcurrentTimeCounter	getBatchFillingTimeCounter()
int	getBuffersToEmit()
int	getBuffersToReuse()
int	getDroppedBuffers()
long	getEventsToEmit()
int	getFailedBuffers()
ConcurrentTimeCounter	getFailedSendingTimeCounter()
long	getLargeEventsToEmit()
ConcurrentTimeCounter	getSuccessfulSendingTimeCounter()
int	getTotalAllocatedBuffers() This and the following methods are public for external monitoring purposes.
long	getTotalEmittedEvents()
void	start()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

HttpPostEmitter

public HttpPostEmitter(HttpEmitterConfig config,
                       org.asynchttpclient.AsyncHttpClient client)

HttpPostEmitter

public HttpPostEmitter(HttpEmitterConfig config,
                       org.asynchttpclient.AsyncHttpClient client,
                       com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

start

public void start()

Specified by:

start in interface Emitter

emit

public void emit(Event event)

Specified by:

emit in interface Emitter

flush

public void flush()
           throws IOException

Specified by:

flush in interface Emitter

Specified by:

flush in interface Flushable

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Emitter

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

getTotalAllocatedBuffers

public int getTotalAllocatedBuffers()

This and the following methods are public for external monitoring purposes.

getBuffersToEmit

public int getBuffersToEmit()

getBuffersToReuse

public int getBuffersToReuse()

getFailedBuffers

public int getFailedBuffers()

getDroppedBuffers

public int getDroppedBuffers()

getTotalEmittedEvents

public long getTotalEmittedEvents()

getEventsToEmit

public long getEventsToEmit()

getLargeEventsToEmit

public long getLargeEventsToEmit()

getBatchFillingTimeCounter

public ConcurrentTimeCounter getBatchFillingTimeCounter()

getSuccessfulSendingTimeCounter

public ConcurrentTimeCounter getSuccessfulSendingTimeCounter()

getFailedSendingTimeCounter

public ConcurrentTimeCounter getFailedSendingTimeCounter()