Newer
Older
trip = new.tableRef("trip", "PostgreSQL", "postgre.config", "public")
airport = new.tableRef("airport", "HBase", "hbase-site.xml", "default")
q = merge(subset(query.from(trip),
function(e) e$duration > 480L,
c(depart)),
query.from(airport), by.x="depart", by.y="code")
results = query.force(q)
print(results)