This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch sevo_support in repository https://gitbox.apache.org/repos/asf/tsfile.git
commit d71552b94a0fb7794541ca2af04ec56cbe05a4d3 Author: Tian Jiang <[email protected]> AuthorDate: Sun Jan 4 16:07:41 2026 +0800 spotless --- .../tsfile/write/chunk/AlignedChunkWriterImpl.java | 7 ++++--- .../apache/tsfile/write/chunk/ChunkWriterImpl.java | 21 +++++++++++++-------- .../org/apache/tsfile/write/chunk/IChunkWriter.java | 6 ++++-- .../apache/tsfile/write/chunk/ValueChunkWriter.java | 16 ++++++++++------ 4 files changed, 31 insertions(+), 19 deletions(-) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkWriterImpl.java b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkWriterImpl.java index 08ae5753..fa3cb348 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkWriterImpl.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkWriterImpl.java @@ -18,7 +18,6 @@ */ package org.apache.tsfile.write.chunk; -import java.util.function.Function; import org.apache.tsfile.block.column.Column; import org.apache.tsfile.common.conf.TSFileDescriptor; import org.apache.tsfile.encoding.encoder.Encoder; @@ -42,6 +41,7 @@ import java.nio.ByteBuffer; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.List; +import java.util.function.Function; public class AlignedChunkWriterImpl implements IChunkWriter { @@ -479,8 +479,9 @@ public class AlignedChunkWriterImpl implements IChunkWriter { } @Override - public void writeToFileWriter(TsFileIOWriter tsfileWriter, - Function<String, String> measurementNameRemapper) throws IOException { + public void writeToFileWriter( + TsFileIOWriter tsfileWriter, Function<String, String> measurementNameRemapper) + throws IOException { timeChunkWriter.writeToFileWriter(tsfileWriter); for (ValueChunkWriter valueChunkWriter : valueChunkWriterList) { valueChunkWriter.writeToFileWriter(tsfileWriter, measurementNameRemapper); diff --git a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ChunkWriterImpl.java b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ChunkWriterImpl.java index d450b373..74205436 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ChunkWriterImpl.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ChunkWriterImpl.java @@ -18,7 +18,6 @@ */ package org.apache.tsfile.write.chunk; -import java.util.function.Function; import org.apache.tsfile.common.conf.TSFileDescriptor; import org.apache.tsfile.compress.ICompressor; import org.apache.tsfile.encoding.encoder.SDTEncoder; @@ -44,6 +43,7 @@ import java.io.Serializable; import java.nio.ByteBuffer; import java.nio.channels.Channels; import java.nio.channels.WritableByteChannel; +import java.util.function.Function; public class ChunkWriterImpl implements IChunkWriter { @@ -351,8 +351,9 @@ public class ChunkWriterImpl implements IChunkWriter { } @Override - public void writeToFileWriter(TsFileIOWriter tsfileWriter, - Function<String, String> measurementNameRemapper) throws IOException { + public void writeToFileWriter( + TsFileIOWriter tsfileWriter, Function<String, String> measurementNameRemapper) + throws IOException { sealCurrentPage(); writeAllPagesOfChunkToTsFile(tsfileWriter, statistics, measurementNameRemapper); @@ -479,21 +480,25 @@ public class ChunkWriterImpl implements IChunkWriter { /** * write the page to specified IOWriter. * - * @param writer the specified IOWriter - * @param statistics the chunk statistics + * @param writer the specified IOWriter + * @param statistics the chunk statistics * @param measurementNameRemapper * @throws IOException exception in IO */ private void writeAllPagesOfChunkToTsFile( - TsFileIOWriter writer, Statistics<? extends Serializable> statistics, - Function<String, String> measurementNameRemapper) throws IOException { + TsFileIOWriter writer, + Statistics<? extends Serializable> statistics, + Function<String, String> measurementNameRemapper) + throws IOException { if (statistics.getCount() == 0) { return; } // start to write this column chunk writer.startFlushChunk( - measurementNameRemapper == null ? measurementSchema.getMeasurementName() : measurementNameRemapper.apply(measurementSchema.getMeasurementName()), + measurementNameRemapper == null + ? measurementSchema.getMeasurementName() + : measurementNameRemapper.apply(measurementSchema.getMeasurementName()), compressor.getType(), measurementSchema.getType(), measurementSchema.getEncodingType(), diff --git a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkWriter.java b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkWriter.java index 11304073..4a198841 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkWriter.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkWriter.java @@ -18,10 +18,10 @@ */ package org.apache.tsfile.write.chunk; -import java.util.function.Function; import org.apache.tsfile.write.writer.TsFileIOWriter; import java.io.IOException; +import java.util.function.Function; /** IChunkWriter provides a list of writing methods for different value types. */ public interface IChunkWriter { @@ -32,7 +32,9 @@ public interface IChunkWriter { /** * flush data to TsFileIOWriter, may rename the measurement in the file according to the remapper. */ - void writeToFileWriter(TsFileIOWriter tsfileWriter, Function<String, String> measurementNameRemapper) throws IOException; + void writeToFileWriter( + TsFileIOWriter tsfileWriter, Function<String, String> measurementNameRemapper) + throws IOException; /** estimate memory usage of this series. */ long estimateMaxSeriesMemSize(); diff --git a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ValueChunkWriter.java b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ValueChunkWriter.java index a778f741..31ab3f6c 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ValueChunkWriter.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/write/chunk/ValueChunkWriter.java @@ -18,7 +18,6 @@ */ package org.apache.tsfile.write.chunk; -import java.util.function.Function; import org.apache.tsfile.common.conf.TSFileDescriptor; import org.apache.tsfile.common.constant.TsFileConstant; import org.apache.tsfile.compress.ICompressor; @@ -46,6 +45,7 @@ import java.io.Serializable; import java.nio.ByteBuffer; import java.nio.channels.Channels; import java.nio.channels.WritableByteChannel; +import java.util.function.Function; public class ValueChunkWriter { @@ -299,8 +299,9 @@ public class ValueChunkWriter { writeToFileWriter(tsfileWriter, null); } - public void writeToFileWriter(TsFileIOWriter tsfileWriter, - Function<String, String> measurementNameRemapper) throws IOException { + public void writeToFileWriter( + TsFileIOWriter tsfileWriter, Function<String, String> measurementNameRemapper) + throws IOException { sealCurrentPage(); writeAllPagesOfChunkToTsFile(tsfileWriter, measurementNameRemapper); @@ -391,9 +392,12 @@ public class ValueChunkWriter { * @param writer the specified IOWriter * @throws IOException exception in IO */ - public void writeAllPagesOfChunkToTsFile(TsFileIOWriter writer, - Function<String, String> measurementNameRemapper) throws IOException { - String finalMeasurementId = measurementNameRemapper == null ? measurementId : measurementNameRemapper.apply(measurementId); + public void writeAllPagesOfChunkToTsFile( + TsFileIOWriter writer, Function<String, String> measurementNameRemapper) throws IOException { + String finalMeasurementId = + measurementNameRemapper == null + ? measurementId + : measurementNameRemapper.apply(measurementId); if (statistics.getCount() == 0) { if (pageBuffer.size() == 0) { return;
