File tree Expand file tree Collapse file tree 6 files changed +18
-20
lines changed
main/scala/org/apache/spark/sql/catalyst
test/scala/org/apache/spark/sql/catalyst/analysis
core/src/test/scala/org/apache/spark/sql Expand file tree Collapse file tree 6 files changed +18
-20
lines changed Original file line number Diff line number Diff line change 192
192
<id >central</id >
193
193
<!-- This should be at top, it makes maven try the central repo first and then others and hence faster dep resolution -->
194
194
<name >Maven Repository</name >
195
- <url >https ://repo1.maven.org/maven2</url >
195
+ <url >http ://repo1.maven.org/maven2</url >
196
196
<releases >
197
197
<enabled >true</enabled >
198
198
</releases >
203
203
<repository >
204
204
<id >apache-repo</id >
205
205
<name >Apache Repository</name >
206
- <url >https ://repository.apache.org/content/repositories/releases</url >
206
+ <url >http ://repository.apache.org/content/repositories/releases</url >
207
207
<releases >
208
208
<enabled >true</enabled >
209
209
</releases >
214
214
<repository >
215
215
<id >jboss-repo</id >
216
216
<name >JBoss Repository</name >
217
- <url >https ://repository.jboss.org/nexus/content/repositories/releases</url >
217
+ <url >http ://repository.jboss.org/nexus/content/repositories/releases</url >
218
218
<releases >
219
219
<enabled >true</enabled >
220
220
</releases >
225
225
<repository >
226
226
<id >mqtt-repo</id >
227
227
<name >MQTT Repository</name >
228
- <url >https ://repo.eclipse.org/content/repositories/paho-releases</url >
228
+ <url >http ://repo.eclipse.org/content/repositories/paho-releases</url >
229
229
<releases >
230
230
<enabled >true</enabled >
231
231
</releases >
236
236
<repository >
237
237
<id >cloudera-repo</id >
238
238
<name >Cloudera Repository</name >
239
- <url >https ://repository.cloudera.com/artifactory/cloudera-repos</url >
239
+ <url >http ://repository.cloudera.com/artifactory/cloudera-repos</url >
240
240
<releases >
241
241
<enabled >true</enabled >
242
242
</releases >
258
258
<repository >
259
259
<id >spring-releases</id >
260
260
<name >Spring Release Repository</name >
261
- <url >https ://repo.spring.io/libs-release</url >
261
+ <url >http ://repo.spring.io/libs-release</url >
262
262
<releases >
263
263
<enabled >true</enabled >
264
264
</releases >
270
270
<pluginRepositories >
271
271
<pluginRepository >
272
272
<id >central</id >
273
- <url >https ://repo1.maven.org/maven2</url >
273
+ <url >http ://repo1.maven.org/maven2</url >
274
274
<releases >
275
275
<enabled >true</enabled >
276
276
</releases >
Original file line number Diff line number Diff line change @@ -36,19 +36,21 @@ private[spark] trait CatalystConf {
36
36
* relations are already filled in and the analyser needs only to resolve attribute references.
37
37
*/
38
38
object EmptyConf extends CatalystConf {
39
- def setConf (key : String , value : String ) : Unit = {
39
+ override def caseSensitiveAnalysis : Boolean = true
40
+
41
+ override def setConf (key : String , value : String ) : Unit = {
40
42
throw new UnsupportedOperationException
41
43
}
42
44
43
- def getConf (key : String ) : String = {
45
+ override def getConf (key : String ) : String = {
44
46
throw new UnsupportedOperationException
45
47
}
46
48
47
- def getConf (key : String , defaultValue : String ) : String = {
49
+ override def getConf (key : String , defaultValue : String ) : String = {
48
50
throw new UnsupportedOperationException
49
51
}
50
52
51
- def getAllConfs : immutable.Map [String , String ] = {
53
+ override def getAllConfs : immutable.Map [String , String ] = {
52
54
throw new UnsupportedOperationException
53
55
}
54
56
}
Original file line number Diff line number Diff line change @@ -31,7 +31,7 @@ import org.apache.spark.sql.types._
31
31
* when all relations are already filled in and the analyzer needs only to resolve attribute
32
32
* references.
33
33
*/
34
- object SimpleAnalyzer extends Analyzer (EmptyCatalog , EmptyFunctionRegistry , new SimpleConf )
34
+ object SimpleAnalyzer extends Analyzer (EmptyCatalog , EmptyFunctionRegistry , new SimpleConf ( true ) )
35
35
36
36
/**
37
37
* Provides a logical query plan analyzer, which translates [[UnresolvedAttribute ]]s and
Original file line number Diff line number Diff line change @@ -23,9 +23,11 @@ import scala.collection.immutable
23
23
import scala .collection .mutable
24
24
25
25
/** A CatalystConf that can be used for local testing. */
26
- class SimpleConf (caseSensitiveAnalysis : Boolean ) extends CatalystConf {
26
+ class SimpleConf (caseSensitive : Boolean ) extends CatalystConf {
27
27
val map = mutable.Map [String , String ]()
28
28
29
+ def caseSensitiveAnalysis : Boolean = caseSensitive
30
+
29
31
def setConf (key : String , value : String ) : Unit = {
30
32
map.put(key, value)
31
33
}
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ import org.apache.spark.sql.catalyst.test.SimpleConf
24
24
import org .scalatest .{BeforeAndAfter , FunSuite }
25
25
26
26
class DecimalPrecisionSuite extends FunSuite with BeforeAndAfter {
27
- val conf = new SimpleConf
27
+ val conf = new SimpleConf ( true )
28
28
val catalog = new SimpleCatalog (conf)
29
29
val analyzer = new Analyzer (catalog, EmptyFunctionRegistry , conf)
30
30
Original file line number Diff line number Diff line change @@ -21,13 +21,7 @@ import org.scalatest.BeforeAndAfterAll
21
21
22
22
import org .apache .spark .sql .execution .GeneratedAggregate
23
23
import org .apache .spark .sql .functions ._
24
- <<<<<<< HEAD
25
24
import org .apache .spark .sql .catalyst .CatalystConf
26
- import org .apache .spark .sql .catalyst .errors .TreeNodeException
27
- import org .apache .spark .sql .catalyst .plans .logical .LogicalPlan
28
- import org .apache .spark .sql .types ._
29
- =======
30
- >>>>>>> 254e0509762937acc9c72b432d5d953bf72c3c52
31
25
import org .apache .spark .sql .TestData ._
32
26
import org .apache .spark .sql .test .TestSQLContext
33
27
import org .apache .spark .sql .test .TestSQLContext .{udf => _ , _ }
You can’t perform that action at this time.
0 commit comments