阿里云Flink sql 基本使用手册

以下操作全部按照阿里云官方文档整理。

参考文档参考 实时计算Flink版 - 帮助中心 - 阿里云https://help.aliyun.com/product/45029.html

CREATE TEMPORARY TABLE datahub_source (
  `goods_id` String,
  `goods_name` String,
  `goods_category` String,
  `goods_price` String,
  `etl_time` BIGINT
) WITH (
  'connector' = 'datahub',
  'subId' = 'xxxx',
  'endPoint' = 'https://dh-cn-shanghai.aliyuncs.com',
  'project' = 'xxxx',
  'topic' = 'xxxx',
  'accessid' = 'xxxx',
  'accesskey' = 'xxxx',