-
Notifications
You must be signed in to change notification settings - Fork 3.5k
[feat](params-refactor) restructure parameters for FS V2 integration #51177
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[feat](params-refactor) restructure parameters for FS V2 integration #51177
Conversation
Reorganized catalog parameter definitions to support the new FS V2 interface. This includes updates to parameter parsing, validation, and adaptation logic.
Thank you for your contribution to Apache Doris. Please clearly describe your PR:
|
run buildall |
run buildall |
TPC-H: Total hot run time: 33773 ms
|
TPC-DS: Total hot run time: 185602 ms
|
ClickBench: Total hot run time: 29.68 s
|
new FileSystemCache.FileSystemCacheKey( | ||
LocationPath.getFSIdentity(location, properties, | ||
bindBrokerName), properties, bindBrokerName)); | ||
bindBrokerName), properties, bindBrokerName));*/ | ||
//fixme |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
what is the problem?
…er-refactor-params-catalog-filesystem-step-1 # Conflicts: # fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java
run buildall |
TPC-H: Total hot run time: 33931 ms
|
TPC-DS: Total hot run time: 192729 ms
|
ClickBench: Total hot run time: 28.91 s
|
run buildall |
TPC-H: Total hot run time: 33810 ms
|
TPC-DS: Total hot run time: 192289 ms
|
ClickBench: Total hot run time: 29.34 s
|
run buildall |
TPC-H: Total hot run time: 34078 ms
|
TPC-DS: Total hot run time: 185699 ms
|
ClickBench: Total hot run time: 28.94 s
|
run external |
run buildall |
TPC-H: Total hot run time: 33745 ms
|
TPC-DS: Total hot run time: 192983 ms
|
ClickBench: Total hot run time: 28.97 s
|
run buildall |
TPC-H: Total hot run time: 33738 ms
|
TPC-DS: Total hot run time: 193508 ms
|
ClickBench: Total hot run time: 29.47 s
|
private final Configuration conf; | ||
|
||
public FileSystemCacheKey(Pair<FileSystemType, String> fs, | ||
Map<String, String> properties, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Still using a raw map?
@@ -52,6 +53,22 @@ public static RemoteFileSystem get(String name, Map<String, String> properties) | |||
return new BrokerFileSystem(name, properties); | |||
} | |||
|
|||
public static RemoteFileSystem get(FileSystemType fileSystemType, Map<String, String> properties, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think in this class, we should only keep get(StorageProperties storageProperties)
, and remove all other get
method.
private Map<String, String> properties; | ||
|
||
public FileSystemProviderImpl(ExternalMetaCacheMgr extMetaCacheMgr, String bindBrokerName, | ||
Map<String, String> properties) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should pass StorageProperties
instead of raw map
|
||
private final String bindBrokerName; | ||
|
||
private final Map<String, String> properties; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should use StorageProperties
instead of raw map
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
PR approved by at least one committer and no changes requested. |
PR approved by anyone and no changes requested. |
Issue Number: #50238
This PR integrates the new file system (FS) with the Catalog module, continuing the previous effort where we migrated functionalities like export and backup to use the new FS implementation.
Main Changes:
Catalog Integration with New FS:
Updated the Catalog-related logic to work with the new file system abstraction, ensuring consistent usage across the system.
Code Sync from FS V1 to V2:
Migrated relevant code from FS V1 to FS V2 to maintain functional parity and ensure compatibility.
Test Enhancements:
Added unit and integration tests for the new FS usage within the Catalog to ensure correctness and stability.