Use aggregate for Sequoia replicas

2 files changed, 20 insertions, 12 deletions

diff --git a/yt/yt/client/table_client/record_helpers-inl.h b/yt/yt/client/table_client/record_helpers-inl.h
index ce35d20e35..2becf3286f 100644
--- a/yt/yt/client/table_client/record_helpers-inl.h
+++ b/yt/yt/client/table_client/record_helpers-inl.h
@@ -85,31 +85,34 @@ template <class TRecord>
 TUnversionedRow FromRecord(
     const TRecord& record,
     const TRowBufferPtr& rowBuffer,
-    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping)
+    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping,
+    NTableClient::EValueFlags flags)
 {
-    return record.ToUnversionedRow(rowBuffer, idMapping);
+    return record.ToUnversionedRow(rowBuffer, idMapping, flags);
 }
 
 template <class TRecord>
 TUnversionedOwningRow FromRecord(
     const TRecord& record,
-    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping)
+    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping,
+    NTableClient::EValueFlags flags)
 {
     // TODO(babenko): optimize
     auto rowBuffer = New<TRowBuffer>(TDefaultRowBufferPoolTag(), 256);
-    return TUnversionedOwningRow(FromRecord(record, rowBuffer, idMapping));
+    return TUnversionedOwningRow(FromRecord(record, rowBuffer, idMapping, flags));
 }
 
 template <class TRecord>
 TSharedRange<TUnversionedRow> FromRecords(
     TRange<TRecord> records,
     const TRowBufferPtr& rowBuffer,
-    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping)
+    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping,
+    NTableClient::EValueFlags flags)
 {
     std::vector<TUnversionedRow> rows;
     rows.reserve(records.size());
     for (const auto& record : records) {
-        rows.push_back(FromRecord(record, rowBuffer, idMapping));
+        rows.push_back(FromRecord(record, rowBuffer, idMapping, flags));
     }
     return MakeSharedRange(std::move(rows), rowBuffer);
 }
@@ -117,9 +120,10 @@ TSharedRange<TUnversionedRow> FromRecords(
 template <class TRecord>
 TSharedRange<TUnversionedRow> FromRecords(
     TRange<TRecord> records,
-    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping)
+    const typename TRecord::TRecordDescriptor::TIdMapping& idMapping,
+    NTableClient::EValueFlags flags)
 {
-    return FromRecords(records, New<TRowBuffer>(), idMapping);
+    return FromRecords(records, New<TRowBuffer>(), idMapping, flags);
 }
 
 ////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/yt/client/table_client/record_helpers.h b/yt/yt/client/table_client/record_helpers.h
index 1ef7982a33..0ca17ba158 100644
--- a/yt/yt/client/table_client/record_helpers.h
+++ b/yt/yt/client/table_client/record_helpers.h
@@ -41,26 +41,30 @@ TUnversionedRow FromRecord(
     const TRecord& record,
     const TRowBufferPtr& rowBuffer,
     const typename TRecord::TRecordDescriptor::TIdMapping& idMapping =
-        TRecord::TRecordDescriptor::Get()->GetIdMapping());
+        TRecord::TRecordDescriptor::Get()->GetIdMapping(),
+    NTableClient::EValueFlags flags = NTableClient::EValueFlags::None);
 
 template <class TRecord>
 TUnversionedOwningRow FromRecord(
     const TRecord& record,
     const typename TRecord::TRecordDescriptor::TIdMapping& idMapping =
-        TRecord::TRecordDescriptor::Get()->GetIdMapping());
+        TRecord::TRecordDescriptor::Get()->GetIdMapping(),
+    NTableClient::EValueFlags flags = NTableClient::EValueFlags::None);
 
 template <class TRecord>
 TSharedRange<TUnversionedRow> FromRecords(
     TRange<TRecord> records,
     const TRowBufferPtr& rowBuffer,
     const typename TRecord::TRecordDescriptor::TIdMapping& idMapping =
-        TRecord::TRecordDescriptor::Get()->GetIdMapping());
+        TRecord::TRecordDescriptor::Get()->GetIdMapping(),
+    NTableClient::EValueFlags flags = NTableClient::EValueFlags::None);
 
 template <class TRecord>
 TSharedRange<TUnversionedRow> FromRecords(
     TRange<TRecord> records,
     const typename TRecord::TRecordDescriptor::TIdMapping& idMapping =
-        TRecord::TRecordDescriptor::Get()->GetIdMapping());
+        TRecord::TRecordDescriptor::Get()->GetIdMapping(),
+    NTableClient::EValueFlags flags = NTableClient::EValueFlags::None);
 
 ////////////////////////////////////////////////////////////////////////////////