diff options
Diffstat (limited to 'sql/catalyst/src/main')
| -rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala index 0c729648ef..5233699fac 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala @@ -114,6 +114,12 @@ abstract class ExternalCatalog { def listTables(db: String, pattern: String): Seq[String] + /** + * Loads data into a table. + * + * @param isSrcLocal Whether the source data is local, as defined by the "LOAD DATA LOCAL" + * HiveQL command. + */ def loadTable( db: String, table: String, @@ -122,6 +128,12 @@ abstract class ExternalCatalog { holdDDLTime: Boolean, isSrcLocal: Boolean): Unit + /** + * Loads data into a partition. + * + * @param isSrcLocal Whether the source data is local, as defined by the "LOAD DATA LOCAL" + * HiveQL command. + */ def loadPartition( db: String, table: String, |