Skip to content

Commit

Permalink
Update Hudi library to 1.0.0
Browse files Browse the repository at this point in the history
  • Loading branch information
ebyhr committed Dec 11, 2024
1 parent a7e72d4 commit 4fef0f0
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 2 deletions.
8 changes: 7 additions & 1 deletion plugin/trino-hudi/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@

<properties>
<air.compiler.fail-warnings>true</air.compiler.fail-warnings>
<dep.hudi.version>0.15.0</dep.hudi.version>
<dep.hudi.version>1.0.0</dep.hudi.version>
</properties>

<dependencies>
Expand Down Expand Up @@ -166,6 +166,12 @@
<scope>provided</scope>
</dependency>

<dependency>
<groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId>
<scope>runtime</scope>
</dependency>

<dependency>
<groupId>io.airlift</groupId>
<artifactId>log-manager</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -214,9 +214,10 @@ private static HoodieJavaWriteClient<HoodieAvroPayload> createWriteClient(TpchTa
StorageConfiguration<?> conf = new HadoopStorageConfiguration(hdfsEnvironment.getConfiguration(CONTEXT, tablePath));

try {
HoodieTableMetaClient.withPropertyBuilder()
HoodieTableMetaClient.newTableBuilder()
.setTableType(COPY_ON_WRITE)
.setTableName(table.getTableName())
.setTimelineLayoutVersion(1)
.setBootstrapIndexClass(NoOpBootstrapIndex.class.getName())
.setPayloadClassName(HoodieAvroPayload.class.getName())
.setRecordKeyFields(FIELD_UUID)
Expand Down

0 comments on commit 4fef0f0

Please sign in to comment.