xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[TD-90] developing

This commit is contained in:
Tao Liu 2020-05-23 09:40:46 +00:00
parent 0f43e08f59
commit df01a390d4
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/common/inc/tdataformat.h
View File

@ -221,20 +221,28 @@ void tdMergeTwoDataCols(SDataCols *target, SDataCols *src1, int *iter1, SD
typedef struct { typedef struct {
int16_t colId; // column ID int16_t colId; // column ID
int16_t colLen; // if col type is binary/Nchar, this is the length of binary/Nchar int8_t colType;
int64_t valueOrOffset; //to store value for numeric col or offset for binary/Nchar int8_t colLen; // if col type is binary/Nchar, this is the length of binary/Nchar
int16_t offset; //to store value for numeric col or offset for binary/Nchar
} STagCol; } STagCol;
typedef struct { typedef struct {
int32_t len; int32_t len;
void * pBinaryData; // Space to store the binary and Nchar value void * pData; // Space to store the tag value
int16_t ncols; // Total columns allocated int16_t ncols; // Total columns allocated
STagCol tagCols[]; STagCol tagCols[];
} STagRow; } STagRow;
int tdInsertTagCol(SDataRow *row, void *value, int32_t bytes, int16_t colId);
int tdQuerTagByID(SDataRow row, void *value, int16_t colId); #define tagColSize(r) (sizeof(STagCol) + r.colLen)
int tdInsertTagCol(SDataRow row, void *value, int16_t len, int8_t type, int16_t colId); //insert tag value and update all the information
int tdDeleteTagCol(SDataRow row, int16_t colId); // delete tag value and update all the information
int tdQuerTagByID(SDataRow row, int16_t colId, void *value); //if find tag, return value length, else return -1;
int tdAppendTagColVal(SDataRow row, void *value, int8_t type, int32_t bytes);
SDataRow tdNewTagRowFromSchema(STSchema *pSchema); SDataRow tdNewTagRowFromSchema(STSchema *pSchema);
STSchema *tdGetSchemaFromData(SDataRow *row);
#ifdef __cplusplus #ifdef __cplusplus
} }