fix lint

Author: pedro93

datahub-upgrade/src/main/java/com/linkedin/datahub/upgrade/config/BackfillPolicyFieldsConfig.java

@@ -7,15 +7,17 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
-
 @Configuration
 public class BackfillPolicyFieldsConfig {
 
   @Bean
-  public BackfillBrowsePathsV2 backfillBrowsePathsV2(EntityService<?> entityService, SearchService searchService,
+  public BackfillBrowsePathsV2 backfillBrowsePathsV2(
+      EntityService<?> entityService,
+      SearchService searchService,
       @Value("${systemUpdate.policyFields.enabled}") final boolean enabled,
       @Value("${systemUpdate.policyFields.reprocess.enabled}") final boolean reprocessEnabled,
       @Value("${systemUpdate.policyFields.batchSize}") final Integer batchSize) {
-    return new BackfillBrowsePathsV2(entityService, searchService, enabled, reprocessEnabled, batchSize);
+    return new BackfillBrowsePathsV2(
+        entityService, searchService, enabled, reprocessEnabled, batchSize);
   }
-}
+}

datahub-upgrade/src/main/java/com/linkedin/datahub/upgrade/config/SystemUpdateConfig.java

@@ -52,8 +52,7 @@ public SystemUpdate systemUpdate(
         version,
         backfillBrowsePathsV2,
         reindexDataJobViaNodesCLL,
-        backfillPolicyFields
-    );
+        backfillPolicyFields);
   }
 
   @Value("#{systemEnvironment['DATAHUB_REVISION'] ?: '0'}")

datahub-upgrade/src/main/java/com/linkedin/datahub/upgrade/system/SystemUpdate.java

@@ -32,7 +32,8 @@ public SystemUpdate(
 
     _preStartupUpgrades = List.of(buildIndicesJob);
     _steps = List.of(new DataHubStartupStep(kafkaEventProducer, version));
-    _postStartupUpgrades = List.of(cleanIndicesJob, backfillBrowsePathsV2, upgradeViaNodeCll, backfillPolicyFields);
+    _postStartupUpgrades =
+        List.of(cleanIndicesJob, backfillBrowsePathsV2, upgradeViaNodeCll, backfillPolicyFields);
   }
 
   @Override

datahub-upgrade/src/main/java/com/linkedin/datahub/upgrade/system/entity/steps/BackfillPolicyFields.java

@@ -7,7 +7,6 @@
 import com.linkedin.metadata.search.SearchService;
 import java.util.List;
 
-
 public class BackfillPolicyFields implements Upgrade {
   private final List<UpgradeStep> _steps;
 
@@ -18,7 +17,8 @@ public BackfillPolicyFields(
       boolean reprocessEnabled,
       Integer batchSize) {
     if (enabled) {
-      _steps = ImmutableList.of(
+      _steps =
+          ImmutableList.of(
               new BackfillPolicyFieldsStep(
                   entityService, searchService, reprocessEnabled, batchSize));
     } else {

datahub-upgrade/src/main/java/com/linkedin/datahub/upgrade/system/entity/steps/BackfillPolicyFieldsStep.java

@@ -1,5 +1,7 @@
 package com.linkedin.datahub.upgrade.system.entity.steps;
 
+import static com.linkedin.metadata.Constants.*;
+
 import com.google.common.collect.ImmutableList;
 import com.linkedin.common.AuditStamp;
 import com.linkedin.common.urn.Urn;
@@ -34,10 +36,10 @@
 import lombok.extern.slf4j.Slf4j;
 import org.jetbrains.annotations.NotNull;
 
-import static com.linkedin.metadata.Constants.*;
-
-
-/** This bootstrap step is responsible for upgrading DataHub policy documents with new searchable fields in ES */
+/**
+ * This bootstrap step is responsible for upgrading DataHub policy documents with new searchable
+ * fields in ES
+ */
 @Slf4j
 public class BackfillPolicyFieldsStep implements UpgradeStep {
   private static final String UPGRADE_ID = "BackfillPolicyFieldsStep";
@@ -47,7 +49,9 @@ public class BackfillPolicyFieldsStep implements UpgradeStep {
   private final EntityService<?> entityService;
   private final SearchService _searchService;
 
-  public BackfillPolicyFieldsStep(EntityService<?> entityService, SearchService searchService,
+  public BackfillPolicyFieldsStep(
+      EntityService<?> entityService,
+      SearchService searchService,
       boolean reprocessEnabled,
       Integer batchSize) {
     this.entityService = entityService;
@@ -74,8 +78,7 @@ public Function<UpgradeContext, UpgradeStepResult> executable() {
       do {
         log.info(
             String.format(
-                "Upgrading batch of policies %s-%s",
-                migratedCount, migratedCount + batchSize));
+                "Upgrading batch of policies %s-%s", migratedCount, migratedCount + batchSize));
         scrollId = backfillPolicies(auditStamp, scrollId);
         migratedCount += batchSize;
       } while (scrollId != null);
@@ -169,8 +172,9 @@ private Filter backfillPolicyFieldFilter() {
   private void ingestPolicyFields(Urn urn, AuditStamp auditStamp) {
     EntityResponse entityResponse = null;
     try {
-      entityResponse = entityService.getEntityV2(
-          urn.getEntityType(), urn, Collections.singleton(DATAHUB_POLICY_INFO_ASPECT_NAME));
+      entityResponse =
+          entityService.getEntityV2(
+              urn.getEntityType(), urn, Collections.singleton(DATAHUB_POLICY_INFO_ASPECT_NAME));
     } catch (URISyntaxException e) {
       log.error(
           String.format(
@@ -181,16 +185,20 @@ private void ingestPolicyFields(Urn urn, AuditStamp auditStamp) {
 
     if (entityResponse != null
         && entityResponse.getAspects().containsKey(DATAHUB_POLICY_INFO_ASPECT_NAME)) {
-      final DataMap dataMap = entityResponse.getAspects().get(DATAHUB_POLICY_INFO_ASPECT_NAME).getValue().data();
+      final DataMap dataMap =
+          entityResponse.getAspects().get(DATAHUB_POLICY_INFO_ASPECT_NAME).getValue().data();
       final DataHubPolicyInfo infoAspect = new DataHubPolicyInfo(dataMap);
-      log.debug(String.format("Restating policy information for urn %s with value %s", urn, infoAspect));
+      log.debug(
+          String.format("Restating policy information for urn %s with value %s", urn, infoAspect));
       MetadataChangeProposal proposal = new MetadataChangeProposal();
       proposal.setEntityUrn(urn);
       proposal.setEntityType(urn.getEntityType());
       proposal.setAspectName(DATAHUB_POLICY_INFO_ASPECT_NAME);
       proposal.setChangeType(ChangeType.RESTATE);
       proposal.setSystemMetadata(
-          new SystemMetadata().setRunId(DEFAULT_RUN_ID).setLastObserved(System.currentTimeMillis()));
+          new SystemMetadata()
+              .setRunId(DEFAULT_RUN_ID)
+              .setLastObserved(System.currentTimeMillis()));
       proposal.setAspect(GenericRecordUtils.serializeAspect(infoAspect));
       entityService.ingestProposal(proposal, auditStamp, true);
     }
@@ -208,5 +216,4 @@ private static ConjunctiveCriterion getCriterionForMissingField(String field) {
     conjunctiveCriterion.setAnd(criterionArray);
     return conjunctiveCriterion;
   }
-
-}
+}