File tree Expand file tree Collapse file tree 4 files changed +6
-14
lines changed Expand file tree Collapse file tree 4 files changed +6
-14
lines changed Original file line number Diff line number Diff line change @@ -31,11 +31,15 @@ struct TChangeRecordBuilderContextTrait<NBackup::NImpl::TChangeRecord> {
31
31
32
32
namespace NKikimr ::NBackup::NImpl {
33
33
34
+ class TChangeRecordBuilder ;
35
+
34
36
class TChangeRecord : public NChangeExchange ::TChangeRecordBase {
35
37
friend class TChangeRecordBuilder ;
36
38
37
39
public:
38
40
using TPtr = TIntrusivePtr<TChangeRecord>;
41
+ using TBuilder = TChangeRecordBuilder;
42
+
39
43
const static NKikimrSchemeOp::ECdcStreamFormat StreamType = NKikimrSchemeOp::ECdcStreamFormatProto;
40
44
41
45
ui64 GetGroup () const override {
@@ -197,9 +201,4 @@ struct TChangeRecordContainer<NBackup::NImpl::TChangeRecord>
197
201
using TBaseChangeRecordContainer<NBackup::NImpl::TChangeRecord>::TBaseChangeRecordContainer;
198
202
};
199
203
200
- template <>
201
- struct TChangeRecordBuilderTrait <NBackup::NImpl::TChangeRecord>
202
- : public NBackup::NImpl::TChangeRecordBuilder
203
- {};
204
-
205
204
}
Original file line number Diff line number Diff line change 6
6
7
7
namespace NKikimr {
8
8
9
- template <typename TChangeRecord>
10
- struct TChangeRecordBuilderTrait ;
11
-
12
9
template <typename TChangeRecord>
13
10
struct TChangeRecordBuilderContextTrait {};
14
11
Original file line number Diff line number Diff line change @@ -31,6 +31,7 @@ class TChangeRecord: public NChangeExchange::TChangeRecordBase {
31
31
32
32
public:
33
33
using TPtr = TIntrusivePtr<TChangeRecord>;
34
+ using TBuilder = TChangeRecordBuilder;
34
35
35
36
const static NKikimrSchemeOp::ECdcStreamFormat StreamType = NKikimrSchemeOp::ECdcStreamFormatJson;
36
37
@@ -88,11 +89,6 @@ struct TChangeRecordContainer<NReplication::NService::TChangeRecord>
88
89
using TBaseChangeRecordContainer<NReplication::NService::TChangeRecord>::TBaseChangeRecordContainer;
89
90
};
90
91
91
- template <>
92
- struct TChangeRecordBuilderTrait <NReplication::NService::TChangeRecord>
93
- : public NReplication::NService::TChangeRecordBuilder
94
- {};
95
-
96
92
template <>
97
93
struct TChangeRecordBuilderContextTrait <NReplication::NService::TChangeRecord> {
98
94
TMemoryPool MemoryPool;
Original file line number Diff line number Diff line change @@ -450,7 +450,7 @@ class TLocalTableWriter
450
450
451
451
for (auto & record : ev->Get ()->Records ) {
452
452
records.emplace_back (record.Offset , TablePathId, record.Data .size ());
453
- auto res = PendingRecords.emplace (record.Offset , TChangeRecordBuilderTrait< TChangeRecord> ()
453
+ auto res = PendingRecords.emplace (record.Offset , typename TChangeRecord::TBuilder ()
454
454
.WithSourceId (ev->Get ()->Source )
455
455
.WithOrder (record.Offset )
456
456
.WithBody (std::move (record.Data ))
You can’t perform that action at this time.
0 commit comments