druid-scala-client

KO | EN

gitlite — search

#python #hacktoberfest #react #typescript #android #rust #docker #nodejs #macos #java #windows #awesome #kubernetes #pytorch

druid-scala-client

(★ 16)

A Scala client for Druid

druid-scala-client Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

Getting started (requires the Wikipedia example to be running):

See also https://github.com/daggerrz/druid-scala-client/blob/master/src/test/scala/com/tapad/druid/client/WikipediaExample.scala

```scala
    import scala.concurrent.ExecutionContext
    import org.joda.time.{DateTime, Interval}
    import scala.util.{Failure, Success}

implicit val executionContext = ExecutionContext.Implicits.global
    val client = DruidClient("http://localhost:8083")

import com.tapad.druid.client.DSL._
    val query = GroupByQuery(
      source = "wikipedia",
      interval = new Interval(new DateTime().minusDays(1), new DateTime()),
      dimensions = Seq("page"),
      granularity = Granularity.All,
      aggregate = Seq(
        sum("count") as "edits",
        sum("added") as "chars_added"
      ),
      postAggregate = Seq(
        "chars_added" / "edits" as "chars_per_edit"
      ),
      filter = "namespace" === "article" and "country" === "United States",
      orderBy = Seq(
        "chars_added" desc
      ),
      limit = Some(100)
    )

client(query).onComplete {
      case Success(resp) =>
        resp.data.foreach { row =>
          println("Page %s, %s edits, %s chars added, %s per edit".format(
            row("page"), row("edits"), row("chars_added"), row("chars_per_edit")
          ))
        }
      case Failure(ex) =>
        ex.printStackTrace()
    }
```

druid-scala-client

druid-scala-client Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

druid-scala-client

druid-scala-client Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README