in java/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkWriterImpl.java [302:335]
public void write(long time, TsPrimitiveType[] points) {
valueIndex = 0;
for (TsPrimitiveType point : points) {
ValueChunkWriter writer = valueChunkWriterList.get(valueIndex++);
switch (writer.getDataType()) {
case INT64:
case TIMESTAMP:
writer.write(time, point != null ? point.getLong() : Long.MAX_VALUE, point == null);
break;
case INT32:
case DATE:
writer.write(time, point != null ? point.getInt() : Integer.MAX_VALUE, point == null);
break;
case FLOAT:
writer.write(time, point != null ? point.getFloat() : Float.MAX_VALUE, point == null);
break;
case DOUBLE:
writer.write(time, point != null ? point.getDouble() : Double.MAX_VALUE, point == null);
break;
case BOOLEAN:
writer.write(time, point != null ? point.getBoolean() : false, point == null);
break;
case TEXT:
case BLOB:
case STRING:
writer.write(
time,
point != null ? point.getBinary() : new Binary("".getBytes(StandardCharsets.UTF_8)),
point == null);
break;
}
}
write(time);
}