From 35be32f702f5d3f3a68ceb0d01dbb5fb2e1adb41 Mon Sep 17 00:00:00 2001 From: Cheng Lian Date: Sat, 23 Apr 2016 22:56:51 +0800 Subject: [PATCH 1/2] Makes OutputWriterFactory.newInstance public --- .../spark/sql/execution/datasources/fileSourceInterfaces.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/fileSourceInterfaces.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/fileSourceInterfaces.scala index d37a939b544aa..2da71f957d6e1 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/fileSourceInterfaces.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/fileSourceInterfaces.scala @@ -59,7 +59,7 @@ abstract class OutputWriterFactory extends Serializable { * @param context The Hadoop MapReduce task context. * @since 1.4.0 */ - private[sql] def newInstance( + def newInstance( path: String, bucketId: Option[Int], // TODO: This doesn't belong here... dataSchema: StructType, From ae8729d3158002fc1e92358282794773c5c2c49c Mon Sep 17 00:00:00 2001 From: Cheng Lian Date: Mon, 25 Apr 2016 12:45:19 +0800 Subject: [PATCH 2/2] Fixes compilation error in test code --- .../scala/org/apache/spark/sql/sources/SimpleTextRelation.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala b/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala index 16996ae036671..dad4f87ae3971 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala @@ -48,7 +48,7 @@ class SimpleTextSource extends FileFormat with DataSourceRegister { job: Job, options: Map[String, String], dataSchema: StructType): OutputWriterFactory = new OutputWriterFactory { - override private[sql] def newInstance( + override def newInstance( path: String, bucketId: Option[Int], dataSchema: StructType,