Documentation ¶
Index ¶
- Constants
- Variables
- func BuildColumn[T any](builder *flatbuffers.Builder, m fbs.Marker, prepend func(T), ...) flatbuffers.UOffsetT
- func FlattenClusterQuery(query []byte, hosts []string, local int) []byte
- func FlattenColumnizedEntities(entities []*ColumnedEntity) []byte
- func SerializeColumnedEntity(entity *ColumnedEntity) ([]byte, error)
- type Columnar
- type ColumnarBuilderFunction
- type ColumnedEntity
- type DateFormat
- type FileTransferRequest
- func (*FileTransferRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FileTransferRequest) GetData() []byte
- func (x *FileTransferRequest) GetFlight() string
- func (x *FileTransferRequest) GetId() uint64
- func (x *FileTransferRequest) GetReplica() uint32
- func (*FileTransferRequest) ProtoMessage()
- func (x *FileTransferRequest) ProtoReflect() protoreflect.Message
- func (x *FileTransferRequest) Reset()
- func (x *FileTransferRequest) String() string
- type FlightSchemaRequest
- func (*FlightSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FlightSchemaRequest) GetFlight() string
- func (x *FlightSchemaRequest) GetSchema() []byte
- func (*FlightSchemaRequest) ProtoMessage()
- func (x *FlightSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *FlightSchemaRequest) Reset()
- func (x *FlightSchemaRequest) String() string
- type FlightServiceAction
- func (FlightServiceAction) Descriptor() protoreflect.EnumDescriptor
- func (x FlightServiceAction) Enum() *FlightServiceAction
- func (FlightServiceAction) EnumDescriptor() ([]byte, []int)deprecated
- func (x FlightServiceAction) Number() protoreflect.EnumNumber
- func (x FlightServiceAction) String() string
- func (FlightServiceAction) Type() protoreflect.EnumType
- type PutResult
- type Schema
- func (s *Schema) AddFields(alter *arrow.Schema) (*Schema, error)
- func (s *Schema) ColumnizeJson(json []byte) ([]*ColumnedEntity, error)
- func (s *Schema) FromArrowFlightStream(ver uint64, info []byte) error
- func (s *Schema) ReconcileStatement(stmt *ssql.Statement) (*ssql.Statement, error)
- func (s *Schema) Rev() uint64
- func (s *Schema) ToArrowFlightStream() ([]byte, error)
Constants ¶
View Source
const (
DayInMillis = 24 * 60 * 60 * 1000
)
Variables ¶
View Source
var ( FlightServiceAction_name = map[int32]string{ 0: "CreateFlight", 1: "DeleteFlight", 2: "UpdateSchema", 3: "UpdateFile", 4: "UploadFile", } FlightServiceAction_value = map[string]int32{ "CreateFlight": 0, "DeleteFlight": 1, "UpdateSchema": 2, "UpdateFile": 3, "UploadFile": 4, } )
Enum value maps for FlightServiceAction.
View Source
var File_codec_proto protoreflect.FileDescriptor
Functions ¶
func BuildColumn ¶
func FlattenColumnizedEntities ¶
func FlattenColumnizedEntities(entities []*ColumnedEntity) []byte
func SerializeColumnedEntity ¶
func SerializeColumnedEntity(entity *ColumnedEntity) ([]byte, error)
Types ¶
type Columnar ¶
type Columnar struct { Int8 map[uint32][]int8 // 1 UInt8 map[uint32][]uint8 // 2 Int16 map[uint32][]int16 // 3 UInt16 map[uint32][]uint16 // 4 Int32 map[uint32][]int32 // 5 Date32 map[uint32][]int32 // 6 UInt32 map[uint32][]uint32 // 7 Int64 map[uint32][]int64 // 8 Date64 map[uint32][]int64 // 9 UInt64 map[uint32][]uint64 // 10 Float32 map[uint32][]float32 // 11 Float64 map[uint32][]float64 // 12 Text map[uint32][][]byte // 13 Bool map[uint32][]bool // 14 Null map[uint32][]uint16 // 15 ArrayBracket map[uint32][]uint16 // 16 ArrayElement map[uint32][]uint16 // 17 }
type ColumnarBuilderFunction ¶
type ColumnarBuilderFunction struct {
// contains filtered or unexported fields
}
type ColumnedEntity ¶
func DeserializeColumnedEntity ¶
func DeserializeColumnedEntity(data []byte) (*ColumnedEntity, error)
type FileTransferRequest ¶
type FileTransferRequest struct { Flight string `protobuf:"bytes,1,opt,name=flight,proto3" json:"flight,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Replica uint32 `protobuf:"varint,3,opt,name=replica,proto3" json:"replica,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*FileTransferRequest) Descriptor
deprecated
func (*FileTransferRequest) Descriptor() ([]byte, []int)
Deprecated: Use FileTransferRequest.ProtoReflect.Descriptor instead.
func (*FileTransferRequest) GetData ¶
func (x *FileTransferRequest) GetData() []byte
func (*FileTransferRequest) GetFlight ¶
func (x *FileTransferRequest) GetFlight() string
func (*FileTransferRequest) GetId ¶
func (x *FileTransferRequest) GetId() uint64
func (*FileTransferRequest) GetReplica ¶
func (x *FileTransferRequest) GetReplica() uint32
func (*FileTransferRequest) ProtoMessage ¶
func (*FileTransferRequest) ProtoMessage()
func (*FileTransferRequest) ProtoReflect ¶
func (x *FileTransferRequest) ProtoReflect() protoreflect.Message
func (*FileTransferRequest) Reset ¶
func (x *FileTransferRequest) Reset()
func (*FileTransferRequest) String ¶
func (x *FileTransferRequest) String() string
type FlightSchemaRequest ¶
type FlightSchemaRequest struct { Flight string `protobuf:"bytes,1,opt,name=flight,proto3" json:"flight,omitempty"` Schema []byte `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` // contains filtered or unexported fields }
func (*FlightSchemaRequest) Descriptor
deprecated
func (*FlightSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use FlightSchemaRequest.ProtoReflect.Descriptor instead.
func (*FlightSchemaRequest) GetFlight ¶
func (x *FlightSchemaRequest) GetFlight() string
func (*FlightSchemaRequest) GetSchema ¶
func (x *FlightSchemaRequest) GetSchema() []byte
func (*FlightSchemaRequest) ProtoMessage ¶
func (*FlightSchemaRequest) ProtoMessage()
func (*FlightSchemaRequest) ProtoReflect ¶
func (x *FlightSchemaRequest) ProtoReflect() protoreflect.Message
func (*FlightSchemaRequest) Reset ¶
func (x *FlightSchemaRequest) Reset()
func (*FlightSchemaRequest) String ¶
func (x *FlightSchemaRequest) String() string
type FlightServiceAction ¶
type FlightServiceAction int32
const ( FlightServiceAction_CreateFlight FlightServiceAction = 0 FlightServiceAction_DeleteFlight FlightServiceAction = 1 FlightServiceAction_UpdateSchema FlightServiceAction = 2 FlightServiceAction_UpdateFile FlightServiceAction = 3 //DirectQuery = 4; FlightServiceAction_UploadFile FlightServiceAction = 4 )
func (FlightServiceAction) Descriptor ¶
func (FlightServiceAction) Descriptor() protoreflect.EnumDescriptor
func (FlightServiceAction) Enum ¶
func (x FlightServiceAction) Enum() *FlightServiceAction
func (FlightServiceAction) EnumDescriptor
deprecated
func (FlightServiceAction) EnumDescriptor() ([]byte, []int)
Deprecated: Use FlightServiceAction.Descriptor instead.
func (FlightServiceAction) Number ¶
func (x FlightServiceAction) Number() protoreflect.EnumNumber
func (FlightServiceAction) String ¶
func (x FlightServiceAction) String() string
func (FlightServiceAction) Type ¶
func (FlightServiceAction) Type() protoreflect.EnumType
type PutResult ¶
type PutResult struct { Seq []uint64 `protobuf:"varint,1,rep,packed,name=seq,proto3" json:"seq,omitempty"` Error []string `protobuf:"bytes,2,rep,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*PutResult) Descriptor
deprecated
func (*PutResult) ProtoMessage ¶
func (*PutResult) ProtoMessage()
func (*PutResult) ProtoReflect ¶
func (x *PutResult) ProtoReflect() protoreflect.Message
type Schema ¶
type Schema struct {
// contains filtered or unexported fields
}
func (*Schema) ColumnizeJson ¶
func (s *Schema) ColumnizeJson(json []byte) ([]*ColumnedEntity, error)
func (*Schema) FromArrowFlightStream ¶
FromArrowFlightStream deserialize schema from Arrow Flight Schema binary format (info)
func (*Schema) ReconcileStatement ¶
func (*Schema) ToArrowFlightStream ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.