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

Class BaseHttpEmittingConfig

java.lang.Object
org.apache.druid.java.util.emitter.core.BaseHttpEmittingConfig
Direct Known Subclasses:
HttpEmitterConfig
public class BaseHttpEmittingConfig extends Object

  • Field Details

    • DEFAULT_FLUSH_MILLIS

      public static final long DEFAULT_FLUSH_MILLIS
      See Also:

    • DEFAULT_FLUSH_COUNTS

      public static final int DEFAULT_FLUSH_COUNTS
      See Also:

    • DEFAULT_MAX_BATCH_SIZE

      public static final int DEFAULT_MAX_BATCH_SIZE
      ensure the event buffers don't use more than 10% of memory by default

    • DEFAULT_BATCH_QUEUE_SIZE_LIMIT

      public static final int DEFAULT_BATCH_QUEUE_SIZE_LIMIT

    • TEST_FLUSH_TIMEOUT_MILLIS

      public static final long TEST_FLUSH_TIMEOUT_MILLIS

    • DEFAULT_FLUSH_TIME_OUT

      public static final long DEFAULT_FLUSH_TIME_OUT
      Do not time out in case flushTimeOut is not set
      See Also:

    • DEFAULT_BATCHING_STRATEGY

      public static final BatchingStrategy DEFAULT_BATCHING_STRATEGY

    • DEFAULT_CONTENT_ENCODING

      public static final ContentEncoding DEFAULT_CONTENT_ENCODING

    • DEFAULT_HTTP_TIMEOUT_ALLOWANCE_FACTOR

      public static final float DEFAULT_HTTP_TIMEOUT_ALLOWANCE_FACTOR
      See Also:

    • DEFAULT_MIN_HTTP_TIMEOUT_MILLIS

      public static final int DEFAULT_MIN_HTTP_TIMEOUT_MILLIS
      The default value effective doesn't set the min timeout
      See Also:

  • Constructor Details

    • BaseHttpEmittingConfig

      public BaseHttpEmittingConfig()

  • Method Details

    • getDefaultBatchSizeAndLimit

      public static Pair<Integer,Integer> getDefaultBatchSizeAndLimit(long maxMemory)

    • getFlushMillis

      public long getFlushMillis()

    • getFlushCount

      public int getFlushCount()

    • getFlushTimeOut

      public long getFlushTimeOut()

    • getBasicAuthentication

      public PasswordProvider getBasicAuthentication()

    • getBatchingStrategy

      public BatchingStrategy getBatchingStrategy()

    • getMaxBatchSize

      public int getMaxBatchSize()

    • getContentEncoding

      public ContentEncoding getContentEncoding()

    • getBatchQueueSizeLimit

      public int getBatchQueueSizeLimit()

    • getHttpTimeoutAllowanceFactor

      public float getHttpTimeoutAllowanceFactor()

    • getMinHttpTimeoutMillis

      public int getMinHttpTimeoutMillis()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • toStringBase

      protected String toStringBase()