本目录聚焦 Streaming SQL 的下游写出能力(Sink)。
| Connector | 支持格式 |
|---|---|
| kafka | json / raw_string / raw_bytes(沿用 Kafka Sink 编码能力) |
| filesystem | csv / parquet / json(JSONL) / avro / orc |
| s3 | csv / parquet |
| delta | csv / parquet / json(JSONL) / avro / orc |
| iceberg | csv / parquet |
| lanceDB | lance |
- 在
CREATE STREAMING TABLE ... WITH (...) AS SELECT ...中通过WITH指定connector与format。 - Sink 场景建议显式指定
type='sink'。 - 仅
lanceDBconnector 允许format='lance';其余 Sink connector 不支持lance。 format='json'的文件类 Sink 输出为 JSON Lines(NDJSON,.jsonl)。