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)