lw309637554 commented on a change in pull request #2136:
URL: https://github.com/apache/hudi/pull/2136#discussion_r527733770
##########
File path: hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
##########
@@ -108,11 +109,13 @@ private[hudi] object HoodieSparkSqlWriter {
handleSaveModes(mode, basePath, tableConfig, tblName, operation, fs)
// Create the table if not present
if (!tableExists) {
- val archiveLogFolder = parameters.getOrElse(
- HoodieTableConfig.HOODIE_ARCHIVELOG_FOLDER_PROP_NAME, "archived")
+ val archiveLogFolder =
parameters.get(HoodieTableConfig.HOODIE_ARCHIVELOG_FOLDER_PROP_NAME).get
+ val hoodieWriteConfig =
DataSourceUtils.createHoodieConfig(Schema.create(Schema.Type.NULL).toString,
path.get, tblName, mapAsJavaMap(parameters))
+ val index = SparkHoodieIndex.createIndex(hoodieWriteConfig)
Review comment:
done, just get index from HoodieIndexUtils. getIndexType , which get
from writeconfig
##########
File path:
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/BootstrapExecutor.java
##########
@@ -170,10 +170,11 @@ private void initializeTable() throws IOException {
throw new HoodieException("target base path already exists at " +
cfg.targetBasePath
+ ". Cannot bootstrap data on top of an existing table");
}
-
+ SparkHoodieIndex index = SparkHoodieIndex.createIndex(bootstrapConfig);
Review comment:
done
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
