utils

Documentation

Index

• Constants
• type Field
  • func Copy(field Field) Field
  • func NewField(DataType string) Field
  • func (f *Field) GetBinaryV() []byte
  • func (f *Field) GetBoolV() bool
  • func (f *Field) GetDoubleV() float64
  • func (f *Field) GetField(value interface{}, dateType string) *Field
  • func (f *Field) GetFloatV() float32
  • func (f *Field) GetIntV() int32
  • func (f *Field) GetLongV() int64
  • func (f *Field) GetObjectValue(dateType string) interface{}
  • func (f *Field) GetStringValue() string
  • func (f *Field) IsNull() bool
  • func (f *Field) SetBinaryV(binaryVal []byte)
  • func (f *Field) SetBoolV(boolVal bool)
  • func (f *Field) SetDoubleV(doubleVal float64)
  • func (f *Field) SetFloatV(floatVal float32)
  • func (f *Field) SetIntV(intVal int32)
  • func (f *Field) SetLongV(longVal int64)
  • func (f *Field) ToString() string
• type IoTDBRpcDataSet
  • func NewIoTDBRpcDataSet(dataSet *SessionDataSet, fetchSize int32) *IoTDBRpcDataSet
• type RowRecord
  • func (r *RowRecord) AddField(field Field)
• type SessionDataSet
  • func NewSessionDataSet(dataSet *SessionDataSet) *SessionDataSet
  • func (s *SessionDataSet) CloseOperationHandle()
  • func (s *SessionDataSet) GetColumnNames() []string
  • func (s *SessionDataSet) GetColumnTypes() []string
  • func (s *SessionDataSet) HasNext() bool
  • func (s *SessionDataSet) Next() *RowRecord
• type Tablet
  • func (t *Tablet) GetBinaryTimestamps() []byte
  • func (t *Tablet) GetBinaryValues() []byte
  • func (t *Tablet) GetDeviceId() string
  • func (t *Tablet) GetMeasurements() []string
  • func (t *Tablet) GetRowNumber() int32
  • func (t *Tablet) GetTypes() []int32
  • func (t *Tablet) SortTablet()

Constants

const (
	BOOLEAN int32 = 0
	INT32   int32 = 1
	INT64   int32 = 2
	FLOAT   int32 = 3
	DOUBLE  int32 = 4
	TEXT    int32 = 5
	INT     int32 = 6
)

const (
	PLAIN            int32 = 0
	PLAIN_DICTIONARY int32 = 1
	RLE              int32 = 2
	DIFF             int32 = 3
	TS_2DIFF         int32 = 4
	BITMAP           int32 = 5
	GORILLA_V1       int32 = 6
	REGULAR          int32 = 7
	GORILLA          int32 = 8
)

const (
	UNCOMPRESSED int32 = 0
	SNAPPY       int32 = 1
	GZIP         int32 = 2
	LZO          int32 = 3
	SDT          int32 = 4
	PAA          int32 = 5
	PLA          int32 = 6
	LZ4          int32 = 7
)

const (
	Flag         = 0x80
	StarIndex    = 2
	TimeStampStr = "Time"
)

const (
	DefaultFetchSize int32 = 10000
)

Types

type Field

type Field struct {
	DataType string
	// contains filtered or unexported fields
}

func Copy

func Copy(field Field) Field

func NewField

func NewField(DataType string) Field

func (*Field) GetBinaryV

func (f *Field) GetBinaryV() []byte

func (*Field) GetBoolV

func (f *Field) GetBoolV() bool

func (*Field) GetDoubleV

func (f *Field) GetDoubleV() float64

func (*Field) GetField

func (f *Field) GetField(value interface{}, dateType string) *Field

func (*Field) GetFloatV

func (f *Field) GetFloatV() float32

func (*Field) GetIntV

func (f *Field) GetIntV() int32

func (*Field) GetLongV

func (f *Field) GetLongV() int64

func (*Field) GetObjectValue

func (f *Field) GetObjectValue(dateType string) interface{}

func (*Field) GetStringValue

func (f *Field) GetStringValue() string

func (*Field) IsNull

func (f *Field) IsNull() bool

func (*Field) SetBinaryV

func (f *Field) SetBinaryV(binaryVal []byte)

func (*Field) SetBoolV

func (f *Field) SetBoolV(boolVal bool)

func (*Field) SetDoubleV

func (f *Field) SetDoubleV(doubleVal float64)

func (*Field) SetFloatV

func (f *Field) SetFloatV(floatVal float32)

func (*Field) SetIntV

func (f *Field) SetIntV(intVal int32)

func (*Field) SetLongV

func (f *Field) SetLongV(longVal int64)

func (*Field) ToString

func (f *Field) ToString() string

type IoTDBRpcDataSet

type IoTDBRpcDataSet struct {
	Sql             string
	ColumnNameList  []string
	ColumnTypeList  []string
	ColumnNameIndex map[string]int32
	QueryId         int64
	SessionId       int64
	IgnoreTimeStamp bool
	Client          *rpc.TSIServiceClient
	QueryDataSet    *rpc.TSQueryDataSet
	FetchSize       int32

	ColumnTypeDeduplicatedList []string
	Values                     [][]byte
	HasCachedRecord            bool
	ColumnOrdinalMap           map[string]int32
	// contains filtered or unexported fields
}

func NewIoTDBRpcDataSet

func NewIoTDBRpcDataSet(dataSet *SessionDataSet, fetchSize int32) *IoTDBRpcDataSet

type RowRecord

type RowRecord struct {
	Timestamp int64
	Fields    []Field
}

func (*RowRecord) AddField

func (r *RowRecord) AddField(field Field)

type SessionDataSet

type SessionDataSet struct {
	Sql             string
	ColumnNameList  []string
	ColumnTypeList  []string
	ColumnNameIndex map[string]int32
	QueryId         int64
	SessionId       int64
	IgnoreTimeStamp bool
	Client          *rpc.TSIServiceClient
	QueryDataSet    *rpc.TSQueryDataSet
	// contains filtered or unexported fields
}

func NewSessionDataSet

func NewSessionDataSet(dataSet *SessionDataSet) *SessionDataSet

func (*SessionDataSet) CloseOperationHandle

func (s *SessionDataSet) CloseOperationHandle()

func (*SessionDataSet) GetColumnNames

func (s *SessionDataSet) GetColumnNames() []string

func (*SessionDataSet) GetColumnTypes

func (s *SessionDataSet) GetColumnTypes() []string

func (*SessionDataSet) HasNext

func (s *SessionDataSet) HasNext() bool

func (*SessionDataSet) Next

func (s *SessionDataSet) Next() *RowRecord

type Tablet

type Tablet struct {
	DeviceId     string
	Measurements []string
	Values       []interface{}
	Timestamps   []int64
	Types        []int32
}

func (*Tablet) GetBinaryTimestamps

func (t *Tablet) GetBinaryTimestamps() []byte

func (*Tablet) GetBinaryValues

func (t *Tablet) GetBinaryValues() []byte

func (*Tablet) GetDeviceId

func (t *Tablet) GetDeviceId() string

func (*Tablet) GetMeasurements

func (t *Tablet) GetMeasurements() []string

func (*Tablet) GetRowNumber

func (t *Tablet) GetRowNumber() int32

func (*Tablet) GetTypes

func (t *Tablet) GetTypes() []int32

func (*Tablet) SortTablet

func (t *Tablet) SortTablet()