class DruidAdvancedHttpClient extends DruidClient with DruidResponseHandler
- Alphabetic
- By Inheritance
- DruidAdvancedHttpClient
- DruidResponseHandler
- DruidClient
- LazyLogging
- CirceDecoders
- CirceHttpSupport
- JsonSupport
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def actorMaterializer: ActorMaterializer
- returns
the underlying akka.stream.ActorMaterializer
- Definition Classes
- DruidAdvancedHttpClient → DruidClient
- def actorSystem: ActorSystem
- returns
the underlying akka.actor.ActorSystem
- Definition Classes
- DruidAdvancedHttpClient → DruidClient
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- implicit def circeJsonMarshaller(implicit P: Printer): ToEntityMarshaller[Json]
- Definition Classes
- CirceHttpSupport
- implicit def circeJsonUnmarshaller: FromEntityUnmarshaller[Json]
- Definition Classes
- CirceHttpSupport
- implicit def circeMarshaller[A](implicit A: Encoder[A], P: Printer): ToEntityMarshaller[A]
- Definition Classes
- CirceHttpSupport
- implicit def circeUnmarshaller[A](implicit arg0: Decoder[A]): FromEntityUnmarshaller[A]
- Definition Classes
- CirceHttpSupport
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def doQuery[T <: DruidResponse](query: DruidQuery)(implicit druidConfig: DruidConfig): Future[T]
Perform a query to Druid and get its resulting response
Perform a query to Druid and get its resulting response
- query
the query to perform
- druidConfig
the configuration options
- returns
a Future holding the resulting response
- Definition Classes
- DruidAdvancedHttpClient → DruidClient
- def doQueryAsStream(query: DruidQuery)(implicit druidConfig: DruidConfig): Source[BaseResult, NotUsed]
Perform a query to Druid and get its result as an Akka Stream akka.stream.scaladsl.Source of ing.wbaa.druid.DruidResult.
Perform a query to Druid and get its result as an Akka Stream akka.stream.scaladsl.Source of ing.wbaa.druid.DruidResult.
This is useful for queries that result to responses with large payloads (Druid responds with streaming JSON)
- query
the query to perform
- druidConfig
the Druid configuration options
- returns
the resulting Akka Streams Source of ing.wbaa.druid.DruidResult
- Definition Classes
- DruidAdvancedHttpClient → DruidClient
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def handleResponse[T <: DruidResponse](response: HttpResponse, queryType: QueryType, responseParsingTimeout: FiniteDuration)(implicit materializer: ActorMaterializer, ec: ExecutionContextExecutor): Future[T]
- Attributes
- protected
- Definition Classes
- DruidResponseHandler
- def handleResponseAsStream(response: HttpResponse, queryType: QueryType): Source[BaseResult, NotUsed]
- Attributes
- protected
- Definition Classes
- DruidResponseHandler
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def healthCheck(implicit druidConfig: DruidConfig): Future[Map[QueryHost, Boolean]]
- druidConfig
the configuration options
- returns
a Map with the health status of each Druid query host, where each host is associated with a Boolean value indicating whether the host is healthy (true) or not (false)
- Definition Classes
- DruidAdvancedHttpClient → DruidClient
- val healthLogger: Logger
- Attributes
- protected
- Definition Classes
- DruidClient
- def isHealthy()(implicit druidConfig: DruidConfig): Future[Boolean]
Checks the health status of all Druid query hosts
Checks the health status of all Druid query hosts
- druidConfig
the configuration options
- returns
true when all Druid query hosts are healthy, otherwise false
- Definition Classes
- DruidAdvancedHttpClient → DruidClient
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit def jsonUnmarshaller[J](implicit arg0: Facade[J]): FromEntityUnmarshaller[J]
- Definition Classes
- JsonSupport
- lazy val logger: Logger
- Attributes
- protected
- Definition Classes
- LazyLogging
- Annotations
- @transient()
- def mapRightProjection[L, R, R1](either: Either[L, R])(f: (R) => R1): Either[L, R1]
- Attributes
- protected
- Definition Classes
- CirceDecoders
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def shutdown(): Future[Unit]
Shutdown the client and close the active connections to Druid
Shutdown the client and close the active connections to Druid
- returns
a Future which completes successfully when all active connections have been closed
- Definition Classes
- DruidAdvancedHttpClient → DruidClient
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- implicit val system: ActorSystem
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.