You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by sz...@apache.org on 2022/10/14 22:00:23 UTC

[iceberg] branch master updated: Docs: Fix typo in DataFrameReader table load (#5978)

This is an automated email from the ASF dual-hosted git repository.

szehon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 876e7183b4 Docs: Fix typo in DataFrameReader table load (#5978)
876e7183b4 is described below

commit 876e7183b47d8517b6d6e10330571e83059a6901
Author: Szehon Ho <sz...@gmail.com>
AuthorDate: Fri Oct 14 15:00:18 2022 -0700

    Docs: Fix typo in DataFrameReader table load (#5978)
---
 docs/spark-queries.md                                                 | 4 ++--
 .../src/main/java/org/apache/iceberg/spark/source/IcebergSource.java  | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/docs/spark-queries.md b/docs/spark-queries.md
index acdd538209..126600a131 100644
--- a/docs/spark-queries.md
+++ b/docs/spark-queries.md
@@ -78,10 +78,10 @@ val df = spark.table("prod.db.table")
 Iceberg 0.11.0 adds multi-catalog support to `DataFrameReader` in both Spark 3.x and 2.4.
 
 Paths and table names can be loaded with Spark's `DataFrameReader` interface. How tables are loaded depends on how
-the identifier is specified. When using `spark.read.format("iceberg").path(table)` or `spark.table(table)` the `table`
+the identifier is specified. When using `spark.read.format("iceberg").load(table)` or `spark.table(table)` the `table`
 variable can take a number of forms as listed below:
 
-*  `file:/path/to/table`: loads a HadoopTable at given path
+*  `file:///path/to/table`: loads a HadoopTable at given path
 *  `tablename`: loads `currentCatalog.currentNamespace.tablename`
 *  `catalog.tablename`: loads `tablename` from the specified catalog.
 *  `namespace.tablename`: loads `namespace.tablename` from current catalog
diff --git a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java
index 00072a134a..4a03d3a5b5 100644
--- a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java
+++ b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java
@@ -47,9 +47,9 @@ import org.apache.spark.sql.util.CaseInsensitiveStringMap;
 /**
  * The IcebergSource loads/writes tables with format "iceberg". It can load paths and tables.
  *
- * <p>How paths/tables are loaded when using spark.read().format("iceberg").path(table)
+ * <p>How paths/tables are loaded when using spark.read().format("iceberg").load(table)
  *
- * <p>table = "file:/path/to/table" -&gt; loads a HadoopTable at given path table = "tablename"
+ * <p>table = "file:///path/to/table" -&gt; loads a HadoopTable at given path table = "tablename"
  * -&gt; loads currentCatalog.currentNamespace.tablename table = "catalog.tablename" -&gt; load
  * "tablename" from the specified catalog. table = "namespace.tablename" -&gt; load
  * "namespace.tablename" from current catalog table = "catalog.namespace.tablename" -&gt;