Interface ColumnarWorkflowOptionsExperimental

interface ColumnarWorkflowOptions {
    beforeRequest?: ((request: ColumnarWorkflowRequest) => void | ColumnarWorkflowRequest | Promise<void | ColumnarWorkflowRequest>);
    budgets?: Partial<ColumnarWorkflowBudgets>;
    clientOptions?: Omit<HonuaClientOptions, "baseUrl">;
    decodeServerResponse?: ColumnarResponseDecoder;
    directFetchFn?: {
        (input: URL | RequestInfo, init?: RequestInit): Promise<Response>;
        (input: string | URL | Request, init?: RequestInit): Promise<Response>;
    };
    inspectBatch?: ((batch: ColumnarBatchV1, limits: Pick<ColumnarWorkflowBudgets, "maxRows" | "maxBackingBytes">) => ColumnarBatchMetrics);
    now?: (() => number);
    onProgress?: ((progress: ColumnarWorkflowProgress) => void);
    openDirectGeoParquet?: DirectGeoParquetOpener;
}

Properties

beforeRequest?: ((request: ColumnarWorkflowRequest) => void | ColumnarWorkflowRequest | Promise<void | ColumnarWorkflowRequest>)
budgets?: Partial<ColumnarWorkflowBudgets>
clientOptions?: Omit<HonuaClientOptions, "baseUrl">
decodeServerResponse?: ColumnarResponseDecoder
directFetchFn?: {
    (input: URL | RequestInfo, init?: RequestInit): Promise<Response>;
    (input: string | URL | Request, init?: RequestInit): Promise<Response>;
}

Fetch implementation used by the default bounded direct-GeoParquet opener.

Type declaration

    • (input, init?): Promise<Response>
    • Parameters

      • input: URL | RequestInfo
      • Optionalinit: RequestInit

      Returns Promise<Response>

    • (input, init?): Promise<Response>
    • Parameters

      • input: string | URL | Request
      • Optionalinit: RequestInit

      Returns Promise<Response>

inspectBatch?: ((batch: ColumnarBatchV1, limits: Pick<ColumnarWorkflowBudgets, "maxRows" | "maxBackingBytes">) => ColumnarBatchMetrics)
now?: (() => number)
onProgress?: ((progress: ColumnarWorkflowProgress) => void)
openDirectGeoParquet?: DirectGeoParquetOpener