Guosmilesmile commented on code in PR #13998:
URL: https://github.com/apache/iceberg/pull/13998#discussion_r2344488116
##########
docs/docs/flink-maintenance.md:
##########
@@ -222,15 +222,17 @@ env.execute("Table Maintenance Job");
#### DeleteOrphanFiles Configuration
-| Method | Description
| Default Value | Type |
-|------------------------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------|--------------------|
-| `location(string)` | The location to start the
recursive listing the candidate files for removal.
| Table's location | String |
-| `usePrefixListing(boolean)` | When true, use prefix-based file
listing via the SupportsPrefixOperations interface. The Table FileIO
implementation must support SupportsPrefixOperations when this flag is
enabled.(Note: Setting it to False will use a recursive method to obtain file
information. If the underlying storage is object storage, it will repeatedly
call the API to get the path.) | False | boolean |
-| `prefixMismatchMode(PrefixMismatchMode)` | Action behavior when location
prefixes (schemes/authorities) mismatch: <ul><li>ERROR - throw an exception.
</li><li>IGNORE - no action.</li><li>DELETE - delete files.</li></ul>
| ERROR | PrefixMismatchMode |
-| `equalSchemes(Map<String, String>)` | Mapping of file system schemes to
be considered equal. Key is a comma-separated list of schemes and value is a
scheme
| "s3n"=>"s3","s3a"=>"s3" | Map<String,String> |
-| `equalAuthorities(Map<String, String>)` | Mapping of file system
authorities to be considered equal. Key is a comma-separated list of
authorities and value is an authority.
| Empty map | Map<String,String> |
-| `minAge(Duration)` | Remove orphan files created
before this timestamp
| 3 days ago | Duration |
-| `planningWorkerPoolSize(int)` | Number of worker threads for
planning snapshot expiration
| Shared worker pool | int |
+| Method | Description
| Default Value | Type |
+|------------------------------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------|--------------------|
+| `location(string)` | The location to start the
recursive listing the candidate files for removal.
| Table's location | String |
+| `usePrefixListing(boolean)` | When true, use prefix-based file
listing via the SupportsPrefixOperations interface. The Table FileIO
implementation must support SupportsPrefixOperations when this flag is
enabled.(Note: Setting it to False will use a recursive method to obtain file
information. If the underlying storage is object storage, it will repeatedly
call the API to get the path.) | False | boolean |
+| `prefixMismatchMode(PrefixMismatchMode)` | Action behavior when location
prefixes (schemes/authorities) mismatch: <ul><li>ERROR - throw an exception.
</li><li>IGNORE - no action.</li><li>DELETE - delete files.</li></ul>
| ERROR | PrefixMismatchMode |
+| `equalSchemes(Map<String, String>)` | Mapping of file system schemes to
be considered equal. Key is a comma-separated list of schemes and value is a
scheme
| "s3n"=>"s3","s3a"=>"s3" | Map<String,String> |
+| `equalAuthorities(Map<String, String>)` | Mapping of file system
authorities to be considered equal. Key is a comma-separated list of
authorities and value is an authority.
| Empty map | Map<String,String> |
+| `minAge(Duration)` | Remove orphan files created
before this timestamp
| 3 days ago | Duration |
+| `planningWorkerPoolSize(int)` | Number of worker threads for
planning snapshot expiration
| Shared worker pool | int |
+| `maxListingDirectSubDirs(int)` | When Flink lists the filesystem,
it uses a two-layer progressive approach for parallel searching. The first
layer is non-concurrent, while the second layer is concurrent. This
configuration specifies the maximum number of direct subdirectories to list in
a single directory. This parameter is not used when usePrefixListing is set to
true. | 10 | int |
+| `maxListingDepth(int)` | When Flink lists the filesystem,
it uses a two-layer progressive approach for parallel searching. The first
layer is non-concurrent, while the second layer is concurrent. This
configuration specifies the maximum depth to recurse when listing files from
the file system.This parameter is not used when usePrefixListing is set to
true. | 3 | int |
Review Comment:
Sorry,I didn't consider that either. I've made the corresponding adjustments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
