Skip to content

Commit fd30e25

Browse files
committed
added override
1 parent 69b3b70 commit fd30e25

File tree

4 files changed

+50
-50
lines changed

4 files changed

+50
-50
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,15 @@ import org.apache.spark.sql.catalyst.CatalystConf
2323
import org.apache.spark.sql.catalyst.expressions._
2424
import org.apache.spark.sql.catalyst.plans.logical._
2525
import org.apache.spark.sql.catalyst.rules._
26-
import org.apache.spark.sql.catalyst.test.SimpleConf
26+
import org.apache.spark.sql.catalyst.test.SimpleCatalystConf
2727
import org.apache.spark.sql.types._
2828

2929
/**
3030
* A trivial [[Analyzer]] with an [[EmptyCatalog]] and [[EmptyFunctionRegistry]]. Used for testing
3131
* when all relations are already filled in and the analyzer needs only to resolve attribute
3232
* references.
3333
*/
34-
object SimpleAnalyzer extends Analyzer(EmptyCatalog, EmptyFunctionRegistry, new SimpleConf(true))
34+
object SimpleAnalyzer extends Analyzer(EmptyCatalog, EmptyFunctionRegistry, new SimpleCatalystConf(true))
3535

3636
/**
3737
* Provides a logical query plan analyzer, which translates [[UnresolvedAttribute]]s and
Original file line numberDiff line numberDiff line change
@@ -1,43 +1,43 @@
1-
/*
2-
* Licensed to the Apache Software Foundation (ASF) under one or more
3-
* contributor license agreements. See the NOTICE file distributed with
4-
* this work for additional information regarding copyright ownership.
5-
* The ASF licenses this file to You under the Apache License, Version 2.0
6-
* (the "License"); you may not use this file except in compliance with
7-
* the License. You may obtain a copy of the License at
8-
*
9-
* http://www.apache.org/licenses/LICENSE-2.0
10-
*
11-
* Unless required by applicable law or agreed to in writing, software
12-
* distributed under the License is distributed on an "AS IS" BASIS,
13-
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14-
* See the License for the specific language governing permissions and
15-
* limitations under the License.
16-
*/
17-
18-
package org.apache.spark.sql.catalyst.test
19-
20-
import org.apache.spark.sql.catalyst.CatalystConf
21-
22-
import scala.collection.immutable
23-
import scala.collection.mutable
24-
25-
/** A CatalystConf that can be used for local testing. */
26-
class SimpleConf(caseSensitive: Boolean) extends CatalystConf {
27-
val map = mutable.Map[String, String]()
28-
29-
def caseSensitiveAnalysis: Boolean = caseSensitive
30-
31-
def setConf(key: String, value: String) : Unit = {
32-
map.put(key, value)
33-
}
34-
def getConf(key: String) : String ={
35-
map.get(key).get
36-
}
37-
def getConf(key: String, defaultValue: String) : String = {
38-
map.getOrElse(key, defaultValue)
39-
}
40-
def getAllConfs: immutable.Map[String, String] = {
41-
map.toMap
42-
}
43-
}
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one or more
3+
* contributor license agreements. See the NOTICE file distributed with
4+
* this work for additional information regarding copyright ownership.
5+
* The ASF licenses this file to You under the Apache License, Version 2.0
6+
* (the "License"); you may not use this file except in compliance with
7+
* the License. You may obtain a copy of the License at
8+
*
9+
* http://www.apache.org/licenses/LICENSE-2.0
10+
*
11+
* Unless required by applicable law or agreed to in writing, software
12+
* distributed under the License is distributed on an "AS IS" BASIS,
13+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
* See the License for the specific language governing permissions and
15+
* limitations under the License.
16+
*/
17+
18+
package org.apache.spark.sql.catalyst.test
19+
20+
import org.apache.spark.sql.catalyst.CatalystConf
21+
22+
import scala.collection.immutable
23+
import scala.collection.mutable
24+
25+
/** A CatalystConf that can be used for local testing. */
26+
class SimpleCatalystConf(caseSensitive: Boolean) extends CatalystConf {
27+
val map = mutable.Map[String, String]()
28+
29+
override def caseSensitiveAnalysis: Boolean = caseSensitive
30+
31+
override def setConf(key: String, value: String) : Unit = {
32+
map.put(key, value)
33+
}
34+
override def getConf(key: String) : String ={
35+
map.get(key).get
36+
}
37+
override def getConf(key: String, defaultValue: String) : String = {
38+
map.getOrElse(key, defaultValue)
39+
}
40+
override def getAllConfs: immutable.Map[String, String] = {
41+
map.toMap
42+
}
43+
}

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/AnalysisSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,13 +24,13 @@ import org.apache.spark.sql.catalyst.expressions._
2424
import org.apache.spark.sql.catalyst.plans.logical._
2525
import org.apache.spark.sql.types._
2626
import org.apache.spark.sql.catalyst.CatalystConf
27-
import org.apache.spark.sql.catalyst.test.SimpleConf
27+
import org.apache.spark.sql.catalyst.test.SimpleCatalystConf
2828
import org.apache.spark.sql.catalyst.dsl.expressions._
2929
import org.apache.spark.sql.catalyst.dsl.plans._
3030

3131
class AnalysisSuite extends FunSuite with BeforeAndAfter {
32-
val caseSensitiveConf = new SimpleConf(true)
33-
val caseInsensitiveConf = new SimpleConf(false)
32+
val caseSensitiveConf = new SimpleCatalystConf(true)
33+
val caseInsensitiveConf = new SimpleCatalystConf(false)
3434

3535
val caseSensitiveCatalog = new SimpleCatalog(caseSensitiveConf)
3636
val caseInsensitiveCatalog = new SimpleCatalog(caseInsensitiveConf)

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/DecimalPrecisionSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,11 @@ package org.apache.spark.sql.catalyst.analysis
2020
import org.apache.spark.sql.catalyst.expressions._
2121
import org.apache.spark.sql.catalyst.plans.logical.{Union, Project, LocalRelation}
2222
import org.apache.spark.sql.types._
23-
import org.apache.spark.sql.catalyst.test.SimpleConf
23+
import org.apache.spark.sql.catalyst.test.SimpleCatalystConf
2424
import org.scalatest.{BeforeAndAfter, FunSuite}
2525

2626
class DecimalPrecisionSuite extends FunSuite with BeforeAndAfter {
27-
val conf = new SimpleConf(true)
27+
val conf = new SimpleCatalystConf(true)
2828
val catalog = new SimpleCatalog(conf)
2929
val analyzer = new Analyzer(catalog, EmptyFunctionRegistry, conf)
3030

0 commit comments

Comments
 (0)