File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
sql/hive/src/test/java/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change 1515 * limitations under the License.
1616 */
1717
18- package org .apache .spark .sql .execution
18+ package org .apache .spark .sql .hive . execution
1919
20- import org .apache .spark .sql .types .{IntegerType , StructField , StructType }
21- import org .apache .spark .sql .{Row , QueryTest }
20+ import org .apache .spark .sql .hive .test .TestHive
2221import org .apache .spark .sql .test .TestSQLContext
22+ import org .apache .spark .sql .{QueryTest , Row }
2323import org .scalatest .BeforeAndAfterAll
2424
2525class Aggregate2Suite extends QueryTest with BeforeAndAfterAll {
2626
27- protected lazy val ctx = TestSQLContext
27+ protected lazy val ctx = TestHive
2828 import ctx .implicits ._
2929
3030 var originalUseAggregate2 : Boolean = _
@@ -43,7 +43,7 @@ class Aggregate2Suite extends QueryTest with BeforeAndAfterAll {
4343 (3 , null ),
4444 (3 , null )).toDF(" key" , " value" )
4545
46- data.registerTempTable (" agg2" )
46+ data.write.saveAsTable (" agg2" )
4747 }
4848
4949 test(" test average2 no key in output" ) {
You can’t perform that action at this time.
0 commit comments