This directory documents sink connectors for Streaming SQL.
| Connector | Supported formats |
|---|---|
kafka |
json / raw_string / raw_bytes |
filesystem |
csv / parquet / json(JSONL) / avro / orc |
s3 |
csv / parquet |
delta |
csv / parquet / json(JSONL) / avro / orc |
iceberg |
csv / parquet |
lanceDB |
lance |
- Configure sink connectors via
WITH (...)inCREATE STREAMING TABLE ... AS SELECT .... - Use
type='sink'explicitly for sink tables. - Only
lanceDBacceptsformat='lance'. - For file-like sinks,
format='json'is written as JSON Lines (NDJSON,.jsonl).