When I read spark source code, I found an abstract class AtomicType. It's
defined like this:
protected[sql] abstract class AtomicType extends DataType {
private[sql] type InternalType
private[sql] val tag: TypeTag[InternalType]
private[sql] val ordering: Ordering[InternalType]
@transient private[sql] val classTag = ScalaReflectionLock.synchronized {
val mirror = runtimeMirror(Utils.getSparkClassLoader)
ClassTag[InternalType](mirror.runtimeClass(tag.tpe))
}
}
I understand that classTag is used to get runtime type information of type
member InternelType, but I can not find how this classTag is used in
subclasses of AtomicType. And I also cannot find any reference to this
variable in spark project.
Can anyone tell me how this classTag is used in spark project?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Can-not-find-usage-of-classTag-variable-defined-in-abstract-class-AtomicType-in-spark-project-tp27534.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscr...@spark.apache.org
