Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
sparksburnitt committed Oct 1, 2015
2 parents 48ce540 + 7d41911 commit a21dc91
Showing 1 changed file with 14 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -197,6 +197,20 @@ class HBaseTpcMiniTestSuite extends TestBase {
assert(rows.length == 5)
}

test("Query 7.1") {
val sql =
s"""SELECT ss_item_sk, ss_ticket_number, sum(ss_wholesale_cost) as sum_wholesale_cost
|FROM store_sales
|WHERE ss_item_sk > 17182
|AND ss_item_sk <= 17183
|GROUP BY ss_item_sk, ss_ticket_number""".stripMargin
val rows = runSql(sql)
assert(rows.length == 1)
assert(rows(0)(0) == 17183)
assert(rows(0)(1) == 6)
assert(rows(0)(2) == 0.0) // should not be null
}

test("Query 8") {
val sql = "SELECT ss_item_sk, ss_ticket_number, min(ss_wholesale_cost) as min_wholesale_cost, max(ss_wholesale_cost) as max_wholesale_cost, avg(ss_wholesale_cost) as avg_wholesale_cost FROM store_sales WHERE ss_item_sk > 4000 AND ss_item_sk <= 5000 GROUP BY ss_item_sk, ss_ticket_number"
val rows = runSql(sql)
Expand Down

0 comments on commit a21dc91

Please sign in to comment.