Whojohn opened a new issue, #6880:
URL: https://github.com/apache/kyuubi/issues/6880

   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   
   
   ### Search before asking
   
   - [X] I have searched in the 
[issues](https://github.com/apache/kyuubi/issues?q=is%3Aissue) and found no 
similar issues.
   
   
   ### Describe the feature
   
   ## which feature we need 
    Expose the query operator as Flink SQL client  done for the select query.
   
   
   query like this
   ```
   select sum(a) ,count(*) from sou
   ```
   
   - before this feature(data return as duplicate, make user confuse)
   +--------------+---------+------------+
   |    EXPR$0    | EXPR$1  |
   +--------------+---------+------------+
   | -1861035379  | 1       |
   | -1861035379  | 1       | 
   | -317406356  | 2       | 
   | -317406356  | 2       |
   | -684766290  | 3       | 
   | -684766290  | 3       | 
   
   
   - after (as flink sql client table SET 'sql-client.execution.result-mode' = 
'changelog'; setting )
   +--------------+---------+------------+
   |    EXPR$0    | EXPR$1  | op  |
   +--------------+---------+------------+
   | -1861035379  | 1       | +I         |
   | -1861035379  | 1       | -U         |
   | -317406356  | 2       | +U         |
   | -317406356  | 2       | -U         |
   | -684766290  | 3       | +U         |
   | -684766290  | 3       | -U         |
   
   
   ### Motivation
   
   ## why is nessary ?
   The concept of changelog is specific to Flink SQL. If the operation is not 
exposed, users will be confused when using JDBC/Beeline.
   
   ### Describe the solution
   
   1. FlinkOperation add operator column meta.
   2. FlinkTRowSetGenerator add opeartor as rowdata return .
   
   ### Additional context
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [X] Yes. I would be willing to submit a PR with guidance from the Kyuubi 
community to improve.
   - [ ] No. I cannot submit a PR at this time.


-- 
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: notifications-unsubscr...@kyuubi.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@kyuubi.apache.org
For additional commands, e-mail: notifications-h...@kyuubi.apache.org

Reply via email to