Documentation
¶
Index ¶
- type Connection
- func (conn *Connection) Close()
- func (conn *Connection) DeregisterTable(name string) error
- func (conn *Connection) Prepare(query string) (*Statement, error)
- func (conn *Connection) RegisterArrowIPC(name string, data []byte) error
- func (conn *Connection) RegisterArrowReaderZeroCopy(name string, reader array.RecordReader) error
- func (conn *Connection) RegisterFFITableProvider(name string, provider unsafe.Pointer, providerDataFusionVersion string) error
- type Database
- type DateParameter
- type DecimalParameter
- type DurationParameter
- type Error
- type NullParameter
- type ParameterType
- type Statement
- type TimeParameter
- type TimestampParameter
- type UInt64Parameter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func (*Connection) Close ¶
func (conn *Connection) Close()
func (*Connection) DeregisterTable ¶ added in v0.530100.2
func (conn *Connection) DeregisterTable(name string) error
DeregisterTable removes a table previously registered on the connection's session. Removing a name that is not registered is not an error.
func (*Connection) RegisterArrowIPC ¶
func (conn *Connection) RegisterArrowIPC(name string, data []byte) error
func (*Connection) RegisterArrowReaderZeroCopy ¶
func (conn *Connection) RegisterArrowReaderZeroCopy(name string, reader array.RecordReader) error
func (*Connection) RegisterFFITableProvider ¶ added in v0.530100.2
func (conn *Connection) RegisterFFITableProvider(name string, provider unsafe.Pointer, providerDataFusionVersion string) error
RegisterFFITableProvider registers a foreign datafusion-ffi FFI_TableProvider (produced by another library) under name. provider must point to a valid FFI_TableProvider; the callee clones it, so the caller retains ownership of the pointer. providerDataFusionVersion is the datafusion version the producing library reports, checked against the native library's version before the provider is dereferenced. The producing library must stay loaded for as long as the table is registered, since the registered table calls back into it on every scan. See datafusion.RegisterFFITableProvider for the full contract.
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func OpenDatabase ¶
type DateParameter ¶
type DateParameter struct {
Days int32
}
type DecimalParameter ¶
type DurationParameter ¶
type DurationParameter struct {
Nanoseconds int64
}
type Error ¶
func (*Error) NativeErrorKind ¶
type NullParameter ¶
type NullParameter struct {
Type ParameterType
Precision uint8
Scale int8
TimeZone string
}
type ParameterType ¶
type ParameterType int32
const ( ParameterBool ParameterType = iota + 1 ParameterInt64 ParameterUInt64 ParameterFloat64 ParameterString ParameterBinary ParameterDate ParameterTime ParameterTimestamp ParameterDuration ParameterDecimal )
type Statement ¶
type Statement struct {
// contains filtered or unexported fields
}
func (*Statement) ExecuteArrow ¶
func (*Statement) Serializes ¶
type TimeParameter ¶
type TimeParameter struct {
Nanoseconds int64
}
type TimestampParameter ¶
type UInt64Parameter ¶
type UInt64Parameter struct {
Value uint64
}
Source Files