Searched refs:batchData (Results 1 – 5 of 5) sorted by relevance
996 CloudSyncBatch &batchData = isInsert ? uploadData.insData : uploadData.updData; in UploadVersionRecordIfNeed() local997 if (batchData.record.empty()) { in UploadVersionRecordIfNeed()1002 …CloudStorageUtils::GetStringFromCloudData(CloudDbConstant::CLOUD_KV_FIELD_VALUE, batchData.record[… in UploadVersionRecordIfNeed()1009 batchData.record[0][CloudDbConstant::CLOUD_KV_FIELD_VALUE] = newVersion; in UploadVersionRecordIfNeed()1012 std::vector<VBucket> copyRecord = batchData.record; in UploadVersionRecordIfNeed()1014 CloudSyncUtils::GetWaterMarkAndUpdateTime(batchData.extend, waterMark); in UploadVersionRecordIfNeed()1016 batchData.record = copyRecord; in UploadVersionRecordIfNeed()1017 CloudSyncUtils::ModifyCloudDataTime(batchData.extend[0]); in UploadVersionRecordIfNeed()
1367 const CloudSyncBatch &batchData) in FillCloudVersionForUpload() argument1369 if (batchData.extend.empty()) { in FillCloudVersionForUpload()1372 if (batchData.hashKey.empty() || batchData.extend.size() != batchData.hashKey.size()) { in FillCloudVersionForUpload()1384 for (size_t i = 0; i < batchData.extend.size(); ++i) { in FillCloudVersionForUpload()1385 errCode = BindUpdateVersionStatement(batchData.extend[i], batchData.hashKey[i], stmt); in FillCloudVersionForUpload()
469 int FillCloudVersionForUpload(const std::string &tableName, const CloudSyncBatch &batchData);
1405 void CheckCloudBatchData(CloudSyncBatch &batchData, bool existRef) in CheckCloudBatchData() argument1407 for (size_t i = 0u; i < batchData.rowid.size(); ++i) { in CheckCloudBatchData()1408 int64_t rowid = batchData.rowid[i]; in CheckCloudBatchData()1409 auto &extend = batchData.extend[i]; in CheckCloudBatchData()
205 …void CombineBatchWorldMinAndMax(const BatchDataVector& batchData, const BatchIndices& batchIndices,