diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultPullConsumerDataSetIT.java index c8d0ec233dc5..b9e1fb0f1dd5 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultPullConsumerDataSetIT.java @@ -29,7 +29,6 @@ import org.apache.thrift.TException; import org.apache.tsfile.enums.TSDataType; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -49,7 +48,7 @@ public class IoTDBDefaultPullConsumerDataSetIT extends AbstractSubscriptionRegre private int deviceCount = 3; private static final String databasePrefix = "root.DefaultPullConsumerDataSet"; private static String topicName = "topic_autodb_DefaultPullConsumerDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultTsfilePushConsumerIT.java index 90b8a4513a44..2b55879f2d98 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultTsfilePushConsumerIT.java @@ -36,7 +36,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -65,7 +64,7 @@ public class IoTDBDefaultTsfilePushConsumerIT extends AbstractSubscriptionRegres private int deviceCount = 3; private static final String databasePrefix = "root.DefaultTsfilePushConsumer"; private static String topicName = "topicDefaultTsfilePushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootDatasetPushConsumerIT.java index d02c3db48511..caacf6757ca8 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootDatasetPushConsumerIT.java @@ -32,7 +32,6 @@ import org.apache.thrift.TException; import org.apache.tsfile.enums.TSDataType; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -61,7 +60,7 @@ public class IoTDBRootDatasetPushConsumerIT extends AbstractSubscriptionRegressi private static final String databasePrefix = "root.RootDatasetPushConsumer"; private static final String database2 = "root.RootDatasetPushConsumer2.test"; private static String topicName = "topicAutoCreateDB_RootDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootPullConsumeTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootPullConsumeTsfileIT.java index 62e7299be0d9..ad7363013570 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootPullConsumeTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootPullConsumeTsfileIT.java @@ -29,7 +29,6 @@ import org.apache.thrift.TException; import org.apache.tsfile.enums.TSDataType; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -54,7 +53,7 @@ public class IoTDBRootPullConsumeTsfileIT extends AbstractSubscriptionRegression private static final String device2 = "root.RootPullConsumeTsfile.d_1"; public static SubscriptionPullConsumer consumer; private static String topicName = "topicAutoCreateDB_RootPullConsumeTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/mix/IoTDBPushConsumerPullConsumerWith1TopicShareProcessMixIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/mix/IoTDBPushConsumerPullConsumerWith1TopicShareProcessMixIT.java index 18eb091ad382..be44aa833602 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/mix/IoTDBPushConsumerPullConsumerWith1TopicShareProcessMixIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/mix/IoTDBPushConsumerPullConsumerWith1TopicShareProcessMixIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -59,7 +58,7 @@ public class IoTDBPushConsumerPullConsumerWith1TopicShareProcessMixIT extends AbstractSubscriptionRegressionIT { private static String topicName = "`1-group.1-consumer.db`"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private final String database = "root.PushConsumerPullConsumerWith1TopicShareProcessMix"; private final String device = database + ".d_0"; private final String pattern = database + ".**"; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitFalseDataSetPullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitFalseDataSetPullConsumerIT.java index ef4b80aa55bf..800bc5ef69bd 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitFalseDataSetPullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitFalseDataSetPullConsumerIT.java @@ -33,7 +33,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -66,7 +65,7 @@ public class IoTDBTestAutoCommitFalseDataSetPullConsumerIT private static final String topicName = "Topic_auto_commit_false"; private String pattern = device + ".**"; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitTrueDataSetPullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitTrueDataSetPullConsumerIT.java index b9110ce54050..d5d72d34137e 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitTrueDataSetPullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitTrueDataSetPullConsumerIT.java @@ -33,7 +33,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBTestAutoCommitTrueDataSetPullConsumerIT extends AbstractSubscr private static final String topicName = "topic_auto_commit_true"; private String pattern = device + ".**"; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBDataSetPullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBDataSetPullConsumerIT.java index ec58d72ef047..6610c1b129a4 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBDataSetPullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBDataSetPullConsumerIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -55,7 +54,7 @@ public class IoTDBDBDataSetPullConsumerIT extends AbstractSubscriptionRegression private static final String topicName = "topic_format_pull_dataset"; private static final String pattern = database + ".**"; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBTsfilePullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBTsfilePullConsumerIT.java index 7f120af3eebf..8a3da6afd6e4 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBTsfilePullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBTsfilePullConsumerIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -55,7 +54,7 @@ public class IoTDBDBTsfilePullConsumerIT extends AbstractSubscriptionRegressionI private static final String topicName = "topic_format_pull_tsfile"; private static final String pattern = database + ".**"; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsDatasetPullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsDatasetPullConsumerIT.java index 57950abb1fa8..07405a8970fc 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsDatasetPullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsDatasetPullConsumerIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -59,7 +58,7 @@ public class IoTDBAllTsDatasetPullConsumerIT extends AbstractSubscriptionRegress private String device2 = database + ".d_1"; private static final String pattern = device + ".s_0"; private static final String topicName = "topic_loose_range_all_pull_dataset"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsTsfilePullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsTsfilePullConsumerIT.java index 4b9fa39bf8fd..3787c28345f1 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsTsfilePullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsTsfilePullConsumerIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBAllTsTsfilePullConsumerIT extends AbstractSubscriptionRegressi private static final String pattern = device + ".s_0"; private static final String device2 = database + ".d_1"; private static SubscriptionPullConsumer consumer; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private long nowTimestamp; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsfilePullConsumerSnapshotIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsfilePullConsumerSnapshotIT.java index 5a36098376bf..95d0bce419da 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsfilePullConsumerSnapshotIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsfilePullConsumerSnapshotIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -62,7 +61,7 @@ public class IoTDBAllTsfilePullConsumerSnapshotIT extends AbstractSubscriptionRe private static final String pattern = device + ".s_0"; private static final String device2 = database + ".d_1"; private static SubscriptionPullConsumer consumer; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private long nowTimestamp; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceDataSetPullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceDataSetPullConsumerIT.java index d0f5db2f1324..6e9c3e5158b5 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceDataSetPullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceDataSetPullConsumerIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -59,7 +58,7 @@ public class IoTDBPathDeviceDataSetPullConsumerIT extends AbstractSubscriptionRe private String pattern = device + ".**"; private String device2 = database + ".d_1"; private static SubscriptionPullConsumer consumer; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceTsfilePullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceTsfilePullConsumerIT.java index 617359530892..25928e6ff7d7 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceTsfilePullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceTsfilePullConsumerIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBPathDeviceTsfilePullConsumerIT extends AbstractSubscriptionReg private static final String pattern = device + ".**"; private static final String device2 = database + ".d_1"; private static SubscriptionPullConsumer consumer; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsDatasetPullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsDatasetPullConsumerIT.java index f6a257181427..111be2cf9723 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsDatasetPullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsDatasetPullConsumerIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBTimeTsDatasetPullConsumerIT extends AbstractSubscriptionRegres private String device2 = database + ".d_1"; private String device3 = database2 + ".d_2"; private String pattern = device + ".s_0"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsTsfilePullConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsTsfilePullConsumerIT.java index 899140c2e14d..6695fde116db 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsTsfilePullConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsTsfilePullConsumerIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBTimeTsTsfilePullConsumerIT extends AbstractSubscriptionRegress private static final String device2 = database + ".d_1"; private static final String device3 = database2 + ".d_2"; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static List rowCountList; private long nowTimestamp; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerDataSetIT.java index b177a4d98f1c..8f6f432558f8 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerDataSetIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -54,7 +53,7 @@ public class IoTDBSnapshotDevicePullConsumerDataSetIT extends AbstractSubscripti private String pattern = device + ".**"; private static SubscriptionPullConsumer consumer; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerTsfileIT.java index 170937498ad9..6f8d49f4fc47 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerTsfileIT.java @@ -32,7 +32,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -58,7 +57,7 @@ public class IoTDBSnapshotDevicePullConsumerTsfileIT extends AbstractSubscriptio private static final String topicName = "topicSnapshotDevicePullConsumerTsfile"; private static final String pattern = device + ".**"; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java index 7b1a991b35c3..4af1f7f3b681 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -53,7 +52,7 @@ public class IoTDBConsumer2With1TopicShareProcessDataSetIT private String pattern = device + ".**"; private SubscriptionPullConsumer consumer2; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java index 90007c5e9fda..934071921f82 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -58,7 +57,7 @@ public class IoTDBConsumer2With1TopicShareProcessTsfileIT extends AbstractSubscr private static final String database = "root.test.Consumer2With1TopicShareProcessTsfile"; private static final String device = database + ".d_0"; private static final String topicName = "topicConsumer2With1TopicShareProcessTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = device + ".**"; private SubscriptionPullConsumer consumer2; private static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java index 23349d90d815..ecae393ebfe6 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -48,7 +47,7 @@ public class IoTDBMultiGroupVsMultiConsumerIT extends AbstractSubscriptionRegressionIT { private static final String database = "root.test.pullMultiGroupVsMultiConsumer"; private static final String device = database + ".d_0"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String topicNamePrefix = "TopicPullMultiGroupVsMultiConsumer_"; private int tsCount = 10; private int consumertCount = 10; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java index 217801a7fa98..261361b4a8a8 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -53,7 +52,7 @@ public class IoTDBOneConsumerMultiTopicsDatasetIT extends AbstractSubscriptionRegressionIT { private static final String database = "root.test.OneConsumerMultiTopicsDataset"; private static final String device = database + ".d_0"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = device + ".s_0"; private String pattern2 = device + ".s_1"; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java index 39c7cafce96f..3e77496db47f 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -69,7 +68,7 @@ public class IoTDBOneConsumerMultiTopicsMixIT extends AbstractSubscriptionRegres private String pattern2 = "root.**"; private String topicName = "topic1_OneConsumerMultiTopicsMix"; private String topicName2 = "topic2_OneConsumerMultiTopicsMix"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java index 6bd2c04f5f5c..9dc310554ccf 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -52,7 +51,7 @@ public class IoTDBOneConsumerMultiTopicsTsfileIT extends AbstractSubscriptionRegressionIT { private static final String database = "root.test.OneConsumerMultiTopicsTsfile"; private static final String device = database + ".d_0"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = database + ".**"; private String database2 = "root.OneConsumerMultiTopicsTsfile"; private String pattern2 = database2 + ".**"; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumeTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumeTsfileIT.java index 10e85e7244f4..bfa0d3b71fbe 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumeTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumeTsfileIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -56,7 +55,7 @@ public class IoTDBDBPatternPullConsumeTsfileIT extends AbstractSubscriptionRegre private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topicDBPatternPullConsumeTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = database + ".**"; private static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumerDataSetIT.java index 04d803b95d46..bbb0f74ab87f 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -54,7 +53,7 @@ public class IoTDBDBPatternPullConsumerDataSetIT extends AbstractSubscriptionReg private static final String database2 = "root.DBPatternPullConsumerDataSet"; private static final String device = database + ".d_0"; private static final String topicName = "topicDBPatternPullConsumerDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = database + ".**"; private static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDefaultPatternPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDefaultPatternPullConsumerDataSetIT.java index 01a5978f3084..a04d05ada701 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDefaultPatternPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDefaultPatternPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -51,7 +50,7 @@ public class IoTDBDefaultPatternPullConsumerDataSetIT extends AbstractSubscripti private static final String device = database + ".d_0"; private static final String topicName = "topicDefaultPatternPullConsumerDataSet"; private static SubscriptionPullConsumer consumer; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); @Override @Before diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumeTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumeTsfileIT.java index 68e4fd19f7c9..7e9bcf723ca4 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumeTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumeTsfileIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -57,7 +56,7 @@ public class IoTDBDevicePatternPullConsumeTsfileIT extends AbstractSubscriptionR private static final String device2 = database + ".d_1"; private static final String device3 = database2 + ".d_2"; private static final String topicName = "topicDevicePatternPullConsumeTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = device + ".**"; private static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumerDataSetIT.java index 9d8f217b8164..58d5c1b54036 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -51,7 +50,7 @@ public class IoTDBDevicePatternPullConsumerDataSetIT extends AbstractSubscriptio private static final String device = database + ".d_0"; private static final String device2 = database2 + ".d_2"; private static final String topicName = "topicDevicePatternPullConsumerDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = device + ".**"; public static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatch2PatternPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatch2PatternPullConsumerDataSetIT.java index 4c0893c28c2c..25c832c71136 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatch2PatternPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatch2PatternPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -59,7 +58,7 @@ public class IoTDBMiddleMatch2PatternPullConsumerDataSetIT private static final String device2 = database2 + ".sd_1"; private static final String device3 = database2 + ".d_2"; private static final String topicName = "topicMiddleMatch2PatternPullConsumerDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = "root.*.d_*.*"; private static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumeTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumeTsfileIT.java index 8785d7a91cff..6c00913f8231 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumeTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumeTsfileIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -56,7 +55,7 @@ public class IoTDBMiddleMatchPatternPullConsumeTsfileIT extends AbstractSubscrip private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topicMiddleMatchPatternPullConsumeTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = "root.**.d_*.**"; private static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumerDataSetIT.java index 395e415584da..5840a4c9a910 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -51,7 +50,7 @@ public class IoTDBMiddleMatchPatternPullConsumerDataSetIT extends AbstractSubscr private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topicMiddleMatchPatternPullConsumerDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = "root.**.d_*.s_0"; public static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBRootPatternPullConsumeTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBRootPatternPullConsumeTsfileIT.java index 290387abb197..8e91c4aa3881 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBRootPatternPullConsumeTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBRootPatternPullConsumeTsfileIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -54,7 +53,7 @@ public class IoTDBRootPatternPullConsumeTsfileIT extends AbstractSubscriptionReg private static final String database = "root.test.RootPatternPullConsumeTsfile"; private static final String device = database + ".d_0"; private static final String topicName = "topicRootPatternPullConsumeTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = "root.**"; public static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumeTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumeTsfileIT.java index 9a2458f2f45d..0bfd0e488aa9 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumeTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumeTsfileIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -57,7 +56,7 @@ public class IoTDBTSPatternPullConsumeTsfileIT extends AbstractSubscriptionRegre private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topicDBPatternPullConsumeTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = device + ".s_0"; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumerDataSetIT.java index 1a96176e2bae..d7a38e8304a4 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -49,7 +48,7 @@ public class IoTDBTSPatternPullConsumerDataSetIT extends AbstractSubscriptionReg private static final String database = "root.test.TSPatternPullConsumerDataSet"; private static final String device = database + ".d_0"; private static final String topicName = "topicTSPatternPullConsumerDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = device + ".s_0"; public static SubscriptionPullConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBAllPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBAllPullConsumerDataSetIT.java index 123139514ec3..4401b1e582f6 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBAllPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBAllPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -51,7 +50,7 @@ public class IoTDBAllPullConsumerDataSetIT extends AbstractSubscriptionRegressio private String pattern = device + ".s_0"; // private String topicName = "`1-group.1-consumer.ts`"; private String topicName = "topic_AllPullConsumerDataSet"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBHistoryPullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBHistoryPullConsumerDataSetIT.java index a10c8c108003..9ffe87dfd3e8 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBHistoryPullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBHistoryPullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -51,7 +50,7 @@ public class IoTDBHistoryPullConsumerDataSetIT extends AbstractSubscriptionRegre private String pattern = device + ".s_0"; // private String topicName = "`1-group.1-consumer.ts`"; private String topicName = "topic_HistoryPullConsumerDataSet"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBRealTimePullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBRealTimePullConsumerDataSetIT.java index 6c06af9bc2ce..b3b73d21766c 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBRealTimePullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBRealTimePullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -50,7 +49,7 @@ public class IoTDBRealTimePullConsumerDataSetIT extends AbstractSubscriptionRegr private String device = database + ".d_0"; private String pattern = device + ".s_0"; private String topicName = "topic_RealTimePullConsumerDataSet"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangeAccuratePullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangeAccuratePullConsumerDataSetIT.java index 5694ae3ce873..1c21a3a3eb97 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangeAccuratePullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangeAccuratePullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -50,7 +49,7 @@ public class IoTDBTimeRangeAccuratePullConsumerDataSetIT extends AbstractSubscri private String device = database + ".d_0"; private String pattern = device + ".s_0"; private String topicName = "topic_TimeRangeAccuratePullConsumerDataSet"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangePullConsumerDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangePullConsumerDataSetIT.java index cabdaaecfc65..66b57279fa2f 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangePullConsumerDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangePullConsumerDataSetIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -53,7 +52,7 @@ public class IoTDBTimeRangePullConsumerDataSetIT extends AbstractSubscriptionReg private String device = database + ".d_0"; private String pattern = device + ".s_0"; private String topicName = "topic_TimeRangePullConsumerDataSet"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeDataSetIT.java index 9d94b4ee2ac7..f8c446c1182a 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeDataSetIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBTestPushConsumeDataSetIT extends AbstractSubscriptionRegressionIT { private static final String database = "root.test.TestPushConsumeDataSet"; private static final String topicName = "topic_TestPushConsumeDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = "root.**"; private static SubscriptionPushConsumer consumer; private static final String device = database + ".d_push_dataset"; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeNoTargetDirTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeNoTargetDirTsfileIT.java index bd82db79f509..182ba3c3a00b 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeNoTargetDirTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeNoTargetDirTsfileIT.java @@ -37,7 +37,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -67,7 +66,7 @@ public class IoTDBTestPushConsumeNoTargetDirTsfileIT extends AbstractSubscriptio private static final String database = "root.test.TestPushConsumeNoTargetDirTsfile"; private static final String device = database + ".d_0"; private static final String topicName = "topic_TestPushConsumeNoTargetDirTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = database + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeTsfileIT.java index ff9850863674..9c43e976f3e9 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeTsfileIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -65,7 +64,7 @@ public class IoTDBTestPushConsumeTsfileIT extends AbstractSubscriptionRegression private static final String database = "root.test.TestPushConsumeTsfile"; private static final String device = database + ".d_0"; private static final String topicName = "topic_TestPushConsumeTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = database + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerIT.java index 89b9c1dd3722..6a34c24f0817 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -64,7 +63,7 @@ public class IoTDBLooseAllTsDatasetPushConsumerIT extends AbstractSubscriptionRe private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_LooseAllTsDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = device + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerSnapshotIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerSnapshotIT.java index 429dc925d1e6..0204d2510993 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerSnapshotIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerSnapshotIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -64,7 +63,7 @@ public class IoTDBLooseAllTsDatasetPushConsumerSnapshotIT extends AbstractSubscr private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_LooseAllTsDatasetPushConsumerSnapshot"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = device + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsfilePushConsumerIT.java index cf42e04564ab..4b0adb059e4a 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsfilePushConsumerIT.java @@ -39,7 +39,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -70,7 +69,7 @@ public class IoTDBLooseAllTsfilePushConsumerIT extends AbstractSubscriptionRegre private String device2 = database + ".d_1"; private String pattern = database + ".**"; private String topicName = "topic_LooseAllTsfilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseDeviceTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseDeviceTsfilePushConsumerIT.java index f3c905ff00de..878608c16f57 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseDeviceTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseDeviceTsfilePushConsumerIT.java @@ -39,7 +39,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -69,7 +68,7 @@ public class IoTDBPathLooseDeviceTsfilePushConsumerIT extends AbstractSubscripti private String device2 = database + ".d_1"; private String pattern = device + ".**"; private String topicName = "topic_PathLooseDeviceTsfilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsDatasetPushConsumerIT.java index 532871c4e95d..e441a853e161 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsDatasetPushConsumerIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -64,7 +63,7 @@ public class IoTDBPathLooseTsDatasetPushConsumerIT extends AbstractSubscriptionR private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_PathLooseTsDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = database + ".d_0.s_0"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsfilePushConsumerIT.java index 33b063815184..157212cb1788 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsfilePushConsumerIT.java @@ -39,7 +39,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -66,7 +65,7 @@ public class IoTDBPathLooseTsfilePushConsumerIT extends AbstractSubscriptionRegr private String device2 = database + ".d_1"; private String pattern = database + ".**"; private String topicName = "topic_PathLooseTsfilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathTsLooseDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathTsLooseDatasetPushConsumerIT.java index f82a6e778140..0ad43be14617 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathTsLooseDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathTsLooseDatasetPushConsumerIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -62,7 +61,7 @@ public class IoTDBPathTsLooseDatasetPushConsumerIT extends AbstractSubscriptionR private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_PathTsLooseDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = database + ".d_0.s_0"; public static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsDatasetPushConsumerIT.java index 2a906df5bf32..9d366f3d9b28 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsDatasetPushConsumerIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -65,7 +64,7 @@ public class IoTDBTimeLooseTsDatasetPushConsumerIT extends AbstractSubscriptionR private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_TimeLooseTsDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static String pattern = device + ".s_0"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsTsfilePushConsumerIT.java index 8fede43146e9..a3dd38dea192 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsTsfilePushConsumerIT.java @@ -39,7 +39,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -69,7 +68,7 @@ public class IoTDBTimeLooseTsTsfilePushConsumerIT extends AbstractSubscriptionRe private String device2 = database + ".d_1"; private String pattern = device + ".s_0"; private String topicName = "topic_TimeLooseTsTsfilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsfilePushConsumerIT.java index da1bc086088f..1057c268d6b8 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsfilePushConsumerIT.java @@ -39,7 +39,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -63,7 +62,7 @@ public class IoTDBTimeLooseTsfilePushConsumerIT extends AbstractSubscriptionRegr private String device2 = database + ".d_1"; private String pattern = device + ".**"; private String topicName = "topic_TimeLooseTsfilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeTsLooseDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeTsLooseDatasetPushConsumerIT.java index edf29e15c789..f5e98108d8c0 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeTsLooseDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeTsLooseDatasetPushConsumerIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -64,7 +63,7 @@ public class IoTDBTimeTsLooseDatasetPushConsumerIT extends AbstractSubscriptionR private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_TimeTsLooseDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = device + ".s_0"; public static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternDatasetPushConsumerIT.java index 55ea6ba9a9a7..3e45c599a8a9 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternDatasetPushConsumerIT.java @@ -35,7 +35,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -62,7 +61,7 @@ public class IoTDBSnapshotTSPatternDatasetPushConsumerIT extends AbstractSubscri private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_SnapshotTSPatternDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = device + ".s_0"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternTsfilePushConsumerIT.java index 4f45d79bf5e0..3197d343456a 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternTsfilePushConsumerIT.java @@ -39,7 +39,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -69,7 +68,7 @@ public class IoTDBSnapshotTSPatternTsfilePushConsumerIT extends AbstractSubscrip private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_SnapshotTSPatternTsfilePushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = device + ".s_0"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java index 9b1b4d63f241..e59088d6a287 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -61,7 +60,7 @@ public class IoTDBConsumer2With1TopicShareProcessDataSetIT private static final String database = "root.test.Consumer2With1TopicShareProcessDataSet"; private static final String device = database + ".d_0"; private static final String topicName = "topic_Consumer2With1TopicShareProcessDataSet"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = database + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java index a49b05c98514..cd33091e4a08 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -64,7 +63,7 @@ public class IoTDBConsumer2With1TopicShareProcessTsfileIT extends AbstractSubscr private static final String database = "root.test.Consumer2With1TopicShareProcessTsfile"; private static final String device = database + ".d_0"; private static final String topicName = "topic_Consumer2With1TopicShareProcessTsfile"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = database + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java index b43f35220c14..d573afce21eb 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java @@ -37,7 +37,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -74,7 +73,7 @@ public class IoTDBMultiGroupVsMultiConsumerIT extends AbstractSubscriptionRegres private String databasePrefix = "root.test.pushMultiGroupVsMultiConsumer_"; private int tsCount = 10; private int consumertCount = 10; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private List consumers = new ArrayList<>(consumertCount); private AtomicInteger rowCount00 = new AtomicInteger(0); diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java index 733d94771b94..31eecb78d04b 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBOneConsumerMultiTopicsDatasetIT extends AbstractSubscriptionRe private static final String database2 = "root.OneConsumerMultiTopicsDataset"; private static final String device = database + ".d_0"; private static final String topicName = "topic_OneConsumerMultiTopicsDataset_1"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private String pattern = database + ".**"; private String pattern2 = database2 + ".**"; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java index c13986a693dc..00a3a973b110 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java @@ -40,7 +40,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -71,7 +70,7 @@ public class IoTDBOneConsumerMultiTopicsMixIT extends AbstractSubscriptionRegres private String pattern2 = database2 + ".**"; private String device2 = database2 + ".d_0"; private String topicName2 = "topic_OneConsumerMultiTopicsMix_2"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java index b19aa314f702..23e9484a9f4b 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -69,7 +68,7 @@ public class IoTDBOneConsumerMultiTopicsTsfileIT extends AbstractSubscriptionReg private String pattern2 = database2 + ".**"; private String device2 = database2 + ".d_0"; private String topicName2 = "topic_OneConsumerMultiTopicsTsfile_2"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternDatasetPushConsumerIT.java index 00a8a955ee56..0cdf6f99fb4b 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternDatasetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -61,7 +60,7 @@ public class IoTDBDBPatternDatasetPushConsumerIT extends AbstractSubscriptionReg private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_DBPatternDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static String pattern = database + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternTsfilePushConsumerIT.java index edaee6346313..4f5e5ce26634 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternTsfilePushConsumerIT.java @@ -37,7 +37,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -66,7 +65,7 @@ public class IoTDBDBPatternTsfilePushConsumerIT extends AbstractSubscriptionRegr private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_DBPatternTsfilePushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static String pattern = database + ".**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDefaultPatternTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDefaultPatternTsfilePushConsumerIT.java index b518ab08cb46..d3353532d23d 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDefaultPatternTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDefaultPatternTsfilePushConsumerIT.java @@ -37,7 +37,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -66,7 +65,7 @@ public class IoTDBDefaultPatternTsfilePushConsumerIT extends AbstractSubscriptio private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_DefaultPatternTsfilePushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternDatasetPushConsumerIT.java index eab557d76644..f837074051ce 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternDatasetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -61,7 +60,7 @@ public class IoTDBDevicePatternDatasetPushConsumerIT extends AbstractSubscriptio private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_DevicePatternDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static String pattern = database + ".d_0.**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternTsfilePushConsumerIT.java index b435e9a04f1d..86485f20021e 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternTsfilePushConsumerIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -67,7 +66,7 @@ public class IoTDBDevicePatternTsfilePushConsumerIT extends AbstractSubscription private static final String database2 = "root.DevicePatternTsfilePushConsumer"; private static final String device = database + ".d_0"; private static final String topicName = "topic_DevicePatternTsfilePushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static String pattern = device + ".**"; private SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBRootPatternDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBRootPatternDatasetPushConsumerIT.java index de97d2ba747e..757857edab4f 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBRootPatternDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBRootPatternDatasetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -61,7 +60,7 @@ public class IoTDBRootPatternDatasetPushConsumerIT extends AbstractSubscriptionR private static final String device = database + ".d_0"; private static final String device2 = database + ".d_1"; private static final String topicName = "topic_RootPatternDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = "root.**"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternDatasetPushConsumerIT.java index 48554ebf74ab..2133d40066f6 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternDatasetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBTSPatternDatasetPushConsumerIT extends AbstractSubscriptionReg private static final String database2 = "root.TSPatternDatasetPushConsumer"; private static final String device = database + ".d_0"; private static final String topicName = "topic_TSPatternDatasetPushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static String pattern = database + ".d_0.s_0"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternTsfilePushConsumerIT.java index de2ffd4c3fad..96e549a2334d 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternTsfilePushConsumerIT.java @@ -37,7 +37,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -66,7 +65,7 @@ public class IoTDBTSPatternTsfilePushConsumerIT extends AbstractSubscriptionRegr private static final String database2 = "root.TSPatternTsfilePushConsumer"; private static final String device = database + ".d_0"; private static final String topicName = "topic_TSPatternTsfilePushConsumer"; - private static List schemaList = new ArrayList<>(); + private static List schemaList = new ArrayList<>(); private static final String pattern = device + ".s_0"; private static SubscriptionPushConsumer consumer; diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootDatasetPushConsumerIT.java index beb68426c2b8..01355f357392 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootDatasetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBHistoryRootDatasetPushConsumerIT extends AbstractSubscriptionR private String device = database + ".d_0"; private String pattern = "root.**"; private String topicName = "topic_HistoryRootDatasetPushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootTsFilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootTsFilePushConsumerIT.java index 63502b0ce185..8319ba6c6c0c 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootTsFilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootTsFilePushConsumerIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -65,7 +64,7 @@ public class IoTDBHistoryRootTsFilePushConsumerIT extends AbstractSubscriptionRe private String device = database + ".d_0"; private String pattern = "root.**"; private String topicName = "topic_HistoryRootTsFilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBDatasetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBDatasetPushConsumerIT.java index c7c7edcfc43b..1eedaa71ef2e 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBDatasetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBDatasetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -55,7 +54,7 @@ public class IoTDBRealTimeDBDatasetPushConsumerIT extends AbstractSubscriptionRe private String device = database + ".d_0"; private String pattern = database + ".**"; private String topicName = "topic_RealTimeDBDatasetPushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBTsfilePushConsumerIT.java index ce0896998932..9e73b77d7cd1 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBTsfilePushConsumerIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -60,7 +59,7 @@ public class IoTDBRealTimeDBTsfilePushConsumerIT extends AbstractSubscriptionReg private String device = database + ".d_0"; private String pattern = database + ".**"; private String topicName = "topic_RealTimeDBTsfilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeAccurateDBDataSetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeAccurateDBDataSetPushConsumerIT.java index a70cd9431e01..c431599aeced 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeAccurateDBDataSetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeAccurateDBDataSetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -56,7 +55,7 @@ public class IoTDBTimeRangeAccurateDBDataSetPushConsumerIT private String device = database + ".d_0"; private String pattern = database + ".**"; private String topicName = "topic_TimeRangeAccurateDBDataSetPushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBDataSetPushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBDataSetPushConsumerIT.java index 14dc033fb042..b9d2368188c2 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBDataSetPushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBDataSetPushConsumerIT.java @@ -34,7 +34,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -58,7 +57,7 @@ public class IoTDBTimeRangeDBDataSetPushConsumerIT extends AbstractSubscriptionR private String device = database + ".d_0"; private String pattern = database + ".**"; private String topicName = "topic_TimeRangeDBDataSetPushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBTsfilePushConsumerIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBTsfilePushConsumerIT.java index bdedda0aa088..cccad773623e 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBTsfilePushConsumerIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBTsfilePushConsumerIT.java @@ -38,7 +38,6 @@ import org.apache.tsfile.read.expression.QueryExpression; import org.apache.tsfile.read.query.dataset.QueryDataSet; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -63,7 +62,7 @@ public class IoTDBTimeRangeDBTsfilePushConsumerIT extends AbstractSubscriptionRe private String device = database + ".d_0"; private String pattern = database + ".**"; private String topicName = "topic_TimeRangeDBTsfilePushConsumer"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPushConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java index cac85058dda6..19ee191d1c7a 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -53,7 +52,7 @@ public class IoTDBDataSet1TopicConsumerSpecialIT extends AbstractSubscriptionReg private String device = database + ".`#01`"; private String pattern = device + ".`ABH#01`"; private String topicName = "topic_DataSet1TopicConsumerSpecial"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override diff --git a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBTestTopicNameIT.java b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBTestTopicNameIT.java index a0bd8d6a038f..f80a819bf5c5 100644 --- a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBTestTopicNameIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBTestTopicNameIT.java @@ -31,7 +31,6 @@ import org.apache.tsfile.file.metadata.enums.CompressionType; import org.apache.tsfile.file.metadata.enums.TSEncoding; import org.apache.tsfile.write.record.Tablet; -import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Before; @@ -53,7 +52,7 @@ public class IoTDBTestTopicNameIT extends AbstractSubscriptionRegressionIT { private String device = database + ".d_0"; private String pattern = device + ".s_0"; private String topicName = "`1-group.1-consumer.ts.topic`"; - private List schemaList = new ArrayList<>(); + private List schemaList = new ArrayList<>(); private SubscriptionPullConsumer consumer; @Override