Change the ListRebalanceProcessProcedure result from String[] to row[]

[swuferhong]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

see comments: #1452 (comment)

Solution

No response

Anything else?

No response

Willingness to contribute

• I'm willing to submit a PR!

[sd4324530]

Here is my solution:
The definition of the 'call' method can be adjusted like this:

@ProcedureHint(
            argument = {
                @ArgumentHint(
                        name = "rebalanceId",
                        type = @DataTypeHint("STRING"),
                        isOptional = true)
            },
            output =
                    @DataTypeHint(
                            "ROW<rebalance_id STRING, rebalance_status STRING, rebalance_progress STRING, rebalance_plan STRING>"))
    public Row[] call(ProcedureContext context, @Nullable String rebalanceId) throws Exception

The content of the rebalance_plan field is the JSON-formatted string of RebalanceResultForBucket.plan list in the result, like:

for (RebalanceResultForBucket resultForBucket : bucketMap.values()) {
            result.add(resultForBucket.plan());
        }

Because rebalanceStatus already exists.
@swuferhong What do you think? I would be willing to take on this issue if possible

[swuferhong]

Here is my solution: The definition of the 'call' method can be adjusted like this:

@ProcedureHint(
argument = {
@ArgumentHint(
name = "rebalanceId",
type = @DataTypeHint("STRING"),
isOptional = true)
},
output =
@DataTypeHint(
"ROW<rebalance_id STRING, rebalance_status STRING, rebalance_progress STRING, rebalance_plan STRING>"))
public Row[] call(ProcedureContext context, @nullable String rebalanceId) throws Exception
The content of the rebalance_plan field is the JSON-formatted string of RebalanceResultForBucket.plan list in the result, like:

for (RebalanceResultForBucket resultForBucket : bucketMap.values()) {
result.add(resultForBucket.plan());
}
Because rebalanceStatus already exists. @swuferhong What do you think? I would be willing to take on this issue if possible

Hi, @sd4324530. The format look good to me. The detail rebalance plan need to print in json format, you might need to reuse the serialization and deserialization code from RebalanceTaskJsonSerde—please extract the common parts.

[swuferhong]

I assigned to you @sd4324530