[ Web Proxy ]
URL:
Viewing: https://dtstack.github.io/Taier/docs/functions/task/flink-sql [Back]  [Original]

Flink SQL | Taier
Skip to main content
On this page

Flink SQL

Flink SQL

""""

  1. 64
  2. Flink SQL
  3. 200
  4. ""

  1. Kafka
  2. Kafka
  3. Kafka Topic
  4. Kafka TopicFlinkFlink,FlinkSQL
  5. FlinkProcTime EventTime
    tip

    ProcTime:Operation
    EventTime:EventTimeFlink Watermark

    TimestampWatermarkEvent TimeQuery
    WatermarkEvent time
    Asia/Shanghai)

  6. FlinkTask Slot

add-source [add-source]

  1. MySQLHBaseElasticSearch
    tip

    MySQLMySQL
    HBaseHBaserowkey
    ElasticSearchElasticSearchid

  2. Kafka TopicFlinkFlink,FlinkSQL
  3. Flink <><>AS <>
  4. FlinkTask Slot
  5. :
  6. :

add-source [add-source]

SQL

  1. sql

add-source [add-source]

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;
Copy
tip

sql

add-source [add-source]

add-source [add-source] add-source [add-source]

tip


1.
2. CheckPointSavePoint

execution.checkpointing.intervalCheckPoint


kafka
: hbasemysql es
mysql

caution

Flink SQL Flink


Web Proxy Viewer  |  New URL  |  Original Page