On this page
Flink SQL
Flink SQL
""""
- 64
- Flink SQL
- 200
- ""
KafkaKafkaKafka TopicKafka TopicFlinkFlink,FlinkSQL- Flink
ProcTimeEventTimetip
ProcTime:Operation
EventTime:EventTimeFlink WatermarkTimestampWatermarkEvent TimeQuery
WatermarkEvent time
Asia/Shanghai) - FlinkTask Slot
MySQLHBaseElasticSearchtip
MySQLMySQL
HBaseHBaserowkey
ElasticSearchElasticSearchidKafka TopicFlinkFlink,FlinkSQL- Flink
<><>AS <> - FlinkTask Slot
- :
- :
SQL
- sql
SQL
CREATE TABLE source
(
id INT,
name STRING,
money DECIMAL(32, 2),
dateone timestamp,
age bigint,
datethree timestamp,
datesix timestamp(6),
datenigth timestamp(9),
dtdate date,
dttime time
) WITH (
'connector' = 'stream-x',
'number-of-rows' = '10', --
'rows-per-second' = '1' --
);
CREATE TABLE sink
(
id INT,
name STRING,
money DECIMAL(32, 2),
dateone timestamp,
age bigint,
datethree timestamp,
datesix timestamp(6),
datenigth timestamp(9),
dtdate date,
dttime time
) WITH (
'connector' = 'stream-x',
'print' = 'true'
);
insert into sink
select *
from source;
Copytip
sql chunjun
sql
tip
1.
2. CheckPointSavePoint
execution.checkpointing.intervalCheckPoint
kafka
: hbasemysql es
mysql
caution
Flink SQL Flink