This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new a311965816 [HUDI-4763] Allow hoodie read client to choose index (#6506)
a311965816 is described below
commit a311965816ece4dd88650fabf2f59fb46705bd65
Author: Nicolas Paris <[email protected]>
AuthorDate: Sat Sep 10 17:51:59 2022 +0200
[HUDI-4763] Allow hoodie read client to choose index (#6506)
Co-authored-by: Y Ethan Guo <[email protected]>
---
.../main/java/org/apache/hudi/client/HoodieReadClient.java | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git
a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieReadClient.java
b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieReadClient.java
index 37a78a4be5..97e54070cf 100644
---
a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieReadClient.java
+++
b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieReadClient.java
@@ -92,6 +92,20 @@ public class HoodieReadClient<T extends
HoodieRecordPayload<T>> implements Seria
this.sqlContextOpt = Option.of(sqlContext);
}
+ /**
+ * Initializes the {@link HoodieReadClient} with engine context, base path,
SQL context and index type.
+ *
+ * @param context Hudi Spark engine context
+ * @param basePath Base path of the table
+ * @param sqlContext {@link SQLContext} instance
+ * @param indexType Hudi index type
+ */
+ public HoodieReadClient(HoodieSparkEngineContext context, String basePath,
SQLContext sqlContext, HoodieIndex.IndexType indexType) {
+ this(context, HoodieWriteConfig.newBuilder().withPath(basePath)
+
.withIndexConfig(HoodieIndexConfig.newBuilder().withIndexType(indexType).build()).build());
+ this.sqlContextOpt = Option.of(sqlContext);
+ }
+
/**
* @param clientConfig instance of HoodieWriteConfig
*/