// clickhouse.ts
import { Sink, SinkConfig } from "./types.js";

export class ClickhouseSink implements Sink {
    // TODO: implement HTTP JSONEachRow streaming
    constructor(_cfg: SinkConfig) {}
    async init(): Promise<void> { throw new Error("ClickhouseSink not implemented yet"); }
    async write(_line: string): Promise<void> { throw new Error("ClickhouseSink not implemented yet"); }
    async close(): Promise<void> { /* noop */ }
}