This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch tsFile_v4
in repository https://gitbox.apache.org/repos/asf/tsfile.git
The following commit(s) were added to refs/heads/tsFile_v4 by this push:
new d2746294 fix spotless
d2746294 is described below
commit d2746294492ea35a4deb408876cb12396a6f4756
Author: Tian Jiang <[email protected]>
AuthorDate: Mon Apr 15 13:10:53 2024 +0800
fix spotless
---
.../tsfile/file/metadata/StringArrayDeviceID.java | 12 ++++--
.../apache/tsfile/read/TsFileSequenceReader.java | 13 +++---
.../java/org/apache/tsfile/read/common/Path.java | 8 ++--
.../apache/tsfile/read/common/block/TsBlock.java | 1 -
.../org/apache/tsfile/utils/MeasurementGroup.java | 1 -
.../java/org/apache/tsfile/write/TsFileWriter.java | 48 +++++++++-------------
.../write/chunk/AlignedChunkGroupWriterImpl.java | 1 -
.../tsfile/write/chunk/IChunkGroupWriter.java | 1 -
.../chunk/NonAlignedChunkGroupWriterImpl.java | 1 -
.../write/writer/RestorableTsFileIOWriter.java | 2 +-
.../apache/tsfile/write/writer/TsFileIOWriter.java | 3 +-
...easurementChunkMetadataListMapIteratorTest.java | 1 -
.../tsfile/read/TsFileSequenceReaderTest.java | 2 +-
.../org/apache/tsfile/write/TsFileWriterTest.java | 3 +-
14 files changed, 42 insertions(+), 55 deletions(-)
diff --git
a/tsfile/src/main/java/org/apache/tsfile/file/metadata/StringArrayDeviceID.java
b/tsfile/src/main/java/org/apache/tsfile/file/metadata/StringArrayDeviceID.java
index c882481f..db4fb7f6 100644
---
a/tsfile/src/main/java/org/apache/tsfile/file/metadata/StringArrayDeviceID.java
+++
b/tsfile/src/main/java/org/apache/tsfile/file/metadata/StringArrayDeviceID.java
@@ -79,8 +79,10 @@ public class StringArrayDeviceID implements IDeviceID {
int segmentCnt = 1;
// split the string with '.', stop when finding enough segments to form a
table name
// String.split is not used here to avoid unnecessary string copy
- for (; currPos < deviceIdString.length()
- && segmentCnt < TSFileConfig.DEFAULT_SEGMENT_NUM_FOR_TABLE_NAME + 1;
currPos++) {
+ for (;
+ currPos < deviceIdString.length()
+ && segmentCnt < TSFileConfig.DEFAULT_SEGMENT_NUM_FOR_TABLE_NAME +
1;
+ currPos++) {
if (deviceIdString.charAt(currPos) ==
TsFileConstant.PATH_SEPARATOR_CHAR) {
lastSeparatorPos = currPos;
segmentCnt++;
@@ -102,8 +104,10 @@ public class StringArrayDeviceID implements IDeviceID {
// "root.a.b.c" -> {"root.a.b", "c"}
// "root.a.b.c.d" -> {"root.a.b", "c", "d"}
tableName = deviceIdString.substring(0, lastSeparatorPos);
- String[] idSegments = deviceIdString.substring(lastSeparatorPos + 1)
- .split(TsFileConstant.PATH_SEPARATER_NO_REGEX);
+ String[] idSegments =
+ deviceIdString
+ .substring(lastSeparatorPos + 1)
+ .split(TsFileConstant.PATH_SEPARATER_NO_REGEX);
segments = new String[idSegments.length + 1];
segments[0] = tableName;
System.arraycopy(idSegments, 0, segments, 1, idSegments.length);
diff --git
a/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java
b/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java
index edd7e421..6d45ef72 100644
--- a/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java
+++ b/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java
@@ -69,8 +69,8 @@ import org.apache.tsfile.utils.ReadWriteIOUtils;
import org.apache.tsfile.utils.TsPrimitiveType;
import org.apache.tsfile.write.schema.IMeasurementSchema;
import org.apache.tsfile.write.schema.MeasurementSchema;
-
import org.apache.tsfile.write.schema.Schema;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -607,8 +607,7 @@ public class TsFileSequenceReader implements AutoCloseable {
}
private MetadataIndexNode getTableRootNode(String tableName) throws
IOException {
- MetadataIndexNode metadataIndexNode =
- tsFileMetaData.getTableMetadataIndexNode(tableName);
+ MetadataIndexNode metadataIndexNode =
tsFileMetaData.getTableMetadataIndexNode(tableName);
if (metadataIndexNode == null && fileVersion <
TSFileConfig.VERSION_NUMBER) {
// this file if from an old version, and all its metadata should have an
anonymous root
metadataIndexNode = tsFileMetaData.getTableMetadataIndexNode("");
@@ -1889,9 +1888,7 @@ public class TsFileSequenceReader implements
AutoCloseable {
*/
@SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity
warning
public long selfCheck(
- Schema schema,
- List<ChunkGroupMetadata> chunkGroupMetadataList,
- boolean fastFinish)
+ Schema schema, List<ChunkGroupMetadata> chunkGroupMetadataList, boolean
fastFinish)
throws IOException {
File checkFile = FSFactoryProducer.getFSFactory().getFile(this.file);
long fileSize;
@@ -2308,8 +2305,8 @@ public class TsFileSequenceReader implements
AutoCloseable {
*
* @return List of ChunkMetaData
*/
- public List<ChunkMetadata> getChunkMetadataList(IDeviceID deviceID, String
measurement, boolean ignoreNotExists)
- throws IOException {
+ public List<ChunkMetadata> getChunkMetadataList(
+ IDeviceID deviceID, String measurement, boolean ignoreNotExists) throws
IOException {
TimeseriesMetadata timeseriesMetaData =
readTimeseriesMetadata(deviceID, measurement, ignoreNotExists);
if (timeseriesMetaData == null) {
diff --git a/tsfile/src/main/java/org/apache/tsfile/read/common/Path.java
b/tsfile/src/main/java/org/apache/tsfile/read/common/Path.java
index a188c539..63d02973 100644
--- a/tsfile/src/main/java/org/apache/tsfile/read/common/Path.java
+++ b/tsfile/src/main/java/org/apache/tsfile/read/common/Path.java
@@ -19,13 +19,11 @@
package org.apache.tsfile.read.common;
-import org.apache.tsfile.common.conf.TSFileConfig;
import org.apache.tsfile.common.constant.TsFileConstant;
import org.apache.tsfile.exception.PathParseException;
import org.apache.tsfile.file.metadata.IDeviceID;
import org.apache.tsfile.file.metadata.IDeviceID.Deserializer;
import org.apache.tsfile.file.metadata.IDeviceID.Factory;
-import org.apache.tsfile.file.metadata.StringArrayDeviceID;
import org.apache.tsfile.read.common.parser.PathNodesGenerator;
import org.apache.tsfile.utils.PublicBAOS;
import org.apache.tsfile.utils.ReadWriteIOUtils;
@@ -132,7 +130,8 @@ public class Path implements Serializable, Comparable<Path>
{
this.fullPath = this.device.toString() + TsFileConstant.PATH_SEPARATOR +
measurement;
} else if (!StringUtils.isEmpty(device)) {
String[] deviceNodes = PathNodesGenerator.splitPathToNodes(device);
- this.device =
Factory.DEFAULT_FACTORY.create(transformNodesToString(deviceNodes,
deviceNodes.length));
+ this.device =
+ Factory.DEFAULT_FACTORY.create(transformNodesToString(deviceNodes,
deviceNodes.length));
this.measurement = measurement;
// for aligned path, sensor name for time column is ""
this.fullPath = device + TsFileConstant.PATH_SEPARATOR + measurement;
@@ -289,7 +288,8 @@ public class Path implements Serializable, Comparable<Path>
{
byte isNull = ReadWriteIOUtils.readByte(byteBuffer);
path.measurement = isNull == 0 ? null :
ReadWriteIOUtils.readString(byteBuffer);
isNull = ReadWriteIOUtils.readByte(byteBuffer);
- path.device = isNull == 0 ? null :
Deserializer.DEFAULT_DESERIALIZER.deserializeFrom(byteBuffer);
+ path.device =
+ isNull == 0 ? null :
Deserializer.DEFAULT_DESERIALIZER.deserializeFrom(byteBuffer);
isNull = ReadWriteIOUtils.readByte(byteBuffer);
path.fullPath = isNull == 0 ? null :
ReadWriteIOUtils.readString(byteBuffer);
return path;
diff --git
a/tsfile/src/main/java/org/apache/tsfile/read/common/block/TsBlock.java
b/tsfile/src/main/java/org/apache/tsfile/read/common/block/TsBlock.java
index bd1f1e86..2e88292e 100644
--- a/tsfile/src/main/java/org/apache/tsfile/read/common/block/TsBlock.java
+++ b/tsfile/src/main/java/org/apache/tsfile/read/common/block/TsBlock.java
@@ -30,7 +30,6 @@ import org.apache.tsfile.utils.RamUsageEstimator;
import org.apache.tsfile.utils.TsPrimitiveType;
import org.apache.tsfile.write.UnSupportedDataTypeException;
import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import java.util.Arrays;
import java.util.Iterator;
diff --git a/tsfile/src/main/java/org/apache/tsfile/utils/MeasurementGroup.java
b/tsfile/src/main/java/org/apache/tsfile/utils/MeasurementGroup.java
index 16c6880c..84f95f24 100644
--- a/tsfile/src/main/java/org/apache/tsfile/utils/MeasurementGroup.java
+++ b/tsfile/src/main/java/org/apache/tsfile/utils/MeasurementGroup.java
@@ -19,7 +19,6 @@
package org.apache.tsfile.utils;
import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import java.io.Serializable;
import java.util.HashMap;
diff --git a/tsfile/src/main/java/org/apache/tsfile/write/TsFileWriter.java
b/tsfile/src/main/java/org/apache/tsfile/write/TsFileWriter.java
index a8e00946..0ae5099f 100644
--- a/tsfile/src/main/java/org/apache/tsfile/write/TsFileWriter.java
+++ b/tsfile/src/main/java/org/apache/tsfile/write/TsFileWriter.java
@@ -38,9 +38,7 @@ import org.apache.tsfile.write.record.TSRecord;
import org.apache.tsfile.write.record.Tablet;
import org.apache.tsfile.write.record.datapoint.DataPoint;
import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import org.apache.tsfile.write.schema.Schema;
-import org.apache.tsfile.write.schema.VectorMeasurementSchema;
import org.apache.tsfile.write.writer.RestorableTsFileIOWriter;
import org.apache.tsfile.write.writer.TsFileIOWriter;
import org.apache.tsfile.write.writer.TsFileOutput;
@@ -58,17 +56,15 @@ import java.util.Map;
/**
* TsFileWriter is the entrance for writing processing. It receives a record
and send it to
* responding chunk group write. It checks memory size for all writing
processing along its strategy
- * and flush data stored in memory to OutputStream. At the end of writing,
user should call
- * {@code close()} method to flush the last data outside and close the normal
outputStream and error
+ * and flush data stored in memory to OutputStream. At the end of writing,
user should call {@code
+ * close()} method to flush the last data outside and close the normal
outputStream and error
* outputStream.
*/
public class TsFileWriter implements AutoCloseable {
protected static final TSFileConfig config =
TSFileDescriptor.getInstance().getConfig();
private static final Logger LOG =
LoggerFactory.getLogger(TsFileWriter.class);
- /**
- * IO writer of this TsFile.
- */
+ /** IO writer of this TsFile. */
private final TsFileIOWriter fileWriter;
private final int pageSize;
@@ -91,9 +87,7 @@ public class TsFileWriter implements AutoCloseable {
private Map<IDeviceID, IChunkGroupWriter> groupWriters = new HashMap<>();
- /**
- * min value of threshold of data points num check.
- */
+ /** min value of threshold of data points num check. */
private long recordCountForNextMemCheck = 100;
private long chunkGroupSizeThreshold;
@@ -121,7 +115,7 @@ public class TsFileWriter implements AutoCloseable {
/**
* init this TsFileWriter.
*
- * @param file the File to be written by this TsFileWriter
+ * @param file the File to be written by this TsFileWriter
* @param schema the schema of this TsFile
*/
public TsFileWriter(File file, Schema schema) throws IOException {
@@ -141,9 +135,9 @@ public class TsFileWriter implements AutoCloseable {
/**
* init this TsFileWriter.
*
- * @param file the File to be written by this TsFileWriter
+ * @param file the File to be written by this TsFileWriter
* @param schema the schema of this TsFile
- * @param conf the configuration of this TsFile
+ * @param conf the configuration of this TsFile
*/
public TsFileWriter(File file, Schema schema, TSFileConfig conf) throws
IOException {
this(new TsFileIOWriter(file), schema, conf);
@@ -153,8 +147,8 @@ public class TsFileWriter implements AutoCloseable {
* init this TsFileWriter.
*
* @param fileWriter the io writer of this TsFile
- * @param schema the schema of this TsFile
- * @param conf the configuration of this TsFile
+ * @param schema the schema of this TsFile
+ * @param conf the configuration of this TsFile
*/
protected TsFileWriter(TsFileIOWriter fileWriter, Schema schema,
TSFileConfig conf)
throws IOException {
@@ -165,8 +159,7 @@ public class TsFileWriter implements AutoCloseable {
this.fileWriter = fileWriter;
if (fileWriter instanceof RestorableTsFileIOWriter) {
- schema =
- ((RestorableTsFileIOWriter) fileWriter).getKnownSchema();
+ schema = ((RestorableTsFileIOWriter) fileWriter).getKnownSchema();
}
fileWriter.setSchema(schema);
@@ -213,9 +206,7 @@ public class TsFileWriter implements AutoCloseable {
IDeviceID.Factory.DEFAULT_FACTORY.create(devicePath.getDeviceString()),
measurementSchema);
}
- /**
- * Register nonAligned timeseries by single.
- */
+ /** Register nonAligned timeseries by single. */
public void registerTimeseries(IDeviceID deviceID, IMeasurementSchema
measurementSchema)
throws WriteProcessException {
MeasurementGroup measurementGroup;
@@ -254,8 +245,8 @@ public class TsFileWriter implements AutoCloseable {
}
}
- public void registerAlignedTimeseries(Path devicePath,
List<IMeasurementSchema> measurementSchemas)
- throws WriteProcessException {
+ public void registerAlignedTimeseries(
+ Path devicePath, List<IMeasurementSchema> measurementSchemas) throws
WriteProcessException {
registerAlignedTimeseries(
IDeviceID.Factory.DEFAULT_FACTORY.create(devicePath.getDeviceString()),
measurementSchemas);
}
@@ -265,7 +256,8 @@ public class TsFileWriter implements AutoCloseable {
* expanded.
*/
public void registerAlignedTimeseries(
- IDeviceID deviceID, List<IMeasurementSchema> measurementSchemas) throws
WriteProcessException {
+ IDeviceID deviceID, List<IMeasurementSchema> measurementSchemas)
+ throws WriteProcessException {
if (getSchema().containsDevice(deviceID)) {
if (getSchema().getSeriesSchema(deviceID).isAligned()) {
throw new WriteProcessException(
@@ -407,9 +399,7 @@ public class TsFileWriter implements AutoCloseable {
}
}
- /**
- * Check whether all measurements of dataPoints list are in the
measurementGroup.
- */
+ /** Check whether all measurements of dataPoints list are in the
measurementGroup. */
private List<IMeasurementSchema> checkIsAllMeasurementsInGroup(
List<DataPoint> dataPoints, MeasurementGroup measurementGroup, boolean
isAligned)
throws NoMeasurementException {
@@ -463,7 +453,7 @@ public class TsFileWriter implements AutoCloseable {
*
* @param record - record responding a data line
* @return true -size of tsfile or metadata reaches the threshold. false -
otherwise
- * @throws IOException exception in IO
+ * @throws IOException exception in IO
* @throws WriteProcessException exception in write process
*/
public boolean write(TSRecord record) throws IOException,
WriteProcessException {
@@ -488,7 +478,7 @@ public class TsFileWriter implements AutoCloseable {
* write a tablet
*
* @param tablet - multiple time series of one device that share a time
column
- * @throws IOException exception in IO
+ * @throws IOException exception in IO
* @throws WriteProcessException exception in write process
*/
public boolean write(Tablet tablet) throws IOException,
WriteProcessException {
@@ -554,7 +544,7 @@ public class TsFileWriter implements AutoCloseable {
* outputStream.
*
* @return true - size of tsfile or metadata reaches the threshold. false -
otherwise. But this
- * function just return false, the Override of IoTDB may return true.
+ * function just return false, the Override of IoTDB may return true.
* @throws IOException exception in IO
*/
public boolean flushAllChunkGroups() throws IOException {
diff --git
a/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java
b/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java
index 9bea331d..6d8289a8 100644
---
a/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java
+++
b/tsfile/src/main/java/org/apache/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java
@@ -32,7 +32,6 @@ import org.apache.tsfile.write.UnSupportedDataTypeException;
import org.apache.tsfile.write.record.Tablet;
import org.apache.tsfile.write.record.datapoint.DataPoint;
import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import org.apache.tsfile.write.writer.TsFileIOWriter;
import org.slf4j.Logger;
diff --git
a/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkGroupWriter.java
b/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkGroupWriter.java
index e0932474..bc7bc12c 100644
--- a/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkGroupWriter.java
+++ b/tsfile/src/main/java/org/apache/tsfile/write/chunk/IChunkGroupWriter.java
@@ -22,7 +22,6 @@ import
org.apache.tsfile.exception.write.WriteProcessException;
import org.apache.tsfile.write.record.Tablet;
import org.apache.tsfile.write.record.datapoint.DataPoint;
import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import org.apache.tsfile.write.writer.TsFileIOWriter;
import java.io.IOException;
diff --git
a/tsfile/src/main/java/org/apache/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java
b/tsfile/src/main/java/org/apache/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java
index 799dc21e..379cb2c2 100644
---
a/tsfile/src/main/java/org/apache/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java
+++
b/tsfile/src/main/java/org/apache/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java
@@ -27,7 +27,6 @@ import org.apache.tsfile.write.UnSupportedDataTypeException;
import org.apache.tsfile.write.record.Tablet;
import org.apache.tsfile.write.record.datapoint.DataPoint;
import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import org.apache.tsfile.write.writer.TsFileIOWriter;
import org.slf4j.Logger;
diff --git
a/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java
b/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java
index 11fecab1..ecbb8bed 100644
---
a/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java
+++
b/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java
@@ -30,8 +30,8 @@ import org.apache.tsfile.read.TsFileCheckStatus;
import org.apache.tsfile.read.TsFileSequenceReader;
import org.apache.tsfile.read.common.Path;
import org.apache.tsfile.write.schema.IMeasurementSchema;
-
import org.apache.tsfile.write.schema.Schema;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/tsfile/src/main/java/org/apache/tsfile/write/writer/TsFileIOWriter.java
b/tsfile/src/main/java/org/apache/tsfile/write/writer/TsFileIOWriter.java
index c7863f3b..cba27995 100644
--- a/tsfile/src/main/java/org/apache/tsfile/write/writer/TsFileIOWriter.java
+++ b/tsfile/src/main/java/org/apache/tsfile/write/writer/TsFileIOWriter.java
@@ -691,7 +691,8 @@ public class TsFileIOWriter implements AutoCloseable {
endPosInCMTForDevice.add(tempOutput.getPosition());
// serialize the device
// for each device, we only serialize it once, in order to save io
- writtenSize += ReadWriteIOUtils.write(seriesPath.getDeviceString(),
tempOutput.wrapAsStream());
+ writtenSize +=
+ ReadWriteIOUtils.write(seriesPath.getDeviceString(),
tempOutput.wrapAsStream());
}
if (isNewPath && !iChunkMetadataList.isEmpty()) {
// serialize the public info of this measurement
diff --git
a/tsfile/src/test/java/org/apache/tsfile/read/MeasurementChunkMetadataListMapIteratorTest.java
b/tsfile/src/test/java/org/apache/tsfile/read/MeasurementChunkMetadataListMapIteratorTest.java
index 5e6f37b6..0dd91bf2 100644
---
a/tsfile/src/test/java/org/apache/tsfile/read/MeasurementChunkMetadataListMapIteratorTest.java
+++
b/tsfile/src/test/java/org/apache/tsfile/read/MeasurementChunkMetadataListMapIteratorTest.java
@@ -24,7 +24,6 @@ import org.apache.tsfile.common.conf.TSFileDescriptor;
import org.apache.tsfile.file.metadata.ChunkMetadata;
import org.apache.tsfile.file.metadata.IChunkMetadata;
import org.apache.tsfile.file.metadata.IDeviceID;
-import org.apache.tsfile.read.common.Path;
import org.apache.tsfile.utils.FileGenerator;
import org.junit.After;
diff --git
a/tsfile/src/test/java/org/apache/tsfile/read/TsFileSequenceReaderTest.java
b/tsfile/src/test/java/org/apache/tsfile/read/TsFileSequenceReaderTest.java
index c65a7fdb..4f338baa 100644
--- a/tsfile/src/test/java/org/apache/tsfile/read/TsFileSequenceReaderTest.java
+++ b/tsfile/src/test/java/org/apache/tsfile/read/TsFileSequenceReaderTest.java
@@ -37,8 +37,8 @@ import org.apache.tsfile.utils.TsFileGeneratorUtils;
import org.apache.tsfile.write.TsFileWriter;
import org.apache.tsfile.write.schema.IMeasurementSchema;
import org.apache.tsfile.write.schema.MeasurementSchema;
-
import org.apache.tsfile.write.schema.Schema;
+
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
diff --git a/tsfile/src/test/java/org/apache/tsfile/write/TsFileWriterTest.java
b/tsfile/src/test/java/org/apache/tsfile/write/TsFileWriterTest.java
index 7d6c380c..1cef9f91 100644
--- a/tsfile/src/test/java/org/apache/tsfile/write/TsFileWriterTest.java
+++ b/tsfile/src/test/java/org/apache/tsfile/write/TsFileWriterTest.java
@@ -104,7 +104,8 @@ public class TsFileWriterTest {
new Path("d1"),
new MeasurementSchema("s1", TSDataType.FLOAT, TSEncoding.RLE,
CompressionType.SNAPPY));
} catch (WriteProcessException e) {
- Assert.assertEquals("given nonAligned timeseries .d1.s1 has been
registered.", e.getMessage());
+ Assert.assertEquals(
+ "given nonAligned timeseries .d1.s1 has been registered.",
e.getMessage());
}
try {
List<IMeasurementSchema> schemas = new ArrayList<>();
