JingsongLi commented on code in PR #5095:
URL: https://github.com/apache/paimon/pull/5095#discussion_r1957763563
##########
docs/content/flink/procedures.md:
##########
@@ -681,5 +681,35 @@ All available procedures are listed below.
CALL sys.compact_manifest(`table` => 'default.T')
</td>
</tr>
+ <tr>
+ <td>compact_postpone_bucket</td>
+ <td>
+ CALL sys.compact_postpone_bucket(`table` => 'identifier',
`default_bucket_num` => bucket_num, `parallelism` => parallelism)
+ </td>
+ <td>
+ Compact postpone bucket tables, which distributes records in
bucket-postpone directory into real bucket directories. Arguments:
+ <li>identifier: The target table identifier. Cannot be empty.</li>
+ <li>bucket_num: Bucket number for the partitions compacted for the
first time. Default value is 4.</li>
+ <li>parallelism: Parallelism of this job.</li>
+ </td>
+ <td>
+ CALL sys.compact_postpone_bucket(`table` => 'default.T')
+ </td>
+ </tr>
+ <tr>
+ <td>rescale_postpone_bucket</td>
+ <td>
+ CALL sys.rescale_postpone_bucket(`table` => 'identifier',
`bucket_num` => bucket_num, `partition` => 'partition')
Review Comment:
We can have an unify rescale procedure.
--
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]
