Builder

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. def build(): DruidBeamConfig

8. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

10. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

11. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

12. def firehoseBufferSize(x: Int): Builder

    Size of buffer used by firehose to store events.

    Size of buffer used by firehose to store events.

    Default is 100000.

13. def firehoseChunkSize(x: Int): Builder

    Maximum number of events to send to Druid in one HTTP request.

    Maximum number of events to send to Druid in one HTTP request. Larger batches will be broken up.

    Default is 1000.

14. def firehoseGracePeriod(x: org.scala_tools.time.Imports.Period): Builder

    Druid indexing tasks will shut down this long after the windowPeriod has elapsed.

    Druid indexing tasks will shut down this long after the windowPeriod has elapsed. The purpose of this extra delay is to allow time to receive the last few events that are valid from our perspective. Otherwise, we could think an event is just barely on-time, but the index task may not be available to receive it.

    Default is 5 minutes.

15. def firehoseQuietPeriod(x: org.scala_tools.time.Imports.Period): Builder

    When we create new Druid indexing tasks, wait this long for the task to appear before complaining that it cannot be found.

    When we create new Druid indexing tasks, wait this long for the task to appear before complaining that it cannot be found.

    Default is 1 minute.

16. def firehoseRetryPeriod(x: org.scala_tools.time.Imports.Period): Builder

    If a push to Druid fails for some apparently-transient reason, retry for this long before complaining that the events could not be pushed.

    If a push to Druid fails for some apparently-transient reason, retry for this long before complaining that the events could not be pushed.

    Default is 1 minute.

17. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

18. def hashCode(): Int

    Definition Classes

    AnyRef → Any

19. def indexRetryPeriod(x: org.scala_tools.time.Imports.Period): Builder

    If an indexing service overlord call fails for some apparently-transient reason, retry for this long before giving up.

    If an indexing service overlord call fails for some apparently-transient reason, retry for this long before giving up.

    Default is 1 minute.

20. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

21. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

22. final def notify(): Unit

    Definition Classes

    AnyRef

23. final def notifyAll(): Unit

    Definition Classes

    AnyRef

24. def overlordLocator(x: String): Builder

    Strategy for locating the Druid Overlord.

    Strategy for locating the Druid Overlord. Can be "curator".

    Default is "curator".

25. def overlordPollPeriod(x: org.scala_tools.time.Imports.Period): Builder

    How often to poll the Overlord for task locations.

    How often to poll the Overlord for task locations. Only applies if taskLocator is "overlord".

    Default is 20 seconds.

26. def randomizeTaskId(x: Boolean): Builder

    True if we should add a random suffix to Druid task IDs.

    True if we should add a random suffix to Druid task IDs. This is useful for testing, since it allows us to re-submit tasks that would otherwise conflict with each other. But for the same reason, it's risky in production, since it allows us to re-submit tasks that conflict with each other.

    Default is false.

27. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

28. def taskLocator(x: String): Builder

    Strategy for locating Druid tasks.

    Strategy for locating Druid tasks. Can be "curator" or "overlord".

    Default is "curator".

29. def toString(): String

    Definition Classes

    AnyRef → Any

30. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

32. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )