| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/dmlpackageproc/ |
| H A D | tdriver.cpp | 50 using namespace WriteEngine;
103 rc = colOp.createColumn( curCol, 2, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1003 ); in build()
107 rc = colOp.createColumn( curCol, 3, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1004 ); in build()
111 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1005 ); in build()
115 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1006 ); in build()
143 rc = colOp.createColumn( curCol, 3, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1010 ); in build()
147 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1011 ); in build()
151 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1012 ); in build()
155 rc = colOp.createColumn( curCol, 6, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1013 ); in build()
159 rc = colOp.createColumn( curCol, 7, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1014 ); in build()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/dmlpackageproc/ |
| H A D | tdriver.cpp | 50 using namespace WriteEngine;
103 rc = colOp.createColumn( curCol, 2, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1003 ); in build()
107 rc = colOp.createColumn( curCol, 3, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1004 ); in build()
111 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1005 ); in build()
115 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1006 ); in build()
143 rc = colOp.createColumn( curCol, 3, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1010 ); in build()
147 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1011 ); in build()
151 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1012 ); in build()
155 rc = colOp.createColumn( curCol, 6, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1013 ); in build()
159 rc = colOp.createColumn( curCol, 7, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1014 ); in build()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackageproc/ |
| H A D | tdriver.cpp | 53 using namespace WriteEngine;
75 rc = colOp.createColumn( curCol, 0, 8, WriteEngine::VARCHAR, WriteEngine::WR_CHAR, 1001 ); in build()
89 rc = colOp.createColumn( curCol, 2, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1003 ); in build()
93 rc = colOp.createColumn( curCol, 3, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1004 ); in build()
97 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1005 ); in build()
101 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1006 ); in build()
128 rc = colOp.createColumn( curCol, 3, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1010 ); in build()
132 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1011 ); in build()
136 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1012 ); in build()
140 rc = colOp.createColumn( curCol, 6, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1013 ); in build()
[all …]
|
| H A D | ddlindexpopulator.h | 64 DDLIndexPopulator(WriteEngine::WriteEngineWrapper* writeEngine, in DDLIndexPopulator()
196 …t* cr, int idx, const execplan::CalpontSystemCatalog::ColType& cType, WriteEngine::IdxTuple& tupl…
211 boost::any tokenizeData( WriteEngine::RID rid );
234 …bool checkConstraints(const WriteEngine::IdxTuple& data, const execplan::CalpontSystemCatalog::Col…
240 …bool checkNotNull(const WriteEngine::IdxTuple& data, const execplan::CalpontSystemCatalog::ColType…
248 …bool checkCheck( const WriteEngine::IdxTuple& data, const execplan::CalpontSystemCatalog::ColType&… in checkCheck()
263 bool compareToken(const WriteEngine::Token& first, const WriteEngine::Token& second) const in compareToken()
268 WriteEngine::WriteEngineWrapper* fWriteEngine;
278 WriteEngine::RIDList fRidList;
279 WriteEngine::IdxStructList fIdxStructList;
[all …]
|
| H A D | ddlindexpopulator.cpp | 42 using namespace WriteEngine;
204 WriteEngine::IdxTupleList tupleList; in addColumnData()
205 WriteEngine::IdxTuple tuple; in addColumnData()
210 WriteEngine::IdxTuple tuple ; in addColumnData()
256 char fileName[WriteEngine::FILE_NAME_SIZE];
279 WriteEngine::Token token; in tokenizeData()
287 WriteEngine::DctnryTuple dictTuple; in tokenizeData()
295 WriteEngine::DctnryStruct dictStruct; in tokenizeData()
511 …isNull = compareToken(any_cast<WriteEngine::Token>(data.data), any_cast<WriteEngine::Token>(nullv… in checkNotNull()
543 …isNull = compareToken(any_cast<WriteEngine::Token>(data.data), any_cast<WriteEngine::Token>(nullv… in checkNotNull()
[all …]
|
| H A D | createindexprocessor.cpp | 171 WriteEngine::ColStruct colStruct; in processPackage()
172 WriteEngine::ColTuple colTuple; in processPackage()
173 WriteEngine::ColStructList colStructs; in processPackage()
174 WriteEngine::ColTupleList colTuples; in processPackage()
175 WriteEngine::ColValueList colValuesList; in processPackage()
176 WriteEngine::RIDList ridList; in processPackage()
268 if ( error != WriteEngine::NO_ERROR ) in processPackage()
290 WriteEngine::ColStruct colStructCol; in processPackage()
291 WriteEngine::ColTuple colTupleCol; in processPackage()
293 WriteEngine::ColTupleList colTuplesCol; in processPackage()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackageproc/ |
| H A D | tdriver.cpp | 53 using namespace WriteEngine;
75 rc = colOp.createColumn( curCol, 0, 8, WriteEngine::VARCHAR, WriteEngine::WR_CHAR, 1001 ); in build()
89 rc = colOp.createColumn( curCol, 2, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1003 ); in build()
93 rc = colOp.createColumn( curCol, 3, 8, WriteEngine::DATE, WriteEngine::WR_CHAR, 1004 ); in build()
97 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1005 ); in build()
101 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1006 ); in build()
128 rc = colOp.createColumn( curCol, 3, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1010 ); in build()
132 rc = colOp.createColumn( curCol, 4, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1011 ); in build()
136 rc = colOp.createColumn( curCol, 5, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1012 ); in build()
140 rc = colOp.createColumn( curCol, 6, 4, WriteEngine::INT, WriteEngine::WR_CHAR, 1013 ); in build()
[all …]
|
| H A D | ddlindexpopulator.h | 64 DDLIndexPopulator(WriteEngine::WriteEngineWrapper* writeEngine, in DDLIndexPopulator()
196 …t* cr, int idx, const execplan::CalpontSystemCatalog::ColType& cType, WriteEngine::IdxTuple& tupl…
211 boost::any tokenizeData( WriteEngine::RID rid );
234 …bool checkConstraints(const WriteEngine::IdxTuple& data, const execplan::CalpontSystemCatalog::Col…
240 …bool checkNotNull(const WriteEngine::IdxTuple& data, const execplan::CalpontSystemCatalog::ColType…
248 …bool checkCheck( const WriteEngine::IdxTuple& data, const execplan::CalpontSystemCatalog::ColType&… in checkCheck()
263 bool compareToken(const WriteEngine::Token& first, const WriteEngine::Token& second) const in compareToken()
268 WriteEngine::WriteEngineWrapper* fWriteEngine;
278 WriteEngine::RIDList fRidList;
279 WriteEngine::IdxStructList fIdxStructList;
[all …]
|
| H A D | ddlindexpopulator.cpp | 42 using namespace WriteEngine;
204 WriteEngine::IdxTupleList tupleList; in addColumnData()
205 WriteEngine::IdxTuple tuple; in addColumnData()
210 WriteEngine::IdxTuple tuple ; in addColumnData()
256 char fileName[WriteEngine::FILE_NAME_SIZE];
279 WriteEngine::Token token; in tokenizeData()
287 WriteEngine::DctnryTuple dictTuple; in tokenizeData()
295 WriteEngine::DctnryStruct dictStruct; in tokenizeData()
511 …isNull = compareToken(any_cast<WriteEngine::Token>(data.data), any_cast<WriteEngine::Token>(nullv… in checkNotNull()
543 …isNull = compareToken(any_cast<WriteEngine::Token>(data.data), any_cast<WriteEngine::Token>(nullv… in checkNotNull()
[all …]
|
| H A D | createindexprocessor.cpp | 171 WriteEngine::ColStruct colStruct; in processPackage()
172 WriteEngine::ColTuple colTuple; in processPackage()
173 WriteEngine::ColStructList colStructs; in processPackage()
174 WriteEngine::ColTupleList colTuples; in processPackage()
175 WriteEngine::ColValueList colValuesList; in processPackage()
176 WriteEngine::RIDList ridList; in processPackage()
268 if ( error != WriteEngine::NO_ERROR ) in processPackage()
290 WriteEngine::ColStruct colStructCol; in processPackage()
291 WriteEngine::ColTuple colTupleCol; in processPackage()
293 WriteEngine::ColTupleList colTuplesCol; in processPackage()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
| H A D | we_convertor.cpp | 97 namespace WriteEngine namespace
461 case WriteEngine::WR_BYTE : in convertWEColType()
466 case WriteEngine::WR_SHORT : in convertWEColType()
476 case WriteEngine::WR_INT : in convertWEColType()
481 case WriteEngine::WR_FLOAT: in convertWEColType()
496 case WriteEngine::WR_BLOB : in convertWEColType()
501 case WriteEngine::WR_TEXT : in convertWEColType()
511 case WriteEngine::WR_CHAR : in convertWEColType()
516 case WriteEngine::WR_UBYTE: in convertWEColType()
521 case WriteEngine::WR_USHORT: in convertWEColType()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
| H A D | we_convertor.cpp | 97 namespace WriteEngine namespace
461 case WriteEngine::WR_BYTE : in convertWEColType()
466 case WriteEngine::WR_SHORT : in convertWEColType()
476 case WriteEngine::WR_INT : in convertWEColType()
481 case WriteEngine::WR_FLOAT: in convertWEColType()
496 case WriteEngine::WR_BLOB : in convertWEColType()
501 case WriteEngine::WR_TEXT : in convertWEColType()
511 case WriteEngine::WR_CHAR : in convertWEColType()
516 case WriteEngine::WR_UBYTE: in convertWEColType()
521 case WriteEngine::WR_USHORT: in convertWEColType()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/wrapper/ |
| H A D | tdriver.cpp | 33 using namespace WriteEngine;
305 CreateColumnFile( 100, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInsertRowInt()
548 CreateColumnFile( 100, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInterfaceInsertUpdateDeleteRow()
549 CreateColumnFile( 200, 4, WriteEngine::FLOAT, WriteEngine::WR_FLOAT ); in testInterfaceInsertUpdateDeleteRow()
730 CreateColumnFile( 100, 4, WriteEngine::MEDINT, WriteEngine::WR_INT ); in testInterfaceInsertRowMedIntDouble()
1279 CreateColumnFile( 100, 1, WriteEngine::CHAR, WriteEngine::WR_CHAR ); in testInterfaceInsertRowSingleChar()
1362 CreateColumnFile( 100, 2, WriteEngine::CHAR, WriteEngine::WR_CHAR ); in testInterfaceInsertRowDoubleChar()
1552 CreateColumnFile( 200, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInterfaceInsertRowByte()
1677 CreateColumnFile( 100, 8, WriteEngine::CHAR, WriteEngine::WR_CHAR ); in testInterfaceInsertRowToken()
2290 CreateColumnFile( 400, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInterfaceInsertRowHwm()
[all …]
|
| H A D | writeengine.cpp | 65 namespace WriteEngine namespace
263 case WriteEngine::WR_INT : in convertValue()
280 case WriteEngine::WR_UINT : in convertValue()
290 case WriteEngine::WR_CHAR : in convertValue()
291 case WriteEngine::WR_BLOB : in convertValue()
292 case WriteEngine::WR_TEXT : in convertValue()
301 case WriteEngine::WR_FLOAT: in convertValue()
328 case WriteEngine::WR_SHORT: in convertValue()
344 case WriteEngine::WR_BYTE: in convertValue()
352 case WriteEngine::WR_UBYTE: in convertValue()
[all …]
|
| H A D | we_colop.cpp | 48 namespace WriteEngine namespace
1616 case WriteEngine::WR_BLOB : in writeRow()
1617 case WriteEngine::WR_TEXT : in writeRow()
1618 case WriteEngine::WR_CHAR : in writeRow()
1631 case WriteEngine::WR_BYTE : in writeRow()
1639 case WriteEngine::WR_TOKEN: in writeRow()
1643 case WriteEngine::WR_INT : in writeRow()
1656 case WriteEngine::WR_UINT : in writeRow()
1769 case WriteEngine::WR_BLOB : in writeRows()
1806 case WriteEngine::WR_INT : in writeRows()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/wrapper/ |
| H A D | tdriver.cpp | 33 using namespace WriteEngine;
305 CreateColumnFile( 100, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInsertRowInt()
548 CreateColumnFile( 100, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInterfaceInsertUpdateDeleteRow()
549 CreateColumnFile( 200, 4, WriteEngine::FLOAT, WriteEngine::WR_FLOAT ); in testInterfaceInsertUpdateDeleteRow()
730 CreateColumnFile( 100, 4, WriteEngine::MEDINT, WriteEngine::WR_INT ); in testInterfaceInsertRowMedIntDouble()
1279 CreateColumnFile( 100, 1, WriteEngine::CHAR, WriteEngine::WR_CHAR ); in testInterfaceInsertRowSingleChar()
1362 CreateColumnFile( 100, 2, WriteEngine::CHAR, WriteEngine::WR_CHAR ); in testInterfaceInsertRowDoubleChar()
1552 CreateColumnFile( 200, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInterfaceInsertRowByte()
1677 CreateColumnFile( 100, 8, WriteEngine::CHAR, WriteEngine::WR_CHAR ); in testInterfaceInsertRowToken()
2290 CreateColumnFile( 400, 4, WriteEngine::INT, WriteEngine::WR_INT ); in testInterfaceInsertRowHwm()
[all …]
|
| H A D | writeengine.cpp | 65 namespace WriteEngine namespace
263 case WriteEngine::WR_INT : in convertValue()
280 case WriteEngine::WR_UINT : in convertValue()
290 case WriteEngine::WR_CHAR : in convertValue()
291 case WriteEngine::WR_BLOB : in convertValue()
292 case WriteEngine::WR_TEXT : in convertValue()
301 case WriteEngine::WR_FLOAT: in convertValue()
328 case WriteEngine::WR_SHORT: in convertValue()
344 case WriteEngine::WR_BYTE: in convertValue()
352 case WriteEngine::WR_UBYTE: in convertValue()
[all …]
|
| H A D | we_colop.cpp | 48 namespace WriteEngine namespace
1616 case WriteEngine::WR_BLOB : in writeRow()
1617 case WriteEngine::WR_TEXT : in writeRow()
1618 case WriteEngine::WR_CHAR : in writeRow()
1631 case WriteEngine::WR_BYTE : in writeRow()
1639 case WriteEngine::WR_TOKEN: in writeRow()
1643 case WriteEngine::WR_INT : in writeRow()
1656 case WriteEngine::WR_UINT : in writeRow()
1769 case WriteEngine::WR_BLOB : in writeRows()
1806 case WriteEngine::WR_INT : in writeRows()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/ |
| H A D | we_ddlcommandproc.cpp | 48 namespace WriteEngine namespace
140 WriteEngine::ColTuple colTuple; in writeSystable()
141 WriteEngine::ColStruct colStruct; in writeSystable()
144 WriteEngine::dictStr dctColTuples; in writeSystable()
149 WriteEngine::RIDList ridList; in writeSystable()
392 WriteEngine::ColTuple colTuple; in writeCreateSyscolumn()
401 WriteEngine::RIDList ridList; in writeCreateSyscolumn()
809 WriteEngine::ColTuple colTuple; in writeSyscolumn()
814 WriteEngine::RIDList ridList; in writeSyscolumn()
1749 WriteEngine::RIDList ridList; in deleteSystables()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/ |
| H A D | we_ddlcommandproc.cpp | 48 namespace WriteEngine namespace
140 WriteEngine::ColTuple colTuple; in writeSystable()
141 WriteEngine::ColStruct colStruct; in writeSystable()
144 WriteEngine::dictStr dctColTuples; in writeSystable()
149 WriteEngine::RIDList ridList; in writeSystable()
392 WriteEngine::ColTuple colTuple; in writeCreateSyscolumn()
401 WriteEngine::RIDList ridList; in writeCreateSyscolumn()
809 WriteEngine::ColTuple colTuple; in writeSyscolumn()
814 WriteEngine::RIDList ridList; in writeSyscolumn()
1749 WriteEngine::RIDList ridList; in deleteSystables()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/index/ |
| H A D | we_freemgr.h | 33 namespace WriteEngine
94 …const int releaseSubblock( CommBlock& cb, WriteEngine::DataBlock*, int, WriteEngine::IdxEmptyListE…
100 …const int assignSubblock( CommBlock& cb, WriteEngine::DataBlock*, int, WriteEngine::IdxEmptyListEn…
105 const void nullPtr( WriteEngine::IdxEmptyListEntry* assignPtr ) const;
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/index/ |
| H A D | we_freemgr.h | 33 namespace WriteEngine
94 …const int releaseSubblock( CommBlock& cb, WriteEngine::DataBlock*, int, WriteEngine::IdxEmptyListE…
100 …const int assignSubblock( CommBlock& cb, WriteEngine::DataBlock*, int, WriteEngine::IdxEmptyListEn…
105 const void nullPtr( WriteEngine::IdxEmptyListEntry* assignPtr ) const;
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/mysql/ |
| H A D | is_columnstore_files.cpp | 62 bs << (messageqcpp::ByteStream::byte) WriteEngine::WE_SVR_GET_FILESIZE; in get_file_sizes()
93 char oidDirName[WriteEngine::FILE_NAME_SIZE]; in generate_result()
94 char fullFileName[WriteEngine::FILE_NAME_SIZE]; in generate_result()
95 char dbDir[WriteEngine::MAX_DB_DIR_LEVEL][WriteEngine::MAX_DB_DIR_NAME_SIZE]; in generate_result()
109 WriteEngine::Config we_config; in generate_result()
149 …WriteEngine::Convertor::oid2FileName(oid, oidDirName, dbDir, iter->partitionNum, iter->segmentNum); in generate_result()
154 … rc = snprintf(fullFileName, WriteEngine::FILE_NAME_SIZE, "%s/%s", DbRootPath.c_str(), oidDirName); in generate_result()
162 if (rc == WriteEngine::FILE_NAME_SIZE || in generate_result()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/mysql/ |
| H A D | is_columnstore_files.cpp | 62 bs << (messageqcpp::ByteStream::byte) WriteEngine::WE_SVR_GET_FILESIZE; in get_file_sizes()
93 char oidDirName[WriteEngine::FILE_NAME_SIZE]; in generate_result()
94 char fullFileName[WriteEngine::FILE_NAME_SIZE]; in generate_result()
95 char dbDir[WriteEngine::MAX_DB_DIR_LEVEL][WriteEngine::MAX_DB_DIR_NAME_SIZE]; in generate_result()
109 WriteEngine::Config we_config; in generate_result()
149 …WriteEngine::Convertor::oid2FileName(oid, oidDirName, dbDir, iter->partitionNum, iter->segmentNum); in generate_result()
154 … rc = snprintf(fullFileName, WriteEngine::FILE_NAME_SIZE, "%s/%s", DbRootPath.c_str(), oidDirName); in generate_result()
162 if (rc == WriteEngine::FILE_NAME_SIZE || in generate_result()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/redistribute/ |
| H A D | we_redistributeworkerthread.cpp | 525 char fileName[WriteEngine::FILE_NAME_SIZE]; in sendData()
528 if (rc == WriteEngine::NO_ERROR) in sendData()
761 if (rc != WriteEngine::NO_ERROR) in sendData()
774 char destName[WriteEngine::FILE_NAME_SIZE]; in sendData()
778 if (rc != WriteEngine::NO_ERROR) in sendData()
865 char tempFileName[WriteEngine::FILE_NAME_SIZE]; in buildFullHdfsPath()
866 char dbDir[WriteEngine::MAX_DB_DIR_LEVEL][WriteEngine::MAX_DB_DIR_NAME_SIZE]; in buildFullHdfsPath()
868 int rc = WriteEngine::Convertor::oid2FileName( in buildFullHdfsPath()
871 if (rc != WriteEngine::NO_ERROR) in buildFullHdfsPath()
1260 char fileName[WriteEngine::FILE_NAME_SIZE]; in handleDataStart()
[all …]
|