Methods
cancelSent
- cancelSent(): boolean
Returns boolean
close
- close(): void
Returns void
createScalarFunction
- createScalarFunction(name, returns, func): void
Parameters
name: string
returns: DataType<Type, any>
func: ((...args) => void)
- (...args): void
Returns void
Returns void
getTableNames
- getTableNames(query): string[]
Returns string[]
insertArrowFromIPCStream
- insertArrowFromIPCStream(buffer, options): void
Returns void
insertArrowTable
- insertArrowTable(table, options): void
Returns void
insertCSVFromPath
- insertCSVFromPath(path, options): void
Returns void
insertJSONFromPath
- insertJSONFromPath(path, options): void
Returns void
prepare
- prepare<T>(text): PreparedStatement<any>
Type Parameters
T extends {
[key: string]: arrow.DataType;
} = any
query
- query<T>(text): Table<T>
Type Parameters
T extends {
[key: string]: arrow.DataType;
} = any
Returns Table<T>
send
- send<T>(text): Promise<RecordBatchStreamReader<T>>
Type Parameters
T extends {
[key: string]: arrow.DataType;
} = any
Returns Promise<RecordBatchStreamReader<T>>
useUnsafe
- useUnsafe<R>(callback): R
Parameters
callback: ((bindings, conn) => R)
- (bindings, conn): R
Returns R
Returns R
A thin helper to bind the connection id and talk record batches