DStream::sink
语法
DStream::sink(dest|name, [asyncWrite=true], [compress=true], [cacheSize],
[retentionMinutes=1440], [flushMode=0], [preCache], [cachePurgeTimeColumn],
[cachePurgeInterval], [cacheRetentionTime])
参数
dest | name 流数据的输出目标，可以是：
- 字符串标量，指定目标流表或 DFS 表全限定名（如 "catalog_name.orca_table.table_name"）或 DFS 表路径（如 "dfs://dbName/tableName"）。
- 一元函数，入参为流数据消息组成的表，忽略返回值。
asyncWrite 可选参数，是一个布尔值，表示是否异步持久化数据到磁盘。默认值为 true，流数据写入内存即为写入成功，持久化到磁盘的操作将会由另一个线程执行。
持久化数据到磁盘包含两个步骤：
-
写内存数据到操作系统缓存
-
写缓存数据到磁盘（是否开启同步刷盘由参数 flushMode 决定）
compress 可选参数，是一个布尔值，表示是否以压缩模式模式保存至磁盘。默认值为 true。
cacheSize 可选参数，整数，表示流数据表在内存中最多保留多少行。如果未指定该参数，则所有记录行都会保存在内存中。如果 cacheSize 小于 1000，它会被自动调整为 1000。
retentionMinutes 可选参数，是一个整数，表示文件大小超过 1GB的 log 文件的保留时间(从文件的最后修改时间开始计算)，单位是分钟。默认值是 1440，即一天。如果 log 文件未达 1GB，则会一直保留至大小达到 1GB。
flushMode 可选参数，是一个整数，表示是否开启同步刷盘，取值只能为 0 或 1。默认值是 0，表示异步刷盘，内存中的流数据写入操作系统缓存即为写入成功，并进行下一批数据的写入。 若为 1，则表示同步刷盘，当前批次的流数据必须落盘完成，才会进行下一批数据的写入。
preCache 可选参数，是一个整数，表示从磁盘加载到内存的记录条数。如果没有指定该参数，默认会把所有记录加载到内存中。
cachePurgeTimeColumn 可选参数，字符串标量，需要指定为持久化流表中的时间列名称。
cachePurgeInterval 可选参数，DURATION 类型标量，表示触发清理内存中数据的时间间隔。
cacheRetentionTime 可选参数，DURATION 类型标量，表示内存中数据的最长保留期限。