xerial

      def f(a:Int, b:String, c:Int) : Unit = {}

      val f3 = f(_, _, _)

      for(m <- f3.getClass.getDeclaredMethods.find(m => m.getName == "apply" && !m.isSynthetic)) {
        val retType = m.getReturnType
        info(s"f3 class: ${f3.getClass.getName}")
        info(s"return type of f3: $retType")
      }

xerial

#!/bin/sh

if [ -z "$PROG_HOME" ] ; then
  ## resolve links - $0 may be a link to PROG_HOME
  PRG="$0"

  # need this for relative symlinks
  while [ -h "$PRG" ] ; do
    ls=`ls -ld "$PRG"`
    link=`expr "$ls" : '.*-> \(.*\)$'`

xerial

require 'formula'

class Prestop < Formula
  homepage 'https://github.com/treasure-data/presto-ops'
  head 'git@github.com:treasure-data/presto-ops.git', :branch => 'pack', :using => :git

  def install
    libexec.install Dir['*']
    bin.install_symlink "#{libexec}/bin/prestop"
    bin.install_symlink "#{libexec}/bin/prestop-shell"

xerial

import xerial.lens.ObjectSchema

class RequestDispatcher {

  // Prepare mappings from a path to ObjectSchema of an WebApp class
  private val webAppMapping = {
    // ObjectSchema contains a list of methods
    for(cl <- webAppClasses; schema <- ObjectSchema.of(cl)) yield { 
      val basePath = m.findAnnotaionOf[path].map(_.value)getOrElse("/" + schema.name)
      basePath -> schema

xerial

Presto JDBC Setup

This is how to connect Treasure Data's Presto using Presto JDBC Driver:

• Download presto-jdbc driver https://prestodb.io/docs/current/installation/jdbc.html
  • For using secure HTTPS (port 443) connection you need to use presto 0.148 or later.
• Use the following parameters to connect prestobase on development server:
  • Driver name: com.facebook.presto.jdbc.PrestoDriver
  • user: (Your TD API key)
  • password: (can be empty or any string)
• Connection URL examples:

xerial

class MyServic(d1:D1, d2:D2, d3:D3, ...) 

val d1 = new D1(....)
val d2 = new D2(....)
val d3 = new D3(....)

val service = new MyService(d1, d2, d3, ...)

xerial

import wvlet.surface
import wvlet.surface.Surface

import scala.reflect.runtime.{universe => ru}

class MapConverter[A](surface: Surface) {
  def toMap(a: A): Map[String, Any] = {
    val m = Map.newBuilder[String, Any]
    for (p <- surface.params) {
      m += (p.name -> p.get(a))

xerial

xerial

xerial

import wvlet.log.LogSupport

object MyApp extends LogSupport  {
  info("Hello airframe-log!")
  warn("This is a warning message")
  debug("debug messsages will not be shown by default")
}