Skip to content

Commit

Permalink
regexrecordrouter
Browse files Browse the repository at this point in the history
  • Loading branch information
tabmatfournier committed Apr 30, 2024
1 parent 13220e9 commit 797b861
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ public static RecordRouter from(
config.tables().forEach(TableIdentifier::of);
baseRecordRouter = new ConfigRecordRouter(writers, config.tables());
} else {
baseRecordRouter = new StaticRecordRouter(writers, config);
baseRecordRouter = new RegexRecordRouter(writers, config);
}
}

Expand Down Expand Up @@ -101,12 +101,12 @@ public void write(SinkRecord record) {
}
}

private static class StaticRecordRouter extends RecordRouter {
private static class RegexRecordRouter extends RecordRouter {
private final String routeField;
private final WriterManager writers;
private final IcebergSinkConfig config;

StaticRecordRouter(WriterManager writers, IcebergSinkConfig config) {
RegexRecordRouter(WriterManager writers, IcebergSinkConfig config) {
this.routeField = config.tablesRouteField();
this.writers = writers;
this.config = config;
Expand Down

0 comments on commit 797b861

Please sign in to comment.