Package org.apache.druid.java.util.emitter.factory

Class HttpEmitterFactory

java.lang.Object

org.apache.druid.java.util.emitter.core.BaseHttpEmittingConfig

org.apache.druid.java.util.emitter.core.HttpEmitterConfig

org.apache.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 org.apache.druid.java.util.emitter.core.HttpEmitterConfig

HttpEmitterConfig.Builder

Field Summary

Fields inherited from class org.apache.druid.java.util.emitter.core.BaseHttpEmittingConfig

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, TEST_FLUSH_TIMEOUT_MILLIS

Constructor Summary

Constructors

Constructor	Description
HttpEmitterFactory()

Method Summary

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

Methods inherited from class org.apache.druid.java.util.emitter.core.HttpEmitterConfig

getRecipientBaseUrl, toString

Methods inherited from class org.apache.druid.java.util.emitter.core.BaseHttpEmittingConfig

getBasicAuthentication, getBatchingStrategy, getBatchQueueSizeLimit, getContentEncoding, getDefaultBatchSizeAndLimit, 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 Details

HttpEmitterFactory

public HttpEmitterFactory()

Method Details

makeEmitter

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

Specified by:

makeEmitter in interface EmitterFactory