druid

Type Members

1. class CuratorOverlordLocator extends OverlordLocator

2. class CuratorTaskLocator extends TaskLocator

3. class DruidBeam[A] extends Beam[A] with Logging with Closable

   A Beam that writes all messages to a fixed set of Druid tasks.

4. case class DruidBeamConfig(firehoseGracePeriod: org.scala_tools.time.Imports.Period = ..., firehoseQuietPeriod: org.scala_tools.time.Imports.Period = ..., firehoseRetryPeriod: org.scala_tools.time.Imports.Period = ..., firehoseChunkSize: Int = 1000, randomizeTaskId: Boolean = false, indexRetryPeriod: org.scala_tools.time.Imports.Period = ..., firehoseBufferSize: Int = 100000, overlordLocator: String = OverlordLocator.Curator, taskLocator: String = TaskLocator.Curator, overlordPollPeriod: org.scala_tools.time.Imports.Period = ...) extends IndexServiceConfig with Product with Serializable

5. class DruidBeamMaker[A] extends BeamMaker[A, DruidBeam[A]] with Logging

6. sealed abstract class DruidDimensions extends AnyRef

7. class DruidEnvironment extends Equals

8. class DruidGuicer extends AnyRef

9. case class DruidLocation(environment: DruidEnvironment, dataSource: String) extends Product with Serializable

10. class DruidRollup extends AnyRef

    Describes rollup (dimensions, aggregators, index granularity) desired for a Druid datasource.

11. sealed abstract class DruidSpatialDimension extends AnyRef

12. case class DruidTuning(maxRowsInMemory: Int = 75000, intermediatePersistPeriod: Period = ..., maxPendingPersists: Int = 0, buildV9Directly: Boolean = false) extends Product with Serializable

13. class IndexService extends Closable

14. trait IndexServiceConfig extends AnyRef

15. sealed trait IndexServiceException extends AnyRef

16. class IndexServicePermanentException extends Exception with IndexServiceException

    Exceptions that are permanent in nature, and are useless to retry externally.

17. class IndexServiceTransientException extends Exception with IndexServiceException

    Exceptions that indicate transient indexing service failures.

18. sealed trait IndexStatus extends AnyRef

19. case class MultipleFieldDruidSpatialDimension(name: String, fieldNames: Seq[String]) extends DruidSpatialDimension with Product with Serializable

20. trait OverlordLocator extends AnyRef

21. class OverlordTaskLocator extends TaskLocator

22. case class SchemalessDruidDimensions(dimensionExclusions: Set[String], spatialDimensions: Seq[DruidSpatialDimension] = immutable.this.Nil) extends DruidDimensions with Product with Serializable

23. case class SingleFieldDruidSpatialDimension(name: String) extends DruidSpatialDimension with Product with Serializable

24. case class SpecificDruidDimensions(dimensions: Seq[String], spatialDimensions: Seq[DruidSpatialDimension] = immutable.this.Nil) extends DruidDimensions with Product with Serializable

25. class TaskClient extends Logging with Closable

    Client for a single Druid task.

26. trait TaskLocator extends AnyRef

27. case class TaskPointer(id: String, serviceKey: String) extends Product with Serializable