import { IcebergAppendSinkOptions, Sink } from "../sink.mjs";
type IcebergAppendSink = Sink;
/**
 * Create an `IcebergAppendSink` over the R2 Data Catalog.
 *
 * `emit` buffers; `close()` commits one `icebergAppend()` per table touched.
 * The catalog connection (REST context + signed S3 resolver) is established
 * lazily on the first flush and reused — a sink that is opened and closed
 * with no rows never touches the network. `options.connect` is forwarded so
 * Worker callers can share the `/v1/config` context through a durable cache;
 * without it every fresh sink/isolate must probe the catalog again.
 */
declare function createIcebergAppendSink(options: IcebergAppendSinkOptions): IcebergAppendSink;
export { IcebergAppendSink, createIcebergAppendSink };