flinksql建表使用压缩模式

Apache Flink SQL是一种用于Apache Flink流处理和批处理任务的语言。在Flink SQL中，你可以通过`CREATE TABLE`语句来创建表，并指定数据的存储方式和压缩模式。以下是使用压缩模式的基本步骤：

1. **创建表**:

   CREATE TABLE your_table (
       column1 INT,
       column2 STRING,
       ...
   ) WITH (
      'connector' = '...',            -- 数据源，比如Kafka或HDFS，
      'format' = 'parquet',           -- 文件格式，Parquet通常支持压缩
      'compression.type' = 'SNAPPY'  -- 设置为SNAPPY压缩
   );

或者如果是CSV格式：

   CREATE TABLE your_table (
       column1 STRING,
       ...
   ) WITH (
      'connector' = '...',             -- 数据源，比如Kafka或HDFS,
      'format' = 'csv',                -- CSV格式
      'compress-csv' = true,            -- 启动CSV压缩
      'compress-csv.compression' = 'SNAPPY' -- 使用SNAPPY压缩算法
   );

2. **压缩配置**:
在上述例子中，`compression.type`或`compress-csv.compression`属性指定了压缩类型。Flink SQL支持多种压缩技术，如`GZipped`, `BROTLI`, `LZ4`和`SNAPPY`。

3. **写入压缩数据**:
当数据被写入到这个表时，Flink会根据所选的压缩模式对数据进行压缩。