Skip to content

Commit

Permalink
minor, format code
Browse files Browse the repository at this point in the history
  • Loading branch information
LauraXia123 committed Apr 17, 2024
1 parent e05ab7a commit 4db5259
Showing 1 changed file with 2 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -164,10 +164,7 @@ void createTableAndColumn(
private static String defaultBaseLocation(String schemaName) {
if (defaultBaseLocation == null) {
defaultBaseLocation =
String.format(
"%s/user/hadoop/%s.db",
hdfsUri,
schemaName.toLowerCase());
String.format("%s/user/hadoop/%s.db", hdfsUri, schemaName.toLowerCase());
}
return defaultBaseLocation;
}
Expand Down Expand Up @@ -241,8 +238,7 @@ void dropTopic(String metalakeName, String catalogName, String schemaName, Strin
metalake.loadCatalog(NameIdentifier.ofCatalog(metalakeName, catalogName));
catalog_kafka
.asTopicCatalog()
.dropTopic(
NameIdentifier.of(metalakeName, catalogName, schemaName, topicName));
.dropTopic(NameIdentifier.of(metalakeName, catalogName, schemaName, topicName));
}

@AfterAll
Expand Down

0 comments on commit 4db5259

Please sign in to comment.