Tonic

Using Tonic

import scala.jdk.CollectionConverters._
import scala.jdk.OptionConverters._

import tonic.java.{ ITonic, Tonic }

val rpc: ITonic = new Tonic("127.0.0.1", 8080)

for {
  table  <- rpc.tableDescribe("processing", "user_agg").toScala
  last   <- rpc.partitionLast(table.getTblId).toScala
  parent <- rpc.partitionParent(table.getTblId, last.getCreateTime).toScala
} {
  val schema = parent.getPartSchema.asScala.head

  println(s"ITableDesc{tblId=${table.getTblId},dbLocationUri=${table.getDbLocationUri}};")
  println(s"IPart{createTime=${parent.getCreateTime},location=${parent.getLocation}};")
  println(s"IPartSchema{pkeyName=${schema.getPkeyName},partKeyVal=${schema.getPartKeyVal}};")
}

rpc.partitionFind(248, List("2021", "08", "09", "15").asJava).toScala.foreach { part =>
  println(s"IPart{createTime=${part.getCreateTime},location=${part.getLocation}};")
}

ITableDesc{tblId=59,dbLocationUri=hdfs://ensime/warehouse/tablespace/managed/hive/processing.db};
IPart{createTime=1626659658,location=hdfs://ensime/warehouse/tablespace/external/hive/processing.db/user_agg/dt=2021-07-18};
IPartSchema{pkeyName=dt,partKeyVal=2021-07-18};

IPart{createTime=1628514173,location=hdfs://ensime/data/logs/siren/year=2021/month=08/day=09/hour=15};

Prerequisites

• Java 8, 11
• Gin 0.3+

Getting Tonic

SBT users may add this to their Dependencies.scala:

resolvers += "clojars" at "https://repo.clojars.org/"

libraryDependencies += "com.ensime" % "tonic" % "0.2"

License

Copyright (C) 2022 Vadim Kornev.
Distributed under the MIT License.