File tree Expand file tree Collapse file tree 1 file changed +2
-11
lines changed
runtime/service/src/main/java/org/apache/polaris/service/catalog/iceberg Expand file tree Collapse file tree 1 file changed +2
-11
lines changed Original file line number Diff line number Diff line change @@ -219,18 +219,9 @@ protected void initializeCatalog() {
219219 ConnectionType .fromCode (connectionConfigInfoDpo .getConnectionTypeCode ());
220220
221221 // Use the unified factory pattern for all external catalog types
222- String factoryIdentifier ;
223- switch (connectionType ) {
224- case ICEBERG_REST :
225- case HADOOP :
226- factoryIdentifier = connectionType .getFactoryIdentifier ();
227- break ;
228- default :
229- throw new UnsupportedOperationException ("Unsupported connection type: " + connectionType );
230- }
231-
232222 Instance <ExternalCatalogFactory > externalCatalogFactory =
233- externalCatalogFactories .select (Identifier .Literal .of (factoryIdentifier ));
223+ externalCatalogFactories .select (
224+ Identifier .Literal .of (connectionType .getFactoryIdentifier ()));
234225 if (!externalCatalogFactory .isUnsatisfied ()) {
235226 federatedCatalog =
236227 externalCatalogFactory
You can’t perform that action at this time.
0 commit comments