ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[DataFrame][minor] cleanup unapply methods in DataTypes

Browse source 
Author: Wenchen Fan <cloud0fan@outlook.com>

Closes #6079 from cloud-fan/unapply and squashes the following commits:

40da442 [Wenchen Fan] one more
7d90a05 [Wenchen Fan] cleanup unapply in DataTypes

(cherry picked from commit 831504cf6b)
Signed-off-by: Reynold Xin <rxin@databricks.com>
This commit is contained in:
Wenchen Fan 2015-05-12 10:28:40 -07:00 committed by Reynold Xin
parent 653db0a1bd
commit a9d84a9bf7
1 changed files with 3 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
sql/catalyst/src/main/scala/org/apache/spark/sql/types/DataType.scala
View file

@ -47,10 +47,7 @@ abstract class DataType {
* ... * ...
* }}} * }}}
*/ */
private[sql] def unapply(a: Expression): Boolean = a match { private[sql] def unapply(e: Expression): Boolean = e.dataType == this
case e: Expression if e.dataType == this => true
case _ => false
}
/** /**
* The default size of a value of this data type, used internally for size estimation. * The default size of a value of this data type, used internally for size estimation.
@ -137,10 +134,7 @@ private[sql] object IntegralType {
* ... * ...
* }}} * }}}
*/ */
def unapply(a: Expression): Boolean = a match { def unapply(e: Expression): Boolean = e.dataType.isInstanceOf[IntegralType]
case e: Expression if e.dataType.isInstanceOf[IntegralType] => true
case _ => false
}
} }
@ -157,10 +151,7 @@ private[sql] object FractionalType {
* ... * ...
* }}} * }}}
*/ */
def unapply(a: Expression): Boolean = a match { def unapply(e: Expression): Boolean = e.dataType.isInstanceOf[FractionalType]
case e: Expression if e.dataType.isInstanceOf[FractionalType] => true
case _ => false
}
} }