作者:遇见你_天意_384 | 来源:互联网 | 2023-08-29 17:36
CREATETABLEfs_table(p_user_idSTRING,user_idSTRING,order_amountDOUBLE,dtSTRING,hstring,mstr
CREATE TABLE fs_table (p_user_id STRING,user_id STRING,order_amount DOUBLE,dt STRING,h string,m string
) PARTITIONED BY (p_user_id) WITH ('connector'='filesystem','path'='file:///D:\\flinkSqlSink\\abc','csv.disable-quote-character'='true','csv.line-delimiter'=U&'\000A','csv.field-delimiter'=U&'\0001','format'='csv'
)