Skip to content

Commit

Permalink
Tiny style improvement.
Browse files Browse the repository at this point in the history
  • Loading branch information
rxin committed Dec 20, 2016
1 parent f923c84 commit 150d26c
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ import org.apache.spark.sql.catalyst.TableIdentifier
import org.apache.spark.sql.catalyst.analysis.UnresolvedRelation
import org.apache.spark.sql.catalyst.catalog.{BucketSpec, CatalogTable, CatalogTableType}
import org.apache.spark.sql.catalyst.plans.logical.InsertIntoTable
import org.apache.spark.sql.execution.command.{AlterTableRecoverPartitionsCommand, DDLUtils}
import org.apache.spark.sql.execution.datasources.{CreateTable, DataSource, HadoopFsRelation}
import org.apache.spark.sql.execution.command.DDLUtils
import org.apache.spark.sql.execution.datasources.{CreateTable, DataSource}
import org.apache.spark.sql.types.StructType

/**
Expand Down Expand Up @@ -214,6 +214,7 @@ final class DataFrameWriter[T] private[sql](ds: Dataset[T]) {

dataSource.write(mode, df)
}

/**
* Inserts the content of the `DataFrame` to the specified table. It requires that
* the schema of the `DataFrame` is the same as the schema of the table.
Expand Down

0 comments on commit 150d26c

Please sign in to comment.