Silk: A framework for managing SQL data flows.

Examples

import xerial.silk.core._
import sampledb._
// SELECT count(*) FROM nasdaq
def dataCount = nasdaq.size
// SELECT time, close FROM nasdaq WHERE symbol = 'APPL'
def appleStock = nasdaq.filter(_.symbol is "APPL").select(_.time, _.close)
// You can use a raw SQL statjement as well:
def appleStockSQL = sql"SELECT time, close FROM nasdaq where symbol = 'APPL'"
// SELECT time, close FROM nasdaq WHERE symbol = 'APPL' LIMIT 10
appleStock.limit(10).print
// time-column based filtering
appleStock.between("2015年05月01日", "2015年06月01日")
for(company <- Seq("YHOO", "GOOG", "MSFT")) yield {
 nasdaq.filter(_.symbol is company).selectAll
}

Milestones