Skip to content
Snippets Groups Projects
Commit e66afd5c authored by Cheng Lian's avatar Cheng Lian
Browse files

[SPARK-14875][SQL] Makes OutputWriterFactory.newInstance public

## What changes were proposed in this pull request?

This method was accidentally made `private[sql]` in Spark 2.0. This PR makes it public again, since 3rd party data sources like spark-avro depend on it.

## How was this patch tested?

N/A

Author: Cheng Lian <lian@databricks.com>

Closes #12652 from liancheng/spark-14875.
parent cef77d1f
No related branches found
No related tags found
No related merge requests found
...@@ -59,7 +59,7 @@ abstract class OutputWriterFactory extends Serializable { ...@@ -59,7 +59,7 @@ abstract class OutputWriterFactory extends Serializable {
* @param context The Hadoop MapReduce task context. * @param context The Hadoop MapReduce task context.
* @since 1.4.0 * @since 1.4.0
*/ */
private[sql] def newInstance( def newInstance(
path: String, path: String,
bucketId: Option[Int], // TODO: This doesn't belong here... bucketId: Option[Int], // TODO: This doesn't belong here...
dataSchema: StructType, dataSchema: StructType,
......
...@@ -48,7 +48,7 @@ class SimpleTextSource extends FileFormat with DataSourceRegister { ...@@ -48,7 +48,7 @@ class SimpleTextSource extends FileFormat with DataSourceRegister {
job: Job, job: Job,
options: Map[String, String], options: Map[String, String],
dataSchema: StructType): OutputWriterFactory = new OutputWriterFactory { dataSchema: StructType): OutputWriterFactory = new OutputWriterFactory {
override private[sql] def newInstance( override def newInstance(
path: String, path: String,
bucketId: Option[Int], bucketId: Option[Int],
dataSchema: StructType, dataSchema: StructType,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment