Skip to content

Commit 72d3cfa

Browse files
author
Bo Meng
committed
move the debug function to the base
1 parent f45f788 commit 72d3cfa

File tree

2 files changed

+8
-9
lines changed

2 files changed

+8
-9
lines changed

src/test/scala/org/apache/spark/sql/hbase/HBaseTpcStringFormatMiniTestSuite.scala

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -847,13 +847,4 @@ class HBaseTpcStringFormatMiniTestSuite extends TestBase {
847847
assert(rows(2).get(22) == null)
848848
assert(rows(2).get(23) == -4398.98f)
849849
}
850-
851-
852-
private def printRows(rows: Array[Row]) = {
853-
println("======= QUERY RESULTS ======")
854-
for (i <- 0 until rows.size) {
855-
println(rows(i).mkString(" | "))
856-
}
857-
println("============================")
858-
}
859850
}

src/test/scala/org/apache/spark/sql/hbase/TestBase.scala

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,4 +173,12 @@ abstract class TestBase
173173
val loadSql = s"LOAD PARALL DATA LOCAL INPATH '$loadFile' INTO TABLE $tableName"
174174
runSql(loadSql)
175175
}
176+
177+
def printRows(rows: Array[Row]) = {
178+
println("======= QUERY RESULTS ======")
179+
for (i <- rows.indices) {
180+
println(rows(i).mkString(" | "))
181+
}
182+
println("============================")
183+
}
176184
}

0 commit comments

Comments
 (0)