io.druid.java.util.emitter.service

Class ServiceEmitter

java.lang.Object

io.druid.java.util.emitter.service.ServiceEmitter

All Implemented Interfaces:

Emitter, Closeable, Flushable, AutoCloseable

public class ServiceEmitter
extends Object
implements Emitter

Constructor Summary

Constructors

Constructor and Description
ServiceEmitter(String service, String host, Emitter emitter)
ServiceEmitter(String service, String host, Emitter emitter, com.google.common.collect.ImmutableMap<String,String> otherServiceDimensions)

Method Summary

Modifier and Type	Method and Description
void	close()
void	emit(Event event)
void	emit(ServiceEventBuilder builder)
void	flush()
String	getHost()
String	getService()
void	start()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceEmitter

public ServiceEmitter(String service,
                      String host,
                      Emitter emitter)

ServiceEmitter

public ServiceEmitter(String service,
                      String host,
                      Emitter emitter,
                      com.google.common.collect.ImmutableMap<String,String> otherServiceDimensions)

Method Detail

getService

public String getService()

getHost

public String getHost()

start

public void start()

Specified by:

start in interface Emitter

emit

public void emit(Event event)

Specified by:

emit in interface Emitter

emit

public void emit(ServiceEventBuilder builder)

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