fix java spotless check

datahub-project · Nov 5, 2024 · c5dde57 · c5dde57
1 parent 27b72af
commit c5dde57
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 21 deletions.
diff --git a/...integration/java/acryl-spark-lineage/src/main/java/datahub/spark/DatahubEventEmitter.java b/...integration/java/acryl-spark-lineage/src/main/java/datahub/spark/DatahubEventEmitter.java
@@ -83,9 +83,9 @@ private Optional<Emitter> getEmitter() {
         try {
           emitter =
               Optional.of(
-                      new KafkaEmitter(
-                              datahubKafkaEmitterConfig.getKafkaEmitterConfig(),
-                              datahubKafkaEmitterConfig.getMcpTopic()));
+                  new KafkaEmitter(
+                      datahubKafkaEmitterConfig.getKafkaEmitterConfig(),
+                      datahubKafkaEmitterConfig.getMcpTopic()));
         } catch (IOException e) {
           throw new RuntimeException(e);
         }

diff --git a/...ntegration/java/acryl-spark-lineage/src/main/java/datahub/spark/DatahubSparkListener.java b/...ntegration/java/acryl-spark-lineage/src/main/java/datahub/spark/DatahubSparkListener.java
@@ -191,8 +191,7 @@ public Optional<DatahubEmitterConfig> initializeEmitter(Config sparkConf) {
         if (sparkConf.hasPath(SparkConfigParser.KAFKA_MCP_TOPIC)) {
           String mcpTopic = sparkConf.getString(SparkConfigParser.KAFKA_MCP_TOPIC);
           return Optional.of(new KafkaDatahubEmitterConfig(kafkaEmitterConfig.build(), mcpTopic));
-        }
-        else {
+        } else {
           return Optional.of(new KafkaDatahubEmitterConfig(kafkaEmitterConfig.build()));
         }
       case "file":

diff --git a/.../java/acryl-spark-lineage/src/main/java/datahub/spark/conf/KafkaDatahubEmitterConfig.java b/.../java/acryl-spark-lineage/src/main/java/datahub/spark/conf/KafkaDatahubEmitterConfig.java
@@ -19,8 +19,7 @@ public KafkaDatahubEmitterConfig(KafkaEmitterConfig kafkaEmitterConfig) {
     this.mcpTopic = KafkaEmitter.DEFAULT_MCP_KAFKA_TOPIC;
   }
 
-  public KafkaDatahubEmitterConfig(KafkaEmitterConfig kafkaEmitterConfig,
-                                   String mcpTopic) {
+  public KafkaDatahubEmitterConfig(KafkaEmitterConfig kafkaEmitterConfig, String mcpTopic) {
     this.kafkaEmitterConfig = kafkaEmitterConfig;
     this.mcpTopic = mcpTopic;
   }

diff --git a/...data-integration/java/datahub-client/src/main/java/datahub/client/kafka/KafkaEmitter.java b/...data-integration/java/datahub-client/src/main/java/datahub/client/kafka/KafkaEmitter.java
@@ -36,31 +36,29 @@ public class KafkaEmitter implements Emitter {
   /**
    * The default constructor
    *
-   * @param config
-   * @throws IOException
+   * @param config KafkaEmitterConfig
+   * @throws IOException when Avro Serialization fails
    */
   public KafkaEmitter(KafkaEmitterConfig config) throws IOException {
     this(config, DEFAULT_MCP_KAFKA_TOPIC);
   }
 
   /**
-   * Constructor that takes in KafkaEmitterConfig
-   * and mcp Kafka Topic Name
+   * Constructor that takes in KafkaEmitterConfig and mcp Kafka Topic Name
    *
-   * @param config
-   * @throws IOException
+   * @param config KafkaEmitterConfig
+   * @throws IOException when Avro Serialization fails
    */
-  public KafkaEmitter(KafkaEmitterConfig config,
-                      String mcpKafkaTopic) throws IOException {
+  public KafkaEmitter(KafkaEmitterConfig config, String mcpKafkaTopic) throws IOException {
     this.config = config;
     kafkaConfigProperties = new Properties();
     kafkaConfigProperties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.config.getBootstrap());
     kafkaConfigProperties.put(
-            ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
-            org.apache.kafka.common.serialization.StringSerializer.class);
+        ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
+        org.apache.kafka.common.serialization.StringSerializer.class);
     kafkaConfigProperties.put(
-            ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
-            io.confluent.kafka.serializers.KafkaAvroSerializer.class);
+        ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
+        io.confluent.kafka.serializers.KafkaAvroSerializer.class);
     kafkaConfigProperties.put("schema.registry.url", this.config.getSchemaRegistryUrl());
     kafkaConfigProperties.putAll(config.getSchemaRegistryConfig());
     kafkaConfigProperties.putAll(config.getProducerConfig());
@@ -87,8 +85,7 @@ public Future<MetadataWriteResponse> emit(MetadataChangeProposal mcp, Callback d
       throws IOException {
     GenericRecord genricRecord = _avroSerializer.serialize(mcp);
     ProducerRecord<Object, Object> record =
-        new ProducerRecord<>(
-                this.mcpKafkaTopic, mcp.getEntityUrn().toString(), genricRecord);
+        new ProducerRecord<>(this.mcpKafkaTopic, mcp.getEntityUrn().toString(), genricRecord);
     org.apache.kafka.clients.producer.Callback callback =
         new org.apache.kafka.clients.producer.Callback() {