io.druid.java.util.emitter.factory

Class HttpEmitterFactory

java.lang.Object

io.druid.java.util.emitter.core.BaseHttpEmittingConfig

io.druid.java.util.emitter.core.HttpEmitterConfig

io.druid.java.util.emitter.factory.HttpEmitterFactory

All Implemented Interfaces:

EmitterFactory

public class HttpEmitterFactory
extends HttpEmitterConfig
implements EmitterFactory

Nested Class Summary

Nested classes/interfaces inherited from class io.druid.java.util.emitter.core.HttpEmitterConfig

HttpEmitterConfig.Builder

Field Summary

Fields inherited from class io.druid.java.util.emitter.core.BaseHttpEmittingConfig

DEFAULT_BASIC_AUTHENTICATION, DEFAULT_BATCH_QUEUE_SIZE_LIMIT, DEFAULT_BATCHING_STRATEGY, DEFAULT_CONTENT_ENCODING, DEFAULT_FLUSH_COUNTS, DEFAULT_FLUSH_MILLIS, DEFAULT_FLUSH_TIME_OUT, DEFAULT_HTTP_TIMEOUT_ALLOWANCE_FACTOR, DEFAULT_MAX_BATCH_SIZE, DEFAULT_MIN_HTTP_TIMEOUT_MILLIS

Constructor Summary

Constructors

Constructor and Description
HttpEmitterFactory()

Method Summary

Modifier and Type	Method and Description
Emitter	makeEmitter(com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.asynchttpclient.AsyncHttpClient httpClient, Lifecycle lifecycle)

Methods inherited from class io.druid.java.util.emitter.core.HttpEmitterConfig

getRecipientBaseUrl, toString

Methods inherited from class io.druid.java.util.emitter.core.BaseHttpEmittingConfig

getBasicAuthentication, getBatchingStrategy, getBatchQueueSizeLimit, getContentEncoding, getFlushCount, getFlushMillis, getFlushTimeOut, getHttpTimeoutAllowanceFactor, getMaxBatchSize, getMinHttpTimeoutMillis, toStringBase

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpEmitterFactory

public HttpEmitterFactory()

Method Detail

makeEmitter

public Emitter makeEmitter(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                           org.asynchttpclient.AsyncHttpClient httpClient,
                           Lifecycle lifecycle)

Specified by:

makeEmitter in interface EmitterFactory