|
38 | 38 | import org.apache.paimon.function.FunctionDefinition; |
39 | 39 | import org.apache.paimon.function.FunctionImpl; |
40 | 40 | import org.apache.paimon.operation.Lock; |
41 | | -import org.apache.paimon.options.CatalogOptions; |
42 | 41 | import org.apache.paimon.options.Options; |
43 | 42 | import org.apache.paimon.partition.Partition; |
44 | 43 | import org.apache.paimon.partition.PartitionStatistics; |
|
120 | 119 | import static org.apache.paimon.CoreOptions.SNAPSHOT_CLEAN_EMPTY_DIRECTORIES; |
121 | 120 | import static org.apache.paimon.CoreOptions.TYPE; |
122 | 121 | import static org.apache.paimon.TableType.FORMAT_TABLE; |
| 122 | +import static org.apache.paimon.options.CatalogOptions.WAREHOUSE; |
123 | 123 | import static org.apache.paimon.rest.RESTApi.MAX_RESULTS; |
124 | 124 | import static org.apache.paimon.rest.RESTApi.PAGE_TOKEN; |
125 | 125 | import static org.apache.paimon.rest.RESTApi.PARTITION_NAME_PATTERN; |
126 | | -import static org.apache.paimon.rest.RESTApi.QUERY_PARAMETER_WAREHOUSE_KEY; |
127 | 126 | import static org.apache.paimon.rest.RESTApi.TABLE_NAME_PATTERN; |
128 | 127 | import static org.apache.paimon.rest.RESTApi.VIEW_NAME_PATTERN; |
129 | 128 |
|
@@ -167,7 +166,7 @@ public RESTCatalogServer( |
167 | 166 | this.functionUri = resourcePaths.functions(); |
168 | 167 | Options conf = new Options(); |
169 | 168 | this.configResponse.getDefaults().forEach(conf::setString); |
170 | | - conf.setString(CatalogOptions.WAREHOUSE.key(), dataPath); |
| 169 | + conf.setString(WAREHOUSE.key(), dataPath); |
171 | 170 | CatalogContext context = CatalogContext.create(conf); |
172 | 171 | Path warehousePath = new Path(dataPath); |
173 | 172 | FileIO fileIO; |
@@ -269,7 +268,7 @@ public MockResponse dispatch(RecordedRequest request) { |
269 | 268 | } |
270 | 269 | if (request.getPath().startsWith(resourcePaths.config()) |
271 | 270 | && request.getRequestUrl() |
272 | | - .queryParameter(QUERY_PARAMETER_WAREHOUSE_KEY) |
| 271 | + .queryParameter(WAREHOUSE.key()) |
273 | 272 | .equals(warehouse)) { |
274 | 273 | return mockResponse(configResponse, 200); |
275 | 274 | } else if (databaseUri.equals(request.getPath()) |
|
0 commit comments