|
23 | 23 | import org.apache.iotdb.commons.path.PartialPath; |
24 | 24 | import org.apache.iotdb.commons.pipe.datastructure.pattern.PrefixPipePattern; |
25 | 25 | import org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent; |
| 26 | +import org.apache.iotdb.db.pipe.event.common.tablet.PipeTabletUtils; |
26 | 27 | import org.apache.iotdb.db.pipe.event.common.tablet.TabletInsertionDataContainer; |
27 | 28 | import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeId; |
28 | 29 | import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.InsertRowNode; |
@@ -217,7 +218,7 @@ private void createTablet() { |
217 | 218 | tabletForInsertRowNode.values = values; |
218 | 219 | tabletForInsertRowNode.timestamps = new long[] {times[0]}; |
219 | 220 | tabletForInsertRowNode.rowSize = 1; |
220 | | - tabletForInsertRowNode.bitMaps = bitMapsForInsertRowNode; |
| 221 | + tabletForInsertRowNode.bitMaps = PipeTabletUtils.compactBitMaps(bitMapsForInsertRowNode, 1); |
221 | 222 |
|
222 | 223 | // create tablet for insertTabletNode |
223 | 224 | BitMap[] bitMapsForInsertTabletNode = new BitMap[schemas.length]; |
@@ -253,7 +254,8 @@ private void createTablet() { |
253 | 254 | tabletForInsertTabletNode.values = values; |
254 | 255 | tabletForInsertTabletNode.timestamps = times; |
255 | 256 | tabletForInsertTabletNode.rowSize = times.length; |
256 | | - tabletForInsertTabletNode.bitMaps = bitMapsForInsertTabletNode; |
| 257 | + tabletForInsertTabletNode.bitMaps = |
| 258 | + PipeTabletUtils.compactBitMaps(bitMapsForInsertTabletNode, times.length); |
257 | 259 | } |
258 | 260 |
|
259 | 261 | @Test |
|
0 commit comments