Skip to content

Commit

Permalink
Use typeOf instead tq
Browse files Browse the repository at this point in the history
  • Loading branch information
marmbrus committed Jul 9, 2014
1 parent f623ffd commit 0e889e8
Showing 1 changed file with 7 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -37,14 +37,13 @@ abstract class CodeGenerator extends Logging {

val toolBox = runtimeMirror(getClass.getClassLoader).mkToolBox()

// TODO: Use typetags?
val rowType = tq"org.apache.spark.sql.catalyst.expressions.Row"
val mutableRowType = tq"org.apache.spark.sql.catalyst.expressions.MutableRow"
val genericRowType = tq"org.apache.spark.sql.catalyst.expressions.GenericRow"
val genericMutableRowType = tq"org.apache.spark.sql.catalyst.expressions.GenericMutableRow"

val projectionType = tq"org.apache.spark.sql.catalyst.expressions.Projection"
val mutableProjectionType = tq"org.apache.spark.sql.catalyst.expressions.MutableProjection"
val rowType = typeOf[Row]
val mutableRowType = typeOf[MutableRow]
val genericRowType = typeOf[GenericRow]
val genericMutableRowType = typeOf[GenericMutableRow]

val projectionType = typeOf[Projection]
val mutableProjectionType = typeOf[MutableProjection]

private val curId = new java.util.concurrent.atomic.AtomicInteger()
private val javaSeperator = "$"
Expand Down

0 comments on commit 0e889e8

Please sign in to comment.