Newer
Older
trip = new.tableRef("trip", "PostgreSQL", "postgre.config", "public")
airport = new.tableRef("airport", "HBase", "hbase-site.xml", "default")
q = query.join(query.select(function (t) {
res = new.env()
res$depart = t$depart
res },
query.where(function (t) t$duration > 480L,
query.from(trip))), query.from(airport), function (t,a) t$depart == a$code)
results = query.force(q)
print(results)