File tree Expand file tree Collapse file tree 1 file changed +9
-4
lines changed
internal/clients/state/v3 Expand file tree Collapse file tree 1 file changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -163,12 +163,17 @@ func (c *Client) Flush(ctx context.Context) error {
163
163
c .mutex .Lock ()
164
164
defer c .mutex .Unlock ()
165
165
bldr := array .NewRecordBuilder (memory .DefaultAllocator , c .schema )
166
+ keys , values := bldr .Field (0 ).(* array.StringBuilder ), bldr .Field (1 ).(* array.StringBuilder )
167
+ var version * array.Uint64Builder
168
+ if c .versionedMode {
169
+ version = bldr .Field (2 ).(* array.Uint64Builder )
170
+ }
166
171
for k := range c .changes {
167
172
val := c .mem [k ]
168
- bldr . Field ( 0 ).( * array. StringBuilder ) .Append (k )
169
- bldr . Field ( 1 ).( * array. StringBuilder ) .Append (val .value )
170
- if c . versionedMode {
171
- bldr . Field ( 2 ).( * array. Uint64Builder ) .Append (val .version )
173
+ keys .Append (k )
174
+ values .Append (val .value )
175
+ if version != nil {
176
+ version .Append (val .version )
172
177
}
173
178
}
174
179
rec := bldr .NewRecord ()
You can’t perform that action at this time.
0 commit comments