Skip to content

Commit ba2cd6f

Browse files
committed
simplify table name parse
Signed-off-by: Sotaro Hikita <bering1814@gmail.com>
1 parent 345ca7f commit ba2cd6f

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

  • data-prepper-plugins/iceberg-source/src/main/java/org/opensearch/dataprepper/plugins/source/iceberg

data-prepper-plugins/iceberg-source/src/main/java/org/opensearch/dataprepper/plugins/source/iceberg/IcebergService.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -62,10 +62,7 @@ public void start(final Buffer<Record<Event>> buffer) {
6262
final Map<String, String> catalogProps = new HashMap<>(tableConfig.getCatalog());
6363
final Catalog catalog = CatalogUtil.buildIcebergCatalog(tableName, catalogProps, null);
6464

65-
final String[] parts = tableName.split("\\.");
66-
final TableIdentifier tableId = parts.length == 2
67-
? TableIdentifier.of(parts[0], parts[1])
68-
: TableIdentifier.parse(tableName);
65+
final TableIdentifier tableId = TableIdentifier.parse(tableName);
6966

7067
final Table table = catalog.loadTable(tableId);
7168
validateCoWTable(table, tableName);

0 commit comments

Comments
 (0)