File tree Expand file tree Collapse file tree 3 files changed +5
-5
lines changed
main/scala/org/apache/spark/sql/execution/aggregate2
test/scala/org/apache/spark/sql
hive/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change 17
17
18
18
package org .apache .spark .sql .execution .aggregate2
19
19
20
- import java .util .{HashSet => JHashSet , Set => JSet }
20
+ import java .util .{HashSet => JHashSet , Set => JSet }
21
21
22
22
import org .apache .spark .annotation .DeveloperApi
23
23
import org .apache .spark .rdd .RDD
Original file line number Diff line number Diff line change @@ -174,7 +174,7 @@ class SQLQuerySuite extends QueryTest with BeforeAndAfterAll with SQLTestUtils {
174
174
case generatedAgg : GeneratedAggregate => hasGeneratedAgg = true
175
175
case _ =>
176
176
}
177
- if (! hasGeneratedAgg && conf.aggregate2 == false ) {
177
+ if (! hasGeneratedAgg && sqlContext.getConf( SQLConf . AGGREGATE_2 ) == false ) {
178
178
fail(
179
179
s """
180
180
|Codegen is enabled, but query $sqlText does not have GeneratedAggregate in the plan.
@@ -1369,11 +1369,11 @@ class SQLQuerySuite extends QueryTest with BeforeAndAfterAll with SQLTestUtils {
1369
1369
class SQLNewUDAFQuerySuite extends SQLQuerySuite {
1370
1370
override def beforeAll () {
1371
1371
super .beforeAll()
1372
- sqlCtx .setConf(SQLConf .AGGREGATE_2 , " true" )
1372
+ sqlContext .setConf(SQLConf .AGGREGATE_2 , " true" )
1373
1373
}
1374
1374
1375
1375
override def afterAll () {
1376
- sqlCtx .setConf(SQLConf .AGGREGATE_2 , " false" )
1376
+ sqlContext .setConf(SQLConf .AGGREGATE_2 , " false" )
1377
1377
super .afterAll()
1378
1378
}
1379
1379
}
Original file line number Diff line number Diff line change 17
17
18
18
package org .apache .spark .sql .hive
19
19
20
- import java .util .{Set => JSet }
20
+ import java .util .{Set => JSet }
21
21
22
22
import org .apache .hadoop .hive .ql .udf .generic .GenericUDAFEvaluator .AggregationBuffer
23
23
import org .apache .hadoop .hive .ql .udf .generic .GenericUDFUtils .ConversionHelper
You can’t perform that action at this time.
0 commit comments