diff options
author | Wenchen Fan <wenchen@databricks.com> | 2015-10-14 16:05:37 -0700 |
---|---|---|
committer | Davies Liu <davies.liu@gmail.com> | 2015-10-14 16:05:37 -0700 |
commit | 56d7da14ab8f89bf4f303b27f51fd22d23967ffb (patch) | |
tree | d21fc4a4d5a197788a8b8e165d89d3e95bff13be /sql/hive/src/test/java/org | |
parent | 9a430a027faafb083ca569698effb697af26a1db (diff) | |
download | spark-56d7da14ab8f89bf4f303b27f51fd22d23967ffb.tar.gz spark-56d7da14ab8f89bf4f303b27f51fd22d23967ffb.tar.bz2 spark-56d7da14ab8f89bf4f303b27f51fd22d23967ffb.zip |
[SPARK-10104] [SQL] Consolidate different forms of table identifiers
Right now, we have QualifiedTableName, TableIdentifier, and Seq[String] to represent table identifiers. We should only have one form and TableIdentifier is the best one because it provides methods to get table name, database name, return unquoted string, and return quoted string.
Author: Wenchen Fan <wenchen@databricks.com>
Author: Wenchen Fan <cloud0fan@163.com>
Closes #8453 from cloud-fan/table-name.
Diffstat (limited to 'sql/hive/src/test/java/org')
-rw-r--r-- | sql/hive/src/test/java/org/apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/sql/hive/src/test/java/org/apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java b/sql/hive/src/test/java/org/apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java index c8d272794d..8c4af1b8ea 100644 --- a/sql/hive/src/test/java/org/apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java +++ b/sql/hive/src/test/java/org/apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java @@ -26,7 +26,6 @@ import java.util.Map; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import org.apache.spark.sql.SaveMode; import org.junit.After; import org.junit.Assert; import org.junit.Before; @@ -41,6 +40,8 @@ import org.apache.spark.sql.hive.test.TestHive$; import org.apache.spark.sql.types.DataTypes; import org.apache.spark.sql.types.StructField; import org.apache.spark.sql.types.StructType; +import org.apache.spark.sql.SaveMode; +import org.apache.spark.sql.catalyst.TableIdentifier; import org.apache.spark.util.Utils; public class JavaMetastoreDataSourcesSuite { @@ -71,7 +72,8 @@ public class JavaMetastoreDataSourcesSuite { if (path.exists()) { path.delete(); } - hiveManagedPath = new Path(sqlContext.catalog().hiveDefaultTableFilePath("javaSavedTable")); + hiveManagedPath = new Path(sqlContext.catalog().hiveDefaultTableFilePath( + new TableIdentifier("javaSavedTable"))); fs = hiveManagedPath.getFileSystem(sc.hadoopConfiguration()); if (fs.exists(hiveManagedPath)){ fs.delete(hiveManagedPath, true); |