codec

package module
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 17, 2023 License: Apache-2.0 Imports: 20 Imported by: 2

Documentation

Index

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 BuildColumn[T any](builder *flatbuffers.Builder, m fbs.Marker, prepend func(T), column map[uint32][]T) flatbuffers.UOffsetT

func FlattenClusterQuery 

func FlattenClusterQuery(query []byte, hosts []string, local int) []byte

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 

type ColumnedEntity struct {
	SchemaVersion uint64
	Columnar      Columnar
}

func DeserializeColumnedEntity 

func DeserializeColumnedEntity(data []byte) (*ColumnedEntity, error)

type DateFormat 

type DateFormat struct {
	Unit     arrow.TimeUnit
	TimeZone string
	Layout   string
}

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) Descriptor() ([]byte, []int)

Deprecated: Use PutResult.ProtoReflect.Descriptor instead.

func (*PutResult) GetError 

func (x *PutResult) GetError() []string

func (*PutResult) GetSeq 

func (x *PutResult) GetSeq() []uint64

func (*PutResult) ProtoMessage 

func (*PutResult) ProtoMessage()

func (*PutResult) ProtoReflect 

func (x *PutResult) ProtoReflect() protoreflect.Message

func (*PutResult) Reset 

func (x *PutResult) Reset()

func (*PutResult) String 

func (x *PutResult) String() string

type Schema 

type Schema struct {
	// contains filtered or unexported fields
}

func (*Schema) AddFields 

func (s *Schema) AddFields(alter *arrow.Schema) (*Schema, error)

func (*Schema) ColumnizeJson 

func (s *Schema) ColumnizeJson(json []byte) ([]*ColumnedEntity, error)

func (*Schema) FromArrowFlightStream 

func (s *Schema) FromArrowFlightStream(ver uint64, info []byte) error

FromArrowFlightStream deserialize schema from Arrow Flight Schema binary format (info)

func (*Schema) ReconcileStatement 

func (s *Schema) ReconcileStatement(stmt *ssql.Statement) (*ssql.Statement, error)

func (*Schema) Rev 

func (s *Schema) Rev() uint64

func (*Schema) ToArrowFlightStream 

func (s *Schema) ToArrowFlightStream() ([]byte, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.