Updated a call with added parameter

rama-mullapudi · rama-mullapudi · commit dddc13762fc9 · 2015-09-26T09:24:42.000-04:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects.scala b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects.scala
@@ -171,8 +171,8 @@ class AggregatedDialect(dialects: List[JdbcDialect]) extends JdbcDialect {
     dialects.flatMap(_.getCatalystType(sqlType, typeName, size, md)).headOption
   }
 
-  override def getJDBCType(dt: DataType): Option[JdbcType] = {
-    dialects.flatMap(_.getJDBCType(dt)).headOption
+  override def getJDBCType(dt: DataType, md: Metadata): Option[JdbcType] = {
+    dialects.flatMap(_.getJDBCType(dt, md)).headOption
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -171,8 +171,8 @@ class AggregatedDialect(dialects: List[JdbcDialect]) extends JdbcDialect {`
`171`	`171`	`dialects.flatMap(_.getCatalystType(sqlType, typeName, size, md)).headOption`
`172`	`172`	`}`
`173`	`173`
`174`		`- override def getJDBCType(dt: DataType): Option[JdbcType] = {`
`175`		`- dialects.flatMap(_.getJDBCType(dt)).headOption`
	`174`	`+ override def getJDBCType(dt: DataType, md: Metadata): Option[JdbcType] = {`
	`175`	`+ dialects.flatMap(_.getJDBCType(dt, md)).headOption`
`176`	`176`	`}`
`177`	`177`	`}`
`178`	`178`