aboutsummaryrefslogtreecommitdiff
path: root/sql/core
diff options
context:
space:
mode:
authorDavies Liu <davies@databricks.com>2016-01-15 19:07:42 -0800
committerDavies Liu <davies.liu@gmail.com>2016-01-15 19:07:42 -0800
commit242efb7546084592a5e8122549a27117977303fb (patch)
treec2c96afd515f130055fdf102bd5e11a133ae9476 /sql/core
parent9039333c0a0ce4bea32f012b81c1e82e31246fc1 (diff)
downloadspark-242efb7546084592a5e8122549a27117977303fb.tar.gz
spark-242efb7546084592a5e8122549a27117977303fb.tar.bz2
spark-242efb7546084592a5e8122549a27117977303fb.zip
[SPARK-12840] [SQL] Support passing arbitrary objects (not just expressions) into code generated classes
This is a refactor to support codegen for aggregation and broadcast join. Author: Davies Liu <davies@databricks.com> Closes #10777 from davies/rename2.
Diffstat (limited to 'sql/core')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala
index 55e2c0ed70..7888e34e8a 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala
@@ -123,7 +123,7 @@ object GenerateColumnAccessor extends CodeGenerator[Seq[DataType], ColumnarItera
import org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter;
import org.apache.spark.sql.execution.columnar.MutableUnsafeRow;
- public SpecificColumnarIterator generate($exprType[] expr) {
+ public SpecificColumnarIterator generate(Object[] references) {
return new SpecificColumnarIterator();
}
@@ -190,6 +190,6 @@ object GenerateColumnAccessor extends CodeGenerator[Seq[DataType], ColumnarItera
logDebug(s"Generated ColumnarIterator: ${CodeFormatter.format(code)}")
- compile(code).generate(ctx.references.toArray).asInstanceOf[ColumnarIterator]
+ compile(code).generate(Array.empty).asInstanceOf[ColumnarIterator]
}
}