diff options
| author | Michael Armbrust <michael@databricks.com> | 2014-07-12 12:13:32 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-07-12 12:13:44 -0700 |
| commit | effa69f9cd6abaafee2c437a3f86cec867855ede (patch) | |
| tree | 04c81ca3da4c71af05698aa183b948b778b4797e /sql/catalyst | |
| parent | 37e49433a89535cb1defa67e3551b02ced1d445c (diff) | |
| download | spark-effa69f9cd6abaafee2c437a3f86cec867855ede.tar.gz spark-effa69f9cd6abaafee2c437a3f86cec867855ede.tar.bz2 spark-effa69f9cd6abaafee2c437a3f86cec867855ede.zip | |
[SPARK-2405][SQL] Reusue same byte buffers when creating new instance of InMemoryRelation
Reuse byte buffers when creating unique attributes for multiple instances of an InMemoryRelation in a single query plan.
Author: Michael Armbrust <michael@databricks.com>
Closes #1332 from marmbrus/doubleCache and squashes the following commits:
4a19609 [Michael Armbrust] Clean up concurrency story by calculating buffersn the constructor.
b39c931 [Michael Armbrust] Allocations are kind of a side effect.
f67eff7 [Michael Armbrust] Reusue same byte buffers when creating new instance of InMemoryRelation
(cherry picked from commit 1a7d7cc85fb24de21f1cde67d04467171b82e845)
Signed-off-by: Reynold Xin <rxin@apache.org>
Diffstat (limited to 'sql/catalyst')
| -rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/MultiInstanceRelation.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/MultiInstanceRelation.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/MultiInstanceRelation.scala index a6ce90854d..22941edef2 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/MultiInstanceRelation.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/MultiInstanceRelation.scala @@ -30,7 +30,7 @@ import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan * of itself with globally unique expression ids. */ trait MultiInstanceRelation { - def newInstance: this.type + def newInstance(): this.type } /** |