更新时间:2024-07-27 GMT+08:00
Print结果表
功能描述
print connector用于将用户输出的数据打印到error文件或者taskmanager的out文件中,方便用户查看,主要用于代码调试,查看输出结果。
语法格式
1 2 3 4 5 6 7 |
create table printSink ( attr_name attr_type (',' attr_name attr_type) * (',' PRIMARY KEY (attr_name,...) NOT ENFORCED) ) with ( 'connector' = 'print', 'print-identifier' = '', 'standard-error' = '' ); |
参数说明
参数 |
是否必选 |
说明 |
---|---|---|
connector |
是 |
固定为print。 |
print-identifier |
否 |
配置一个标识符作为输出数据的前缀。 |
standard-error |
否 |
该值只能为true或false,默认为false。
|
示例
从kafka中读取数据输出到taskmanager的out文件中,可以在taskmanager的out文件中看到输出结果。
create table kafkaSource( attr0 string, attr1 boolean, attr3 decimal(38, 18), attr4 TINYINT, attr5 smallint, attr6 int, attr7 bigint, attr8 float, attr9 double, attr10 date, attr11 time, attr12 timestamp(3) ) with ( 'connector.type' = 'kafka', 'connector.version' = '0.11', 'connector.topic' = 'test_json', 'connector.properties.bootstrap.servers' = 'xx.xx.xx.xx:9092', 'connector.properties.group.id' = 'test_print', 'connector.startup-mode' = 'latest-offset', 'format.type' = 'csv' ); create table printTable( attr0 string, attr1 boolean, attr3 decimal(38,18), attr4 TINYINT, attr5 smallint, attr6 int, attr7 bigint, attr8 float, attr9 double, attr10 date, attr11 time, attr12 timestamp(3), attr13 array<string>, attr14 row<attr15 float, attr16 timestamp(3)>, attr17 map<int, bigint> ) with ( "connector" = "print" ); insert into printTable select attr0, attr1, attr3, attr4, attr5, attr6, attr7, attr8, attr9, attr10, attr11, attr12, array [cast(attr0 as string), cast(attr0 as string)], row( cast(attr8 as float), cast(attr12 as timestamp(3)) ), map [cast(attr6 as int), cast(attr7 as bigint)] from kafkaSource;
父主题: 创建结果表