This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch
4194-checkstyle-not-consistently-enforced-in-validate-across-all-modules
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/4194-checkstyle-not-consistently-enforced-in-validate-across-all-modules
by this push:
new 4d752508a7 refactor(#4194): Clean up imports and improve code
formatting in various classes
4d752508a7 is described below
commit 4d752508a70bcdcaecfa75053a6767059aafcefb
Author: Philipp Zehnder <[email protected]>
AuthorDate: Mon Feb 23 10:27:01 2026 +0100
refactor(#4194): Clean up imports and improve code formatting in various
classes
---
.../dataexplorer/export/objectstorage/IObjectStorage.java | 3 ++-
.../dataexplorer/export/objectstorage/LocalFolder.java | 1 +
.../streampipes/dataexplorer/export/objectstorage/S3.java | 4 +---
.../export/objectstorage/TestExportProviderConnection.java | 4 +---
.../dataexplorer/export/TestJsonItemGenerator.java | 5 ++---
.../dataexplorer/influx/DataLakeInfluxQueryBuilder.java | 2 +-
.../dataexplorer/influx/SelectQueryParamsTest.java | 2 +-
.../dataexplorer/iotdb/DataExplorerIotDbQueryExecutor.java | 11 ++++++-----
.../dataexplorer/iotdb/DataExplorerQueryManagementIotDb.java | 1 +
.../dataexplorer/iotdb/IotDbPropertyConverter.java | 12 +++++++-----
.../streampipes/dataexplorer/iotdb/IotDbSessionProvider.java | 3 ++-
.../dataexplorer/iotdb/TimeSeriesStorageIotDb.java | 7 ++++---
.../sanitize/DataLakeMeasurementSanitizerIotDbTest.java | 1 +
.../connectors/opcua/config/identity/X509IdentityConfig.java | 4 ++--
.../connectors/plc/adapter/ConnectionContainerReproTest.java | 10 ++++++----
.../streampipes/connectors/ros/sink/RosBridgeSink.java | 2 +-
.../connectors/tubemq/sink/TubeMQPublisherSink.java | 2 +-
17 files changed, 40 insertions(+), 34 deletions(-)
diff --git
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/IObjectStorage.java
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/IObjectStorage.java
index 31fb06e7d1..38d3556931 100644
---
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/IObjectStorage.java
+++
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/IObjectStorage.java
@@ -1,4 +1,4 @@
-/**
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -24,5 +24,6 @@ import java.io.IOException;
public interface IObjectStorage {
void store(StreamingResponseBody datastream) throws IOException;
+
String getFileName();
}
diff --git
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/LocalFolder.java
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/LocalFolder.java
index 59da9d4376..573470a6cc 100644
---
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/LocalFolder.java
+++
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/LocalFolder.java
@@ -19,6 +19,7 @@
package org.apache.streampipes.dataexplorer.export.objectstorage;
import org.apache.streampipes.commons.environment.Environments;
+
import
org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
import java.io.FileOutputStream;
diff --git
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/S3.java
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/S3.java
index 7e83a1a5c4..84cacccc0d 100644
---
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/S3.java
+++
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/S3.java
@@ -17,10 +17,10 @@
*/
package org.apache.streampipes.dataexplorer.export.objectstorage;
-
import org.apache.streampipes.model.configuration.ExportProviderSettings;
import
org.apache.streampipes.user.management.encryption.SecretEncryptionManager;
+import
org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.core.sync.RequestBody;
@@ -28,8 +28,6 @@ import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;
import software.amazon.awssdk.services.s3.model.PutObjectRequest;
-import
org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
-
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.net.URI;
diff --git
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/TestExportProviderConnection.java
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/TestExportProviderConnection.java
index b0304baa46..6752d46b70 100644
---
a/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/TestExportProviderConnection.java
+++
b/streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/TestExportProviderConnection.java
@@ -18,19 +18,17 @@
package org.apache.streampipes.dataexplorer.export.objectstorage;
-
import org.apache.streampipes.model.configuration.ExportProviderSettings;
import org.apache.streampipes.model.configuration.ProviderType;
import
org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
import java.io.ByteArrayInputStream;
-import java.io.InputStream;
import java.io.IOException;
+import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;
-
public class TestExportProviderConnection {
public static Map<String, Object> connectionTest(ExportProviderSettings
setting) throws Exception {
diff --git
a/streampipes-data-explorer-export/src/test/java/org/apache/streampipes/dataexplorer/export/TestJsonItemGenerator.java
b/streampipes-data-explorer-export/src/test/java/org/apache/streampipes/dataexplorer/export/TestJsonItemGenerator.java
index 95b56284f8..fa4cb8a728 100644
---
a/streampipes-data-explorer-export/src/test/java/org/apache/streampipes/dataexplorer/export/TestJsonItemGenerator.java
+++
b/streampipes-data-explorer-export/src/test/java/org/apache/streampipes/dataexplorer/export/TestJsonItemGenerator.java
@@ -21,14 +21,13 @@ package org.apache.streampipes.dataexplorer.export;
import org.apache.streampipes.dataexplorer.export.item.JsonItemGenerator;
import org.apache.streampipes.serializers.json.JacksonSerializer;
+import com.fasterxml.jackson.databind.DeserializationFeature;
import org.junit.jupiter.api.Test;
-import com.fasterxml.jackson.databind.DeserializationFeature;
+import java.util.Map;
import static org.junit.jupiter.api.Assertions.assertEquals;
-import java.util.Map;
-
public class TestJsonItemGenerator extends TestItemGenerator {
private static final String Expected = "{\"time\": 1668578077051,\"string\":
\"test\",\"number\": 1}";
diff --git
a/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/DataLakeInfluxQueryBuilder.java
b/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/DataLakeInfluxQueryBuilder.java
index 24f552ea24..ac17abee90 100644
---
a/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/DataLakeInfluxQueryBuilder.java
+++
b/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/DataLakeInfluxQueryBuilder.java
@@ -20,10 +20,10 @@ package org.apache.streampipes.dataexplorer.influx;
import org.apache.streampipes.commons.environment.Environment;
import org.apache.streampipes.commons.environment.Environments;
+import org.apache.streampipes.dataexplorer.api.IDataLakeQueryBuilder;
import org.apache.streampipes.model.datalake.AggregationFunction;
import org.apache.streampipes.model.datalake.DataLakeQueryOrdering;
import org.apache.streampipes.model.datalake.FilterCondition;
-import org.apache.streampipes.dataexplorer.api.IDataLakeQueryBuilder;
import org.influxdb.dto.Query;
import org.influxdb.querybuilder.Ordering;
diff --git
a/streampipes-data-explorer-influx/src/test/java/org/apache/streampipes/dataexplorer/influx/SelectQueryParamsTest.java
b/streampipes-data-explorer-influx/src/test/java/org/apache/streampipes/dataexplorer/influx/SelectQueryParamsTest.java
index 828ed2304c..104097ce73 100644
---
a/streampipes-data-explorer-influx/src/test/java/org/apache/streampipes/dataexplorer/influx/SelectQueryParamsTest.java
+++
b/streampipes-data-explorer-influx/src/test/java/org/apache/streampipes/dataexplorer/influx/SelectQueryParamsTest.java
@@ -18,9 +18,9 @@
package org.apache.streampipes.dataexplorer.influx;
+import
org.apache.streampipes.dataexplorer.influx.utils.ProvidedQueryParameterBuilder;
import
org.apache.streampipes.dataexplorer.param.ProvidedRestQueryParamConverter;
import org.apache.streampipes.dataexplorer.param.SelectQueryParams;
-import
org.apache.streampipes.dataexplorer.influx.utils.ProvidedQueryParameterBuilder;
import org.junit.jupiter.api.Test;
diff --git
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerIotDbQueryExecutor.java
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerIotDbQueryExecutor.java
index 9622aebd48..7cf2b9dcaa 100644
---
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerIotDbQueryExecutor.java
+++
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerIotDbQueryExecutor.java
@@ -18,16 +18,17 @@
package org.apache.streampipes.dataexplorer.iotdb;
-import org.apache.iotdb.isession.pool.SessionDataSetWrapper;
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.pool.SessionPool;
import org.apache.streampipes.commons.exceptions.SpRuntimeException;
import org.apache.streampipes.dataexplorer.param.DeleteQueryParams;
import org.apache.streampipes.dataexplorer.param.SelectQueryParams;
import org.apache.streampipes.dataexplorer.query.DataExplorerQueryExecutor;
import org.apache.streampipes.model.datalake.DataLakeMeasure;
import org.apache.streampipes.model.datalake.SpQueryResult;
+
+import org.apache.iotdb.isession.pool.SessionDataSetWrapper;
+import org.apache.iotdb.rpc.IoTDBConnectionException;
+import org.apache.iotdb.rpc.StatementExecutionException;
+import org.apache.iotdb.session.pool.SessionPool;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -93,4 +94,4 @@ public class DataExplorerIotDbQueryExecutor extends
DataExplorerQueryExecutor<St
var deleteTimeSeriesQuery = "DELETE timeseries
root.streampipes.%s.*".formatted(measure.getMeasureName());
return executeNonQueryStatement(deleteTimeSeriesQuery);
}
-}
\ No newline at end of file
+}
diff --git
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerQueryManagementIotDb.java
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerQueryManagementIotDb.java
index dfc88efea8..9ce1901fae 100644
---
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerQueryManagementIotDb.java
+++
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/DataExplorerQueryManagementIotDb.java
@@ -23,6 +23,7 @@ import
org.apache.streampipes.dataexplorer.api.IDataExplorerSchemaManagement;
import org.apache.streampipes.dataexplorer.export.OutputFormat;
import org.apache.streampipes.model.datalake.SpQueryResult;
import org.apache.streampipes.model.datalake.param.ProvidedRestQueryParams;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbPropertyConverter.java
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbPropertyConverter.java
index 4bb46a2cfd..46b3e6a0c9 100644
---
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbPropertyConverter.java
+++
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbPropertyConverter.java
@@ -18,7 +18,6 @@
package org.apache.streampipes.dataexplorer.iotdb;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.streampipes.commons.exceptions.SpRuntimeException;
import org.apache.streampipes.model.runtime.field.PrimitiveField;
import org.apache.streampipes.model.schema.EventProperty;
@@ -26,6 +25,8 @@ import
org.apache.streampipes.model.schema.EventPropertyPrimitive;
import org.apache.streampipes.vocabulary.SO;
import org.apache.streampipes.vocabulary.XSD;
+import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
+
/**
* Converts StreamPipes {@link EventProperty} into {@link
IotDbMeasurementRecord}s.
*/
@@ -57,13 +58,13 @@ public class IotDbPropertyConverter {
} else if (XSD.FLOAT.toString().equals(runtimeType)) {
iotDbType = TSDataType.FLOAT;
value = primitiveField.getAsFloat();
- }else if (XSD.DOUBLE.toString().equals(runtimeType) ||
SO.NUMBER.equals(runtimeType)) {
+ } else if (XSD.DOUBLE.toString().equals(runtimeType) ||
SO.NUMBER.equals(runtimeType)) {
iotDbType = TSDataType.DOUBLE;
value = primitiveField.getAsDouble();
} else if (XSD.BOOLEAN.toString().equals(runtimeType)) {
iotDbType = TSDataType.BOOLEAN;
value = primitiveField.getAsBoolean();
- } else if (XSD.STRING.toString().equals(runtimeType)){
+ } else if (XSD.STRING.toString().equals(runtimeType)) {
iotDbType = TSDataType.TEXT;
value = primitiveField.getAsString();
} else {
@@ -84,7 +85,8 @@ public class IotDbPropertyConverter {
public IotDbMeasurementRecord convertNonPrimitiveProperty(
EventProperty eventProperty,
String sanitizedRuntimeName) throws SpRuntimeException {
- throw new SpRuntimeException("Handling non-primitive event properties is
not yet supported " +
- "when using IoTDB as time series store.");
+ throw new SpRuntimeException(
+ "Handling non-primitive event properties is not yet supported "
+ + "when using IoTDB as time series store.");
}
}
diff --git
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbSessionProvider.java
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbSessionProvider.java
index 6ff4bc38ca..c0457d48ff 100644
---
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbSessionProvider.java
+++
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/IotDbSessionProvider.java
@@ -18,9 +18,10 @@
package org.apache.streampipes.dataexplorer.iotdb;
-import org.apache.iotdb.session.pool.SessionPool;
import org.apache.streampipes.commons.environment.Environment;
+import org.apache.iotdb.session.pool.SessionPool;
+
/**
* This class provides a method to retrieve a session pool for IoT DB
operations based on the given environment configuration.
*/
diff --git
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/TimeSeriesStorageIotDb.java
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/TimeSeriesStorageIotDb.java
index c233580d1f..891fa881bb 100644
---
a/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/TimeSeriesStorageIotDb.java
+++
b/streampipes-data-explorer-iotdb/src/main/java/org/apache/streampipes/dataexplorer/iotdb/TimeSeriesStorageIotDb.java
@@ -18,9 +18,6 @@
package org.apache.streampipes.dataexplorer.iotdb;
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.pool.SessionPool;
import org.apache.streampipes.commons.environment.Environments;
import org.apache.streampipes.commons.exceptions.SpRuntimeException;
import org.apache.streampipes.dataexplorer.TimeSeriesStorage;
@@ -28,6 +25,10 @@ import
org.apache.streampipes.dataexplorer.iotdb.sanitize.IotDbNameSanitizer;
import org.apache.streampipes.model.datalake.DataLakeMeasure;
import org.apache.streampipes.model.runtime.Event;
import org.apache.streampipes.model.schema.EventPropertyPrimitive;
+
+import org.apache.iotdb.rpc.IoTDBConnectionException;
+import org.apache.iotdb.rpc.StatementExecutionException;
+import org.apache.iotdb.session.pool.SessionPool;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/streampipes-data-explorer-iotdb/src/test/java/org/apache/streampipes/dataexplorer/iotdb/sanitize/DataLakeMeasurementSanitizerIotDbTest.java
b/streampipes-data-explorer-iotdb/src/test/java/org/apache/streampipes/dataexplorer/iotdb/sanitize/DataLakeMeasurementSanitizerIotDbTest.java
index 12e491637d..260023aff3 100644
---
a/streampipes-data-explorer-iotdb/src/test/java/org/apache/streampipes/dataexplorer/iotdb/sanitize/DataLakeMeasurementSanitizerIotDbTest.java
+++
b/streampipes-data-explorer-iotdb/src/test/java/org/apache/streampipes/dataexplorer/iotdb/sanitize/DataLakeMeasurementSanitizerIotDbTest.java
@@ -22,6 +22,7 @@ import org.apache.streampipes.client.api.IStreamPipesClient;
import org.apache.streampipes.model.datalake.DataLakeMeasure;
import org.apache.streampipes.test.generator.EventPropertyPrimitiveTestBuilder;
import org.apache.streampipes.test.generator.EventSchemaTestBuilder;
+
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
diff --git
a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/X509IdentityConfig.java
b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/X509IdentityConfig.java
index 1b79459586..19509c6744 100644
---
a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/X509IdentityConfig.java
+++
b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/X509IdentityConfig.java
@@ -91,8 +91,8 @@ public class X509IdentityConfig implements IdentityConfig {
}
}
throw new IllegalArgumentException(
- "Unsupported or invalid PKCS#8 private key. " +
- "Make sure it is an unencrypted PKCS#8 key (BEGIN PRIVATE KEY).");
+ "Unsupported or invalid PKCS#8 private key. "
+ + "Make sure it is an unencrypted PKCS#8 key (BEGIN PRIVATE
KEY).");
}
private static byte[] extractPemBlock(String pem, String type) {
diff --git
a/streampipes-extensions/streampipes-connectors-plc/src/test/java/org/apache/streampipes/extensions/connectors/plc/adapter/ConnectionContainerReproTest.java
b/streampipes-extensions/streampipes-connectors-plc/src/test/java/org/apache/streampipes/extensions/connectors/plc/adapter/ConnectionContainerReproTest.java
index 8dfc646e06..aa96155be1 100644
---
a/streampipes-extensions/streampipes-connectors-plc/src/test/java/org/apache/streampipes/extensions/connectors/plc/adapter/ConnectionContainerReproTest.java
+++
b/streampipes-extensions/streampipes-connectors-plc/src/test/java/org/apache/streampipes/extensions/connectors/plc/adapter/ConnectionContainerReproTest.java
@@ -34,7 +34,6 @@ import org.apache.plc4x.java.api.messages.PlcWriteRequest;
import org.apache.plc4x.java.api.metadata.PlcConnectionMetadata;
import org.apache.plc4x.java.api.model.PlcTag;
import org.apache.plc4x.java.api.value.PlcValue;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import java.time.Duration;
@@ -43,7 +42,6 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicInteger;
import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -60,8 +58,12 @@ class ConnectionContainerReproTest {
@Override
public PlcConnection getConnection(String url) throws
PlcConnectionException {
int n = calls.getAndIncrement();
- if (n == 0) return c1; // initial success
- if (n == 1) throw new PlcConnectionException("PLC down"); // reconnect
fails once
+ if (n == 0) {
+ return c1; // initial success
+ }
+ if (n == 1) {
+ throw new PlcConnectionException("PLC down"); // reconnect fails once
+ }
return c2; // would succeed later
}
diff --git
a/streampipes-extensions/streampipes-connectors-ros/src/main/java/org/apache/streampipes/connectors/ros/sink/RosBridgeSink.java
b/streampipes-extensions/streampipes-connectors-ros/src/main/java/org/apache/streampipes/connectors/ros/sink/RosBridgeSink.java
index 4e5e9c6393..98df739af2 100644
---
a/streampipes-extensions/streampipes-connectors-ros/src/main/java/org/apache/streampipes/connectors/ros/sink/RosBridgeSink.java
+++
b/streampipes-extensions/streampipes-connectors-ros/src/main/java/org/apache/streampipes/connectors/ros/sink/RosBridgeSink.java
@@ -18,8 +18,8 @@
package org.apache.streampipes.connectors.ros.sink;
-import org.apache.streampipes.dataformat.SpDataFormatDefinition;
import org.apache.streampipes.dataformat.JsonDataFormatDefinition;
+import org.apache.streampipes.dataformat.SpDataFormatDefinition;
import org.apache.streampipes.extensions.api.pe.IStreamPipesDataSink;
import org.apache.streampipes.extensions.api.pe.config.IDataSinkConfiguration;
import
org.apache.streampipes.extensions.api.pe.context.EventSinkRuntimeContext;
diff --git
a/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/sink/TubeMQPublisherSink.java
b/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/sink/TubeMQPublisherSink.java
index 1037c26ec2..93f088cffb 100644
---
a/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/sink/TubeMQPublisherSink.java
+++
b/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/sink/TubeMQPublisherSink.java
@@ -19,8 +19,8 @@
package org.apache.streampipes.extensions.connectors.tubemq.sink;
import org.apache.streampipes.commons.exceptions.SpRuntimeException;
-import org.apache.streampipes.dataformat.SpDataFormatDefinition;
import org.apache.streampipes.dataformat.JsonDataFormatDefinition;
+import org.apache.streampipes.dataformat.SpDataFormatDefinition;
import org.apache.streampipes.extensions.api.pe.IStreamPipesDataSink;
import org.apache.streampipes.extensions.api.pe.config.IDataSinkConfiguration;
import
org.apache.streampipes.extensions.api.pe.context.EventSinkRuntimeContext;
