Versions in this module Expand all Collapse all v0 v0.1.0 Mar 17, 2023 Changes in this version + const DayInMillis + var File_codec_proto protoreflect.FileDescriptor + var FlightServiceAction_name = map[int32]string + var FlightServiceAction_value = map[string]int32 + func BuildColumn(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 struct + ArrayBracket map[uint32][]uint16 + ArrayElement map[uint32][]uint16 + Bool map[uint32][]bool + Date32 map[uint32][]int32 + Date64 map[uint32][]int64 + Float32 map[uint32][]float32 + Float64 map[uint32][]float64 + Int16 map[uint32][]int16 + Int32 map[uint32][]int32 + Int64 map[uint32][]int64 + Int8 map[uint32][]int8 + Null map[uint32][]uint16 + Text map[uint32][][]byte + UInt16 map[uint32][]uint16 + UInt32 map[uint32][]uint32 + UInt64 map[uint32][]uint64 + UInt8 map[uint32][]uint8 + type ColumnarBuilderFunction struct + type ColumnedEntity struct + Columnar Columnar + SchemaVersion uint64 + func DeserializeColumnedEntity(data []byte) (*ColumnedEntity, error) + type DateFormat struct + Layout string + TimeZone string + Unit arrow.TimeUnit + type FileTransferRequest struct + Data []byte + Flight string + Id uint64 + Replica uint32 + func (*FileTransferRequest) Descriptor() ([]byte, []int) + func (*FileTransferRequest) ProtoMessage() + func (x *FileTransferRequest) GetData() []byte + func (x *FileTransferRequest) GetFlight() string + func (x *FileTransferRequest) GetId() uint64 + func (x *FileTransferRequest) GetReplica() uint32 + func (x *FileTransferRequest) ProtoReflect() protoreflect.Message + func (x *FileTransferRequest) Reset() + func (x *FileTransferRequest) String() string + type FlightSchemaRequest struct + Flight string + Schema []byte + func (*FlightSchemaRequest) Descriptor() ([]byte, []int) + func (*FlightSchemaRequest) ProtoMessage() + func (x *FlightSchemaRequest) GetFlight() string + func (x *FlightSchemaRequest) GetSchema() []byte + func (x *FlightSchemaRequest) ProtoReflect() protoreflect.Message + func (x *FlightSchemaRequest) Reset() + func (x *FlightSchemaRequest) String() string + type FlightServiceAction int32 + const FlightServiceAction_CreateFlight + const FlightServiceAction_DeleteFlight + const FlightServiceAction_UpdateFile + const FlightServiceAction_UpdateSchema + const FlightServiceAction_UploadFile + func (FlightServiceAction) Descriptor() protoreflect.EnumDescriptor + func (FlightServiceAction) EnumDescriptor() ([]byte, []int) + func (FlightServiceAction) Type() protoreflect.EnumType + func (x FlightServiceAction) Enum() *FlightServiceAction + func (x FlightServiceAction) Number() protoreflect.EnumNumber + func (x FlightServiceAction) String() string + type PutResult struct + Error []string + Seq []uint64 + func (*PutResult) Descriptor() ([]byte, []int) + func (*PutResult) ProtoMessage() + func (x *PutResult) GetError() []string + func (x *PutResult) GetSeq() []uint64 + func (x *PutResult) ProtoReflect() protoreflect.Message + func (x *PutResult) Reset() + func (x *PutResult) String() string + type Schema struct + 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)