Skip to content

Commit

Permalink
fix compile
Browse files Browse the repository at this point in the history
  • Loading branch information
HTHou committed Nov 29, 2024
1 parent 4b9edf6 commit 9caa42a
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public class AlignedWritableMemChunk implements IWritableMemChunk {
private final Map<String, Integer> measurementIndexMap;
private final List<IMeasurementSchema> schemaList;
private AlignedTVList list;
private boolean ignoreAllNullRows;
private final boolean ignoreAllNullRows;

private static final IoTDBConfig CONFIG = IoTDBDescriptor.getInstance().getConfig();
private final long TARGET_CHUNK_SIZE = CONFIG.getTargetChunkSize();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -234,7 +234,7 @@ public void testFlushMultiChunks()
assertTrue(tsfileResourcesForQuery.isEmpty());

for (int i = 1; i <= 100; i++) {
TSRecord record = new TSRecord(i, deviceId);
TSRecord record = new TSRecord(deviceId, i);
record.addTuple(DataPoint.getDataPoint(dataType, measurementId, String.valueOf(i)));
processor.insert(buildInsertRowNodeByTSRecord(record), new long[4]);
}
Expand Down Expand Up @@ -313,7 +313,7 @@ public void testFlushMultiBinaryChunks()
assertTrue(tsfileResourcesForQuery.isEmpty());

for (int i = 1; i <= 100; i++) {
TSRecord record = new TSRecord(i, deviceId);
TSRecord record = new TSRecord(deviceId, i);
record.addTuple(DataPoint.getDataPoint(TSDataType.TEXT, measurementId, String.valueOf(i)));
processor.insert(buildInsertRowNodeByTSRecord(record), new long[4]);
}
Expand Down Expand Up @@ -390,15 +390,15 @@ public void testFlushMultiAlignedChunks()
assertTrue(tsfileResourcesForQuery.isEmpty());

for (int i = 1; i <= 100; i++) {
TSRecord record = new TSRecord(i, deviceId);
TSRecord record = new TSRecord(deviceId, i);
record.addTuple(DataPoint.getDataPoint(dataType, measurementId, String.valueOf(i)));
InsertRowNode rowNode = buildInsertRowNodeByTSRecord(record);
rowNode.setAligned(true);
processor.insert(rowNode, new long[4]);
}

// add another point time = 1, value = 1
TSRecord record = new TSRecord(1, deviceId);
TSRecord record = new TSRecord(deviceId, 1);
record.addTuple(DataPoint.getDataPoint(dataType, measurementId, "1"));
InsertRowNode rowNode = buildInsertRowNodeByTSRecord(record);
rowNode.setAligned(true);
Expand Down Expand Up @@ -480,14 +480,14 @@ public void testFlushMultiAlignedBinaryChunks()
assertTrue(tsfileResourcesForQuery.isEmpty());

for (int i = 1; i <= 100; i++) {
TSRecord record = new TSRecord(i, deviceId);
TSRecord record = new TSRecord(deviceId, i);
record.addTuple(DataPoint.getDataPoint(TSDataType.TEXT, measurementId, String.valueOf(i)));
InsertRowNode rowNode = buildInsertRowNodeByTSRecord(record);
rowNode.setAligned(true);
processor.insert(rowNode, new long[4]);
}
// add another point time = 1, value = "1"
TSRecord record = new TSRecord(1, deviceId);
TSRecord record = new TSRecord(deviceId, 1);
record.addTuple(DataPoint.getDataPoint(TSDataType.TEXT, measurementId, "1"));
InsertRowNode rowNode = buildInsertRowNodeByTSRecord(record);
rowNode.setAligned(true);
Expand Down

0 comments on commit 9caa42a

Please sign in to comment.