This is an automated email from the ASF dual-hosted git repository.
bhavanisudha pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 91995aee8e3 [DOCS][MINOR] Fix sample scala code typo (#9034)
91995aee8e3 is described below
commit 91995aee8e3538a5bdd74f178bb1ad4d696199f3
Author: Yongkyun Lee <[email protected]>
AuthorDate: Wed Jun 21 17:47:36 2023 -0700
[DOCS][MINOR] Fix sample scala code typo (#9034)
---
website/docs/querying_data.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/website/docs/querying_data.md b/website/docs/querying_data.md
index 5e7b62c2cdd..b743fec3893 100644
--- a/website/docs/querying_data.md
+++ b/website/docs/querying_data.md
@@ -28,7 +28,7 @@ Retrieve the data table at the present point in time.
```scala
val hudiIncQueryDF = spark
- .read()
+ .read
.format("hudi")
.option(DataSourceReadOptions.QUERY_TYPE_OPT_KEY(),
DataSourceReadOptions.QUERY_TYPE_SNAPSHOT_OPT_VAL())
.load(tablePath)
@@ -41,7 +41,7 @@ Thanks to Hudi's support for record level change streams,
these incremental pipe
The following snippet shows how to obtain all records changed after
`beginInstantTime` and run some SQL on them.
```java
- Dataset<Row> hudiIncQueryDF = spark.read()
+Dataset<Row> hudiIncQueryDF = spark.read()
.format("org.apache.hudi")
.option(DataSourceReadOptions.QUERY_TYPE_OPT_KEY(),
DataSourceReadOptions.QUERY_TYPE_INCREMENTAL_OPT_VAL())
.option(DataSourceReadOptions.BEGIN_INSTANTTIME_OPT_KEY(),
<beginInstantTime>)
