diff options
author | Davies Liu <davies@databricks.com> | 2016-01-15 19:07:42 -0800 |
---|---|---|
committer | Davies Liu <davies.liu@gmail.com> | 2016-01-15 19:07:42 -0800 |
commit | 242efb7546084592a5e8122549a27117977303fb (patch) | |
tree | c2c96afd515f130055fdf102bd5e11a133ae9476 /sql/core/src | |
parent | 9039333c0a0ce4bea32f012b81c1e82e31246fc1 (diff) | |
download | spark-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/src')
-rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala | 4 |
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] } } |