io.druid.java.util.emitter.core

Class ParametrizedUriEmitter

java.lang.Object

io.druid.java.util.emitter.core.ParametrizedUriEmitter

All Implemented Interfaces:

Emitter, Closeable, Flushable, AutoCloseable

public class ParametrizedUriEmitter
extends Object
implements Flushable, Closeable, Emitter

Constructor Summary

Constructors

Constructor and Description
ParametrizedUriEmitter(ParametrizedUriEmitterConfig config, org.asynchttpclient.AsyncHttpClient client, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
ParametrizedUriEmitter(ParametrizedUriEmitterConfig config, org.asynchttpclient.AsyncHttpClient client, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, UriExtractor uriExtractor)

Method Summary

Modifier and Type	Method and Description
void	close()
void	emit(Event event)
void	flush()
void	forEachEmitter(BiConsumer<URI,HttpPostEmitter> action)
void	start()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ParametrizedUriEmitter

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

ParametrizedUriEmitter

public ParametrizedUriEmitter(ParametrizedUriEmitterConfig config,
                              org.asynchttpclient.AsyncHttpClient client,
                              com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                              UriExtractor uriExtractor)

Method Detail

start

public void start()

Specified by:

start in interface Emitter

emit

public void emit(Event event)

Specified by:

emit in interface Emitter

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

flush

public void flush()
           throws IOException

Specified by:

flush in interface Emitter

Specified by:

flush in interface Flushable

Throws:

IOException

forEachEmitter

public void forEachEmitter(BiConsumer<URI,HttpPostEmitter> action)

toString

public String toString()

Overrides:

toString in class Object