in tsfile-viewer-core/src/main/java/org/apache/iotdb/tool/core/util/TsFileEncodeCompressAnalysedUtil.java [112:137]
private static List<EncodeCompressAnalysedModel> generateEncodeAndCompressAnalysedBase(
DsTypeEncodeModel encodeModel) throws IOException {
List<PublicBAOS> publicBAOS = encodeModel.getPublicBAOS();
List<String> encodeNameList = encodeModel.getEncodeNameList();
List<EncodeCompressAnalysedModel> modelList = new ArrayList<>();
List<Encoder> encoders = encodeModel.getEncoders();
for (int i = 0; i < encodeModel.getEncoders().size(); i++) {
encoders.get(i).flush(publicBAOS.get(i));
}
long uncompressSize = publicBAOS.get(0).size();
for (int i = 0; i < encodeModel.getEncoders().size(); i++) {
for (int j = 0; j < compressTypes.length; j++) {
modelList.add(
generateAnalysedModel(
compressTypes[j],
encodeNameList.get(i),
uncompressSize,
encodeModel.getTypeName(),
publicBAOS.get(i)));
}
}
for (PublicBAOS baos : publicBAOS) {
baos.close();
}
return modelList;
}