smileyboy2019 commented on PR #46154:
URL: https://github.com/apache/spark/pull/46154#issuecomment-2068599219
How to use Structured Streaming in Spark SQL
In Flink, you can create flow calculation tables using Flink SQL, and
directly connect with SQL through CDC and Kafka. How to use SQL for flow
calculation in Spark
for example
CREATE TABLE orders (
order_id INT,
order_date TIMESTAMP(0),
customer_name STRING,
price DECIMAL(10, 5),
product_id INT,
order_status BOOLEAN
) WITH (
'connector' = 'mysql-cdc',
'hostname' = 'localhost',
'port' = '3306',
'username' = 'root',
'password' = '123456',
'database-name' = 'mydb',
'table-name' = 'orders'
);
SELECT * FROM orders
insert into orders_sink select * from orders
志阳
***@***.***
------------------ 原始邮件 ------------------
发件人:
"apache/spark"
***@***.***>;
发送时间: 2024年4月22日(星期一) 中午1:25
***@***.***>;
***@***.******@***.***>;
主题: Re: [apache/spark] [SPARK-47932][SQL][TEST] Avoid using legacy
commons-lang (PR #46154)
@LuciferYang approved this pull request.
—
Reply to this email directly, view it on GitHub, or unsubscribe.
You are receiving this because you were mentioned.Message ID: ***@***.***>
--
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]
