Versions in this module Expand all Collapse all v2 v2.0.8 Mar 12, 2026 Changes in this version + const ATTRIBUTE + const ActiveTriggerInstanceError + const AddConfignodeError + const AliasAlreadyExist + const AlignedTimeseriesError + const AlreadyHasPrivilege + const AuthIoException + const BINARY_ARRAY_COLUMN_ENCODING + const BYTE_ARRAY_COLUMN_ENCODING + const CanNotConnectDatanode + const ClearPermissionCacheError + const CloseOperationError + const CompactionError + const ConfigurationError + const ConsensusNotInitialized + const CqAlreadyActive + const CqAlreadyExist + const CqUpdateLastExecTimeError + const CreatePipeSinkError + const CreateRegionError + const CreateTemplateError + const CreateTriggerError + const CreateTriggerInstanceError + const CreateUdfOnDatanodeError + const DEFAULT_TIME_FORMAT + const DEFAULT_VERSION + const DatabaseAlreadyExists + const DatabaseNotExist + const DatanodeAlreadyRegistered + const DatanodeNotExist + const DatanodeStopError + const DataregionProcessError + const DefaultConnectRetryMax + const DefaultFetchSize + const DefaultTimeZone + const DeleteRegionError + const DeserializePieceOfTsfileError + const DifferentTemplate + const DiskSpaceInsufficient + const DropTriggerError + const DropTriggerInstanceError + const DropUdfOnDatanodeError + const DuplicatedTemplate + const ExecuteStatementError + const FIELD + const GenerateTimeZoneError + const INT32_ARRAY_COLUMN_ENCODING + const INT64_ARRAY_COLUMN_ENCODING + const IllegalParameter + const IllegalPath + const IncompatibleVersion + const InitAuthError + const InternalRequestRetryError + const InternalRequestTimeOut + const InternalServerError + const LoadFileError + const LoadPieceOfTsfileError + const LogicalOperatorError + const LogicalOptimizeError + const MICROSECOND + const MILLISECOND + const MetadataError + const MigrateRegionError + const MppMemoryNotEnough + const MultipleError + const NANOSECOND + const NoAvailableRegionGroup + const NoEnoughDatanode + const NoPermission + const NoSuchCq + const NotHasPrivilege + const NotLogin + const OutOfTtl + const OverlapWithExistingTask + const OversizeRecord + const PageOutOfSpace + const PartitionCacheUpdateError + const PathAlreadyExist + const PathNotExist + const PipeError + const PipeserverError + const QueryNotAllowed + const QueryProcessError + const RLE_COLUMN_ENCODING + const RecordDuplicated + const RedirectionRecommend + const RegionLeaderChangeError + const RegisterRemovedDatanode + const RemoveConfignodeError + const RemoveDatanodeError + const RoleAlreadyExist + const RoleNotExist + const SchemaFileNotExists + const SchemaFileRedoLogBroken + const SegmentNotFound + const SegmentOutOfSpace + const SemanticError + const SeriesOverflow + const SetTimeZoneError + const ShutDownError + const SqlParseError + const StartUpError + const StorageEngineError + const StorageEngineNotReady + const SuccessStatus + const SyncConnectionError + const SyncFileError + const SyncFileRedirectionError + const SystemReadOnly + const TAG + const TIME_PRECISION + const TableSqlDialect + const TemplateIncompatible + const TemplateIsInUse + const TemplateNotActivated + const TemplateNotSet + const TimeseriesAlreadyExist + const TimeseriesInBlackList + const TimestampColumnName + const TreeSqlDialect + const TriggerDownloadError + const TriggerFireError + const TriggerLoadClassError + const TsblockSerializeError + const TsfileProcessorError + const UdfDownloadError + const UdfLoadClassError + const UndefinedTemplate + const UnknownAuthPrivilege + const UnsupportedAuthOperation + const UnsupportedFillType + const UnsupportedOperation + const UpdateTriggerLocationError + const UserAlreadyExist + const UserAlreadyHasRole + const UserNotExist + const UserNotHasRole + const V_0_12 + const V_0_13 + const V_1_0 + const VerifyMetadataError + const WalError + const WriteProcessError + const WriteProcessReject + const WrongLoginPassword + var BitUtil = []byte + var ErrTableSessionClosed = errors.New("table session has been closed") + var UnmarkBitUtil = []byte + func DateToInt32(localDate time.Time) (int32, error) + func Int32ToDate(val int32) (time.Time, error) + func VerifySuccess(status *common.TSStatus) error + type BatchError struct + Message string + func (e *BatchError) Error() string + func (e *BatchError) GetStatuses() []*common.TSStatus + type Binary struct + func NewBinary(v []byte) *Binary + func (b *Binary) GetStringValue() string + func (b *Binary) GetValues() []byte + type BinaryArrayColumnDecoder struct + func (decoder *BinaryArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) + type BinaryColumn struct + func NewBinaryColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []*Binary) (*BinaryColumn, error) + func (c *BinaryColumn) GetBinaries() ([]*Binary, error) + func (c *BinaryColumn) GetBinary(position int32) (*Binary, error) + func (c *BinaryColumn) GetBoolean(_ int32) (bool, error) + func (c *BinaryColumn) GetBooleans() ([]bool, error) + func (c *BinaryColumn) GetDataType() TSDataType + func (c *BinaryColumn) GetDouble(_ int32) (float64, error) + func (c *BinaryColumn) GetDoubles() ([]float64, error) + func (c *BinaryColumn) GetEncoding() ColumnEncoding + func (c *BinaryColumn) GetFloat(_ int32) (float32, error) + func (c *BinaryColumn) GetFloats() ([]float32, error) + func (c *BinaryColumn) GetInt(_ int32) (int32, error) + func (c *BinaryColumn) GetInts() ([]int32, error) + func (c *BinaryColumn) GetLong(_ int32) (int64, error) + func (c *BinaryColumn) GetLongs() ([]int64, error) + func (c *BinaryColumn) GetObject(position int32) (interface{}, error) + func (c *BinaryColumn) GetObjects() ([]interface{}, error) + func (c *BinaryColumn) GetPositionCount() int32 + func (c *BinaryColumn) IsNull(position int32) bool + func (c *BinaryColumn) IsNulls() []bool + func (c *BinaryColumn) MayHaveNull() bool + type BitMap struct + func NewBitMap(size int) *BitMap + func (b *BitMap) GetBits() []byte + func (b *BitMap) IsAllUnmarked() bool + func (b *BitMap) IsMarked(position int) bool + func (b *BitMap) Mark(position int) + func (b *BitMap) UnMark(position int) + type BooleanColumn struct + func NewBooleanColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []bool) (*BooleanColumn, error) + func (c *BooleanColumn) GetBinaries() ([]*Binary, error) + func (c *BooleanColumn) GetBinary(_ int32) (*Binary, error) + func (c *BooleanColumn) GetBoolean(position int32) (bool, error) + func (c *BooleanColumn) GetBooleans() ([]bool, error) + func (c *BooleanColumn) GetDataType() TSDataType + func (c *BooleanColumn) GetDouble(_ int32) (float64, error) + func (c *BooleanColumn) GetDoubles() ([]float64, error) + func (c *BooleanColumn) GetEncoding() ColumnEncoding + func (c *BooleanColumn) GetFloat(_ int32) (float32, error) + func (c *BooleanColumn) GetFloats() ([]float32, error) + func (c *BooleanColumn) GetInt(_ int32) (int32, error) + func (c *BooleanColumn) GetInts() ([]int32, error) + func (c *BooleanColumn) GetLong(_ int32) (int64, error) + func (c *BooleanColumn) GetLongs() ([]int64, error) + func (c *BooleanColumn) GetObject(position int32) (interface{}, error) + func (c *BooleanColumn) GetObjects() ([]interface{}, error) + func (c *BooleanColumn) GetPositionCount() int32 + func (c *BooleanColumn) IsNull(position int32) bool + func (c *BooleanColumn) IsNulls() []bool + func (c *BooleanColumn) MayHaveNull() bool + type ByteArrayColumnDecoder struct + func (decoder *ByteArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) + type ClusterConfig struct + ConnectRetryMax int + Database string + FetchSize int32 + NodeUrls []string + Password string + TimeZone string + UserName string + type Column interface + GetBinaries func() ([]*Binary, error) + GetBinary func(position int32) (*Binary, error) + GetBoolean func(position int32) (bool, error) + GetBooleans func() ([]bool, error) + GetDataType func() TSDataType + GetDouble func(position int32) (float64, error) + GetDoubles func() ([]float64, error) + GetEncoding func() ColumnEncoding + GetFloat func(position int32) (float32, error) + GetFloats func() ([]float32, error) + GetInt func(position int32) (int32, error) + GetInts func() ([]int32, error) + GetLong func(position int32) (int64, error) + GetLongs func() ([]int64, error) + GetObject func(position int32) (interface{}, error) + GetObjects func() ([]interface{}, error) + GetPositionCount func() int32 + IsNull func(position int32) bool + IsNulls func() []bool + MayHaveNull func() bool + type ColumnCategory int8 + type ColumnDecoder interface + ReadColumn func(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) + type ColumnEncoding uint8 + type Config struct + ConnectRetryMax int + Database string + FetchSize int32 + Host string + Password string + Port string + TimeZone string + UserName string + Version Version + type DoubleColumn struct + func NewDoubleColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []float64) (*DoubleColumn, error) + func (c *DoubleColumn) GetBinaries() ([]*Binary, error) + func (c *DoubleColumn) GetBinary(_ int32) (*Binary, error) + func (c *DoubleColumn) GetBoolean(_ int32) (bool, error) + func (c *DoubleColumn) GetBooleans() ([]bool, error) + func (c *DoubleColumn) GetDataType() TSDataType + func (c *DoubleColumn) GetDouble(position int32) (float64, error) + func (c *DoubleColumn) GetDoubles() ([]float64, error) + func (c *DoubleColumn) GetEncoding() ColumnEncoding + func (c *DoubleColumn) GetFloat(_ int32) (float32, error) + func (c *DoubleColumn) GetFloats() ([]float32, error) + func (c *DoubleColumn) GetInt(_ int32) (int32, error) + func (c *DoubleColumn) GetInts() ([]int32, error) + func (c *DoubleColumn) GetLong(_ int32) (int64, error) + func (c *DoubleColumn) GetLongs() ([]int64, error) + func (c *DoubleColumn) GetObject(position int32) (interface{}, error) + func (c *DoubleColumn) GetObjects() ([]interface{}, error) + func (c *DoubleColumn) GetPositionCount() int32 + func (c *DoubleColumn) IsNull(position int32) bool + func (c *DoubleColumn) IsNulls() []bool + func (c *DoubleColumn) MayHaveNull() bool + type ExecutionError struct + Code int32 + Message string + func (e *ExecutionError) Error() string + type Field struct + func (f *Field) GetDataType() TSDataType + func (f *Field) GetFloat32() float32 + func (f *Field) GetFloat64() float64 + func (f *Field) GetInt32() int32 + func (f *Field) GetInt64() int64 + func (f *Field) GetName() string + func (f *Field) GetText() string + func (f *Field) GetValue() interface{} + func (f *Field) IsNull() bool + type FloatColumn struct + func NewFloatColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []float32) (*FloatColumn, error) + func (c *FloatColumn) GetBinaries() ([]*Binary, error) + func (c *FloatColumn) GetBinary(_ int32) (*Binary, error) + func (c *FloatColumn) GetBoolean(_ int32) (bool, error) + func (c *FloatColumn) GetBooleans() ([]bool, error) + func (c *FloatColumn) GetDataType() TSDataType + func (c *FloatColumn) GetDouble(_ int32) (float64, error) + func (c *FloatColumn) GetDoubles() ([]float64, error) + func (c *FloatColumn) GetEncoding() ColumnEncoding + func (c *FloatColumn) GetFloat(position int32) (float32, error) + func (c *FloatColumn) GetFloats() ([]float32, error) + func (c *FloatColumn) GetInt(_ int32) (int32, error) + func (c *FloatColumn) GetInts() ([]int32, error) + func (c *FloatColumn) GetLong(_ int32) (int64, error) + func (c *FloatColumn) GetLongs() ([]int64, error) + func (c *FloatColumn) GetObject(position int32) (interface{}, error) + func (c *FloatColumn) GetObjects() ([]interface{}, error) + func (c *FloatColumn) GetPositionCount() int32 + func (c *FloatColumn) IsNull(position int32) bool + func (c *FloatColumn) IsNulls() []bool + func (c *FloatColumn) MayHaveNull() bool + type ITableSession interface + Close func() (err error) + ExecuteNonQueryStatement func(sql string) error + ExecuteQueryStatement func(sql string, timeoutInMs *int64) (*SessionDataSet, error) + Insert func(tablet *Tablet) error + func NewClusterTableSession(clusterConfig *ClusterConfig, enableRPCCompression bool) (ITableSession, error) + func NewTableSession(config *Config, enableRPCCompression bool, connectionTimeoutInMs int) (ITableSession, error) + type Int32ArrayColumnDecoder struct + func (decoder *Int32ArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) + type Int64ArrayColumnDecoder struct + func (decoder *Int64ArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) + type IntColumn struct + func NewIntColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []int32) (*IntColumn, error) + func (c *IntColumn) GetBinaries() ([]*Binary, error) + func (c *IntColumn) GetBinary(_ int32) (*Binary, error) + func (c *IntColumn) GetBoolean(_ int32) (bool, error) + func (c *IntColumn) GetBooleans() ([]bool, error) + func (c *IntColumn) GetDataType() TSDataType + func (c *IntColumn) GetDouble(_ int32) (float64, error) + func (c *IntColumn) GetDoubles() ([]float64, error) + func (c *IntColumn) GetEncoding() ColumnEncoding + func (c *IntColumn) GetFloat(_ int32) (float32, error) + func (c *IntColumn) GetFloats() ([]float32, error) + func (c *IntColumn) GetInt(position int32) (int32, error) + func (c *IntColumn) GetInts() ([]int32, error) + func (c *IntColumn) GetLong(_ int32) (int64, error) + func (c *IntColumn) GetLongs() ([]int64, error) + func (c *IntColumn) GetObject(position int32) (interface{}, error) + func (c *IntColumn) GetObjects() ([]interface{}, error) + func (c *IntColumn) GetPositionCount() int32 + func (c *IntColumn) IsNull(position int32) bool + func (c *IntColumn) IsNulls() []bool + func (c *IntColumn) MayHaveNull() bool + type IoTDBRpcDataSet struct + func NewIoTDBRpcDataSet(sql string, columnNameList []string, columnTypeList []string, ...) (rpcDataSet *IoTDBRpcDataSet, err error) + func (s *IoTDBRpcDataSet) Close() (err error) + func (s *IoTDBRpcDataSet) GetColumnNameTypeList() []string + func (s *IoTDBRpcDataSet) GetColumnSize() int32 + func (s *IoTDBRpcDataSet) GetColumnTypeList() []string + func (s *IoTDBRpcDataSet) GetCurrentRowTime() int64 + func (s *IoTDBRpcDataSet) GetDate(columnName string) (time.Time, error) + func (s *IoTDBRpcDataSet) GetDateByIndex(columnIndex int32) (time.Time, error) + func (s *IoTDBRpcDataSet) GetDateByTsBlockColumnIndex(tsBlockColumnIndex int32) (time.Time, error) + func (s *IoTDBRpcDataSet) GetFetchSize() int32 + func (s *IoTDBRpcDataSet) GetValueColumnStartIndex() int32 + func (s *IoTDBRpcDataSet) HasCachedRecord() bool + func (s *IoTDBRpcDataSet) IsClosed() bool + func (s *IoTDBRpcDataSet) IsIgnoreTimestamp() bool + func (s *IoTDBRpcDataSet) IsLastReadWasNull() bool + func (s *IoTDBRpcDataSet) Next() (result bool, err error) + func (s *IoTDBRpcDataSet) SetFetchSize(fetchSize int32) + func (s *IoTDBRpcDataSet) SetHasCachedRecord(hasCachedRecord bool) + type LongColumn struct + func NewLongColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []int64) (*LongColumn, error) + func (c *LongColumn) GetBinaries() ([]*Binary, error) + func (c *LongColumn) GetBinary(_ int32) (*Binary, error) + func (c *LongColumn) GetBoolean(_ int32) (bool, error) + func (c *LongColumn) GetBooleans() ([]bool, error) + func (c *LongColumn) GetDataType() TSDataType + func (c *LongColumn) GetDouble(_ int32) (float64, error) + func (c *LongColumn) GetDoubles() ([]float64, error) + func (c *LongColumn) GetEncoding() ColumnEncoding + func (c *LongColumn) GetFloat(_ int32) (float32, error) + func (c *LongColumn) GetFloats() ([]float32, error) + func (c *LongColumn) GetInt(_ int32) (int32, error) + func (c *LongColumn) GetInts() ([]int32, error) + func (c *LongColumn) GetLong(position int32) (int64, error) + func (c *LongColumn) GetLongs() ([]int64, error) + func (c *LongColumn) GetObject(position int32) (interface{}, error) + func (c *LongColumn) GetObjects() ([]interface{}, error) + func (c *LongColumn) GetPositionCount() int32 + func (c *LongColumn) IsNull(position int32) bool + func (c *LongColumn) IsNulls() []bool + func (c *LongColumn) MayHaveNull() bool + type MeasurementSchema struct + DataType TSDataType + Measurement string + type PoolConfig struct + ConnectRetryMax int + Database string + FetchSize int32 + Host string + NodeUrls []string + Password string + Port string + TimeZone string + UserName string + type PooledTableSession struct + func (s *PooledTableSession) Close() error + func (s *PooledTableSession) ExecuteNonQueryStatement(sql string) error + func (s *PooledTableSession) ExecuteQueryStatement(sql string, timeoutInMs *int64) (*SessionDataSet, error) + func (s *PooledTableSession) Insert(tablet *Tablet) error + type RowRecord struct + func (r *RowRecord) GetFields() []*Field + func (r *RowRecord) GetTimestamp() int64 + type RunLengthColumnDecoder struct + func (decoder *RunLengthColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) + type RunLengthEncodedColumn struct + func NewRunLengthEncodedColumn(value Column, positionCount int32) (*RunLengthEncodedColumn, error) + func (c *RunLengthEncodedColumn) GetBinaries() ([]*Binary, error) + func (c *RunLengthEncodedColumn) GetBinary(_ int32) (*Binary, error) + func (c *RunLengthEncodedColumn) GetBoolean(_ int32) (bool, error) + func (c *RunLengthEncodedColumn) GetBooleans() ([]bool, error) + func (c *RunLengthEncodedColumn) GetDataType() TSDataType + func (c *RunLengthEncodedColumn) GetDouble(_ int32) (float64, error) + func (c *RunLengthEncodedColumn) GetDoubles() ([]float64, error) + func (c *RunLengthEncodedColumn) GetEncoding() ColumnEncoding + func (c *RunLengthEncodedColumn) GetFloat(_ int32) (float32, error) + func (c *RunLengthEncodedColumn) GetFloats() ([]float32, error) + func (c *RunLengthEncodedColumn) GetInt(_ int32) (int32, error) + func (c *RunLengthEncodedColumn) GetInts() ([]int32, error) + func (c *RunLengthEncodedColumn) GetLong(_ int32) (int64, error) + func (c *RunLengthEncodedColumn) GetLongs() ([]int64, error) + func (c *RunLengthEncodedColumn) GetObject(_ int32) (interface{}, error) + func (c *RunLengthEncodedColumn) GetObjects() ([]interface{}, error) + func (c *RunLengthEncodedColumn) GetPositionCount() int32 + func (c *RunLengthEncodedColumn) GetValue() Column + func (c *RunLengthEncodedColumn) IsNull(_ int32) bool + func (c *RunLengthEncodedColumn) IsNulls() []bool + func (c *RunLengthEncodedColumn) MayHaveNull() bool + type Session struct + func NewClusterSession(clusterConfig *ClusterConfig) (Session, error) + func NewSession(config *Config) Session + func (s *Session) Close() error + func (s *Session) CreateAlignedTimeseries(prefixPath string, measurements []string, dataTypes []TSDataType, ...) error + func (s *Session) CreateMultiTimeseries(paths []string, dataTypes []TSDataType, encodings []TSEncoding, ...) error + func (s *Session) CreateTimeseries(path string, dataType TSDataType, encoding TSEncoding, ...) error + func (s *Session) DeleteData(paths []string, startTime int64, endTime int64) error + func (s *Session) DeleteStorageGroup(storageGroupId string) error + func (s *Session) DeleteStorageGroups(storageGroupIds ...string) error + func (s *Session) DeleteTimeseries(paths []string) error + func (s *Session) ExecuteAggregationQuery(paths []string, aggregations []common.TAggregationType, startTime *int64, ...) (*SessionDataSet, error) + func (s *Session) ExecuteAggregationQueryWithLegalNodes(paths []string, aggregations []common.TAggregationType, startTime *int64, ...) (*SessionDataSet, error) + func (s *Session) ExecuteBatchStatement(inserts []string) error + func (s *Session) ExecuteFastLastDataQueryForOnePrefixPath(prefixes []string, timeoutMs *int64) (*SessionDataSet, error) + func (s *Session) ExecuteNonQueryStatement(sql string) error + func (s *Session) ExecuteQueryStatement(sql string, timeoutMs *int64) (*SessionDataSet, error) + func (s *Session) ExecuteRawDataQuery(paths []string, startTime int64, endTime int64) (*SessionDataSet, error) + func (s *Session) ExecuteStatement(sql string) (*SessionDataSet, error) + func (s *Session) ExecuteStatementWithContext(ctx context.Context, sql string) (*SessionDataSet, error) + func (s *Session) ExecuteUpdateStatement(sql string) (*SessionDataSet, error) + func (s *Session) GetSessionId() int64 + func (s *Session) GetTimeZone() (string, error) + func (s *Session) InsertAlignedRecord(deviceId string, measurements []string, dataTypes []TSDataType, ...) error + func (s *Session) InsertAlignedRecords(deviceIds []string, measurements [][]string, dataTypes [][]TSDataType, ...) error + func (s *Session) InsertAlignedRecordsOfOneDevice(deviceId string, timestamps []int64, measurementsSlice [][]string, ...) error + func (s *Session) InsertAlignedTablet(tablet *Tablet, sorted bool) error + func (s *Session) InsertAlignedTablets(tablets []*Tablet, sorted bool) error + func (s *Session) InsertRecord(deviceId string, measurements []string, dataTypes []TSDataType, ...) error + func (s *Session) InsertRecords(deviceIds []string, measurements [][]string, dataTypes [][]TSDataType, ...) error + func (s *Session) InsertRecordsOfOneDevice(deviceId string, timestamps []int64, measurementsSlice [][]string, ...) error + func (s *Session) InsertStringRecord(deviceId string, measurements []string, values []string, timestamp int64) error + func (s *Session) InsertTablet(tablet *Tablet, sorted bool) error + func (s *Session) InsertTablets(tablets []*Tablet, sorted bool) error + func (s *Session) Open(enableRPCCompression bool, connectionTimeoutInMs int) error + func (s *Session) OpenCluster(enableRPCCompression bool) error + func (s *Session) SetFetchSize(fetchSize int32) + func (s *Session) SetStorageGroup(storageGroupId string) error + func (s *Session) SetTimeZone(timeZone string) error + type SessionDataSet struct + func NewSessionDataSet(sql string, columnNameList []string, columnTypeList []string, ...) (*SessionDataSet, error) + func (s *SessionDataSet) Close() error + func (s *SessionDataSet) FindColumn(columnName string) int32 + func (s *SessionDataSet) GetBlob(columnName string) (*Binary, error) + func (s *SessionDataSet) GetBlobByIndex(columnIndex int32) (*Binary, error) + func (s *SessionDataSet) GetBoolean(columnName string) (bool, error) + func (s *SessionDataSet) GetBooleanByIndex(columnIndex int32) (bool, error) + func (s *SessionDataSet) GetColumnNames() []string + func (s *SessionDataSet) GetColumnTypes() []string + func (s *SessionDataSet) GetCurrentRowTime() time.Time + func (s *SessionDataSet) GetDate(columnName string) (time.Time, error) + func (s *SessionDataSet) GetDateByIndex(columnIndex int32) (time.Time, error) + func (s *SessionDataSet) GetDouble(columnName string) (float64, error) + func (s *SessionDataSet) GetDoubleByIndex(columnIndex int32) (float64, error) + func (s *SessionDataSet) GetFloat(columnName string) (float32, error) + func (s *SessionDataSet) GetFloatByIndex(columnIndex int32) (float32, error) + func (s *SessionDataSet) GetInt(columnName string) (int32, error) + func (s *SessionDataSet) GetIntByIndex(columnIndex int32) (int32, error) + func (s *SessionDataSet) GetLong(columnName string) (int64, error) + func (s *SessionDataSet) GetLongByIndex(columnIndex int32) (int64, error) + func (s *SessionDataSet) GetObject(columnName string) (interface{}, error) + func (s *SessionDataSet) GetObjectByIndex(columnIndex int32) (interface{}, error) + func (s *SessionDataSet) GetString(columnName string) (string, error) + func (s *SessionDataSet) GetStringByIndex(columnIndex int32) (string, error) + func (s *SessionDataSet) GetTimestamp(columnName string) (time.Time, error) + func (s *SessionDataSet) GetTimestampByIndex(columnIndex int32) (time.Time, error) + func (s *SessionDataSet) IsNull(columnName string) (bool, error) + func (s *SessionDataSet) IsNullByIndex(columnIndex int32) (bool, error) + func (s *SessionDataSet) Next() (bool, error) + type SessionPool struct + func NewSessionPool(conf *PoolConfig, ...) SessionPool + func (spool *SessionPool) Close() + func (spool *SessionPool) ConstructSession(config *PoolConfig) (session Session, err error) + func (spool *SessionPool) GetSession() (session Session, err error) + func (spool *SessionPool) PutBack(session Session) + type TSCompressionType uint8 + const GZIP + const LZ4 + const LZMA2 + const SNAPPY + const UNCOMPRESSED + const ZSTD + type TSDataType int8 + const BLOB + const BOOLEAN + const DATE + const DOUBLE + const FLOAT + const INT32 + const INT64 + const STRING + const TEXT + const TIMESTAMP + const UNKNOWN + func GetDataTypeByStr(name string) (TSDataType, error) + type TSEncoding uint8 + const BITMAP + const CHIMP + const DICTIONARY + const DIFF + const FREQ + const GORILLA + const GORILLA_V1 + const PLAIN + const REGULAR + const RLBE + const RLE + const SPRINTZ + const TS_2DIFF + const ZIGZAG + type TableSession struct + func (s *TableSession) Close() error + func (s *TableSession) ExecuteNonQueryStatement(sql string) error + func (s *TableSession) ExecuteQueryStatement(sql string, timeoutInMs *int64) (*SessionDataSet, error) + func (s *TableSession) Insert(tablet *Tablet) error + type TableSessionPool struct + func NewTableSessionPool(conf *PoolConfig, ...) TableSessionPool + func (spool *TableSessionPool) Close() + func (spool *TableSessionPool) GetSession() (ITableSession, error) + type Tablet struct + RowSize int + func NewRelationalTablet(tableName string, measurementSchemas []*MeasurementSchema, ...) (*Tablet, error) + func NewTablet(insertTargetName string, measurementSchemas []*MeasurementSchema, ...) (*Tablet, error) + func (t *Tablet) GetMaxRowNumber() int + func (t *Tablet) GetMeasurements() []string + func (t *Tablet) GetTimestampBytes() []byte + func (t *Tablet) GetValueAt(columnIndex, rowIndex int) (interface{}, error) + func (t *Tablet) Len() int + func (t *Tablet) Less(i, j int) bool + func (t *Tablet) Reset() + func (t *Tablet) SetTimestamp(timestamp int64, rowIndex int) + func (t *Tablet) SetValueAt(value interface{}, columnIndex, rowIndex int) error + func (t *Tablet) Sort() error + func (t *Tablet) Swap(i, j int) + type TimeColumn struct + func NewTimeColumn(arrayOffset int32, positionCount int32, values []int64) (*TimeColumn, error) + func (c *TimeColumn) GetBinaries() ([]*Binary, error) + func (c *TimeColumn) GetBinary(_ int32) (*Binary, error) + func (c *TimeColumn) GetBoolean(_ int32) (bool, error) + func (c *TimeColumn) GetBooleans() ([]bool, error) + func (c *TimeColumn) GetDouble(_ int32) (float64, error) + func (c *TimeColumn) GetDoubles() ([]float64, error) + func (c *TimeColumn) GetFloat(_ int32) (float32, error) + func (c *TimeColumn) GetFloats() ([]float32, error) + func (c *TimeColumn) GetInt(_ int32) (int32, error) + func (c *TimeColumn) GetInts() ([]int32, error) + func (c *TimeColumn) GetObject(_ int32) (interface{}, error) + func (c *TimeColumn) GetObjects() ([]interface{}, error) + func (tc *TimeColumn) GetDataType() TSDataType + func (tc *TimeColumn) GetEncoding() ColumnEncoding + func (tc *TimeColumn) GetEndTime() int64 + func (tc *TimeColumn) GetLong(position int32) (int64, error) + func (tc *TimeColumn) GetLongs() ([]int64, error) + func (tc *TimeColumn) GetPositionCount() int32 + func (tc *TimeColumn) GetStartTime() int64 + func (tc *TimeColumn) GetTimes() []int64 + func (tc *TimeColumn) IsNull(_ int32) bool + func (tc *TimeColumn) IsNulls() []bool + func (tc *TimeColumn) MayHaveNull() bool + type TsBlock struct + func DeserializeTsBlock(data []byte) (*TsBlock, error) + func NewTsBlock(positionCount int32, timeColumn Column, valueColumns ...Column) (*TsBlock, error) + func (t *TsBlock) GetColumn(columnIndex int32) Column + func (t *TsBlock) GetEndTime() (int64, error) + func (t *TsBlock) GetPositionCount() int32 + func (t *TsBlock) GetStartTime() (int64, error) + func (t *TsBlock) GetTimeByIndex(index int32) (int64, error) + func (t *TsBlock) GetTimeColumn() Column + func (t *TsBlock) GetValueColumnCount() int32 + func (t *TsBlock) GetValueColumns() *[]Column + func (t *TsBlock) IsEmpty() bool + type Version string v2.0.3-1 Jun 20, 2025 Other modules containing this package github.com/apache/iotdb-client-go
Go to main page