Fix formatting for TypeReference usages

apache · Dec 13, 2024 · 1b8d536 · 1b8d536
1 parent b1cefce
commit 1b8d536
Show file tree

Hide file tree

Showing 41 changed files with 62 additions and 178 deletions.
diff --git a/.../apache/druid/indexing/rabbitstream/IncrementalPublishingRabbitStreamIndexTaskRunner.java b/.../apache/druid/indexing/rabbitstream/IncrementalPublishingRabbitStreamIndexTaskRunner.java
@@ -148,9 +148,8 @@ protected TreeMap<Integer, Map<String, Long>> getCheckPointsFromContext(
       log.debug("Got checkpoints from task context[%s].", checkpointsString);
       return toolbox.getJsonMapper().readValue(
           checkpointsString,
-          new TypeReference<>()
-          {
-          });
+          new TypeReference<>() {}
+      );
     } else {
       return null;
     }

diff --git a/...c/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisor.java b/...c/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisor.java
@@ -83,9 +83,7 @@
  */
 public class RabbitStreamSupervisor extends SeekableStreamSupervisor<String, Long, ByteEntity>
 {
-  public static final TypeReference<TreeMap<Integer, Map<String, Long>>> CHECKPOINTS_TYPE_REF = new TypeReference<>()
-  {
-  };
+  public static final TypeReference<TreeMap<Integer, Map<String, Long>>> CHECKPOINTS_TYPE_REF = new TypeReference<>() {};
 
   private static final EmittingLogger log = new EmittingLogger(RabbitStreamSupervisor.class);
   private static final Long NOT_SET = -1L;

diff --git a/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogClient.java b/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogClient.java
@@ -59,13 +59,9 @@ public class CatalogClient implements CatalogSource
 {
   public static final String SCHEMA_SYNC_PATH = CatalogResource.ROOT_PATH + CatalogResource.SCHEMA_SYNC;
   public static final String TABLE_SYNC_PATH = CatalogResource.ROOT_PATH + CatalogResource.TABLE_SYNC;
-  private static final TypeReference<List<TableMetadata>> LIST_OF_TABLE_METADATA_TYPE = new TypeReference<>()
-  {
-  };
+  private static final TypeReference<List<TableMetadata>> LIST_OF_TABLE_METADATA_TYPE = new TypeReference<>() {};
   // Not strictly needed as a TypeReference, but doing so makes the code simpler.
-  private static final TypeReference<TableMetadata> TABLE_METADATA_TYPE = new TypeReference<>()
-  {
-  };
+  private static final TypeReference<TableMetadata> TABLE_METADATA_TYPE = new TypeReference<>() {};
 
   private final DruidLeaderClient coordClient;
   private final ObjectMapper smileMapper;

diff --git a/.../main/java/org/apache/druid/indexing/kafka/IncrementalPublishingKafkaIndexTaskRunner.java b/.../main/java/org/apache/druid/indexing/kafka/IncrementalPublishingKafkaIndexTaskRunner.java
@@ -232,9 +232,7 @@ protected TreeMap<Integer, Map<KafkaTopicPartition, Long>> getCheckPointsFromCon
       log.debug("Got checkpoints from task context[%s].", checkpointsString);
       return toolbox.getJsonMapper().readValue(
           checkpointsString,
-          new TypeReference<>()
-          {
-          }
+          new TypeReference<>() {}
       );
     } else {
       return null;

diff --git a/...exing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskRunner.java b/...exing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskRunner.java
@@ -195,9 +195,7 @@ protected TreeMap<Integer, Map<String, String>> getCheckPointsFromContext(
       log.debug("Got checkpoints from task context[%s]", checkpointsString);
       return toolbox.getJsonMapper().readValue(
           checkpointsString,
-          new TypeReference<>()
-          {
-          }
+          new TypeReference<>() {}
       );
     } else {
       return null;

diff --git a/...-stage-query/src/test/java/org/apache/druid/msq/indexing/TaskReportQueryListenerTest.java b/...-stage-query/src/test/java/org/apache/druid/msq/indexing/TaskReportQueryListenerTest.java
@@ -114,9 +114,7 @@ public void test_taskReportDestination() throws IOException
     final TaskReport.ReportMap reportMap =
         JSON_MAPPER.readValue(
             baos.toByteArray(),
-            new TypeReference<>()
-            {
-            }
+            new TypeReference<>() {}
         );
 
     Assert.assertEquals(ImmutableSet.of("multiStageQuery", TaskContextReport.REPORT_KEY), reportMap.keySet());
@@ -185,9 +183,7 @@ public void test_durableDestination() throws IOException
     final TaskReport.ReportMap reportMap =
         JSON_MAPPER.readValue(
             baos.toByteArray(),
-            new TypeReference<>()
-            {
-            }
+            new TypeReference<>() {}
         );
 
     Assert.assertEquals(ImmutableSet.of("multiStageQuery", TaskContextReport.REPORT_KEY), reportMap.keySet());

diff --git a/indexing-hadoop/src/main/java/org/apache/druid/indexer/DetermineHashedPartitionsJob.java b/indexing-hadoop/src/main/java/org/apache/druid/indexer/DetermineHashedPartitionsJob.java
@@ -159,9 +159,7 @@ public boolean run()
         }
         List<Interval> intervals = HadoopDruidIndexerConfig.JSON_MAPPER.readValue(
             Utils.openInputStream(groupByJob, intervalInfoPath),
-            new TypeReference<>()
-            {
-            }
+            new TypeReference<>() {}
         );
         config.setGranularitySpec(
             new UniformGranularitySpec(

diff --git a/indexing-hadoop/src/main/java/org/apache/druid/indexer/DeterminePartitionsJob.java b/indexing-hadoop/src/main/java/org/apache/druid/indexer/DeterminePartitionsJob.java
@@ -272,9 +272,7 @@ public boolean run()
         }
         if (Utils.exists(dimSelectionJob, fileSystem, partitionInfoPath)) {
           List<ShardSpec> specs = HadoopDruidIndexerConfig.JSON_MAPPER.readValue(
-              Utils.openInputStream(dimSelectionJob, partitionInfoPath), new TypeReference<>()
-              {
-              }
+              Utils.openInputStream(dimSelectionJob, partitionInfoPath), new TypeReference<>() {}
           );
 
           List<HadoopyShardSpec> actualSpecs = Lists.newArrayListWithExpectedSize(specs.size());

diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java
@@ -274,9 +274,7 @@ public TaskStatus call()
                           try {
                             List<String> taskJavaOptsArray = jsonMapper.convertValue(
                                 task.getContextValue(ForkingTaskRunnerConfig.JAVA_OPTS_ARRAY_PROPERTY),
-                                new TypeReference<>()
-                                {
-                                }
+                                new TypeReference<>() {}
                             );
                             if (taskJavaOptsArray != null) {
                               command.addAll(taskJavaOptsArray);

diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/WorkerHolder.java b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/WorkerHolder.java
@@ -62,9 +62,7 @@ public class WorkerHolder
 {
   private static final EmittingLogger log = new EmittingLogger(WorkerHolder.class);
 
-  public static final TypeReference<ChangeRequestsSnapshot<WorkerHistoryItem>> WORKER_SYNC_RESP_TYPE_REF = new TypeReference<>()
-  {
-  };
+  public static final TypeReference<ChangeRequestsSnapshot<WorkerHistoryItem>> WORKER_SYNC_RESP_TYPE_REF = new TypeReference<>() {};
 
 
   private final Worker worker;

diff --git a/...tests/src/main/java/org/apache/druid/testing/clients/AbstractQueryResourceTestClient.java b/...tests/src/main/java/org/apache/druid/testing/clients/AbstractQueryResourceTestClient.java
@@ -99,9 +99,7 @@ public byte[] encode(Object content) throws IOException
     @Override
     public List<Map<String, Object>> decode(byte[] content) throws IOException
     {
-      return om.readValue(content, new TypeReference<>()
-      {
-      });
+      return om.readValue(content, new TypeReference<>() {});
     }
   }
 

diff --git a/...on-tests/src/main/java/org/apache/druid/testing/clients/ClientInfoResourceTestClient.java b/...on-tests/src/main/java/org/apache/druid/testing/clients/ClientInfoResourceTestClient.java
@@ -89,9 +89,7 @@ public List<String> getDimensions(String dataSource, String interval)
         );
       }
       return jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (Exception e) {

diff --git a/...n-tests/src/main/java/org/apache/druid/testing/clients/CoordinatorResourceTestClient.java b/...n-tests/src/main/java/org/apache/druid/testing/clients/CoordinatorResourceTestClient.java
@@ -131,9 +131,7 @@ public List<String> getSegments(final String dataSource)
       );
 
       segments = jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (Exception e) {
@@ -152,9 +150,7 @@ public List<DataSegment> getFullSegmentsMetadata(final String dataSource)
       );
 
       segments = jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (Exception e) {
@@ -171,9 +167,7 @@ public List<String> getSegmentIntervals(final String dataSource)
       StatusResponseHolder response = makeRequest(HttpMethod.GET, getIntervalsURL(dataSource));
 
       segments = jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (Exception e) {
@@ -189,9 +183,7 @@ public List<DataSegment> getAvailableSegments(final String dataSource)
       StatusResponseHolder response = makeRequest(HttpMethod.GET, getFullSegmentsURL(dataSource));
 
       return jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (Exception e) {
@@ -222,9 +214,7 @@ private Map<String, Integer> getLoadStatus(String dataSource)
       }
 
       status = jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (Exception e) {
@@ -365,9 +355,7 @@ private Map<String, Map<HostAndPort, LookupsState<LookupExtractorFactoryMapConta
 
       status = jsonMapper.readValue(
           response.getContent(),
-          new TypeReference<>()
-          {
-          }
+          new TypeReference<>() {}
       );
     }
     catch (Exception e) {

diff --git a/...tion-tests/src/main/java/org/apache/druid/testing/clients/OverlordResourceTestClient.java b/...tion-tests/src/main/java/org/apache/druid/testing/clients/OverlordResourceTestClient.java
@@ -147,9 +147,7 @@ public TaskStatusPlus getTaskStatus(String taskID)
       LOG.debug("Index status response" + response.getContent());
       TaskStatusResponse taskStatusResponse = jsonMapper.readValue(
           response.getContent(),
-          new TypeReference<>()
-          {
-          }
+          new TypeReference<>() {}
       );
       return taskStatusResponse.getStatus();
     }
@@ -236,9 +234,7 @@ private List<TaskResponseObject> getTasks(String identifier)
         LOG.debug("Tasks %s response %s", identifier, response.getContent());
       }
       return jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (Exception e) {
@@ -257,9 +253,7 @@ public TaskPayloadResponse getTaskPayload(String taskId)
         LOG.debug("Task %s response %s", taskId, response.getContent());
       }
       return jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
     }
     catch (ISE e) {
@@ -350,9 +344,7 @@ public Map<String, List<Interval>> getLockedIntervals(List<LockFilterPolicy> loc
       ).get();
       return jsonMapper.readValue(
           response.getContent(),
-          new TypeReference<>()
-          {
-          }
+          new TypeReference<>() {}
       );
     }
     catch (Exception e) {
@@ -758,9 +750,7 @@ public List<Object> getSupervisorHistory(String id)
         );
       }
       List<Object> responseData = jsonMapper.readValue(
-          response.getContent(), new TypeReference<>()
-          {
-          }
+          response.getContent(), new TypeReference<>() {}
       );
       return responseData;
     }

diff --git a/integration-tests/src/main/java/org/apache/druid/testing/utils/AbstractTestQueryHelper.java b/integration-tests/src/main/java/org/apache/druid/testing/utils/AbstractTestQueryHelper.java
@@ -117,9 +117,7 @@ public void testQueriesFromFile(String url, String filePath) throws Exception
     List<QueryResultType> queries =
         jsonMapper.readValue(
             TestQueryHelper.class.getResourceAsStream(filePath),
-            new TypeReference<>()
-            {
-            }
+            new TypeReference<>() {}
         );
 
     testQueries(url, queries);
@@ -131,9 +129,7 @@ public void testQueriesFromString(String url, String str) throws Exception
     List<QueryResultType> queries =
         jsonMapper.readValue(
             str,
-            new TypeReference<>()
-            {
-            }
+            new TypeReference<>() {}
         );
     testQueries(url, queries);
   }

diff --git a/integration-tests/src/main/java/org/apache/druid/testing/utils/MsqTestQueryHelper.java b/integration-tests/src/main/java/org/apache/druid/testing/utils/MsqTestQueryHelper.java
@@ -269,9 +269,7 @@ public void testQueriesFromFile(String filePath, String fullDatasourcePath) thro
     List<MsqQueryWithResults> queries =
         jsonMapper.readValue(
             TestQueryHelper.class.getResourceAsStream(filePath),
-            new TypeReference<>()
-            {
-            }
+            new TypeReference<>() {}
         );
     for (MsqQueryWithResults queryWithResults : queries) {
       String queryString = queryWithResults.getQuery();

diff --git a/...n-tests/src/test/java/org/apache/druid/tests/query/ITQueryRetryTestOnMissingSegments.java b/...n-tests/src/test/java/org/apache/druid/tests/query/ITQueryRetryTestOnMissingSegments.java
@@ -154,9 +154,7 @@ private void testQueries(List<QueryWithResults> queries, Expectation expectation
 
         List<Map<String, Object>> result = jsonMapper.readValue(
             responseHolder.getContent(),
-            new TypeReference<>()
-            {
-            }
+            new TypeReference<>() {}
         );
         if (!QueryResultVerifier.compareResults(
             result,

diff --git a/processing/src/main/java/org/apache/druid/query/groupby/GroupByQueryQueryToolChest.java b/processing/src/main/java/org/apache/druid/query/groupby/GroupByQueryQueryToolChest.java
@@ -90,9 +90,7 @@ public class GroupByQueryQueryToolChest extends QueryToolChest<ResultRow, GroupB
   private static final byte GROUPBY_QUERY = 0x14;
   private static final TypeReference<Object> OBJECT_TYPE_REFERENCE =
       new TypeReference<>() {};
-  private static final TypeReference<ResultRow> TYPE_REFERENCE = new TypeReference<>()
-  {
-  };
+  private static final TypeReference<ResultRow> TYPE_REFERENCE = new TypeReference<>() {};
 
   private final GroupingEngine groupingEngine;
   private final GroupByQueryConfig queryConfig;

diff --git a/processing/src/main/java/org/apache/druid/query/lookup/LookupSnapshotTaker.java b/processing/src/main/java/org/apache/druid/query/lookup/LookupSnapshotTaker.java
@@ -69,9 +69,7 @@ public synchronized List<LookupBean> pullExistingSnapshot(final String tier)
         LOGGER.warn("found empty file no lookups to load from [%s]", persistFile.getAbsolutePath());
         return Collections.emptyList();
       }
-      lookupBeanList = objectMapper.readValue(persistFile, new TypeReference<>()
-      {
-      });
+      lookupBeanList = objectMapper.readValue(persistFile, new TypeReference<>() {});
       return lookupBeanList;
     }
     catch (IOException e) {

diff --git a/...ing/src/main/java/org/apache/druid/query/metadata/SegmentMetadataQueryQueryToolChest.java b/...ing/src/main/java/org/apache/druid/query/metadata/SegmentMetadataQueryQueryToolChest.java
@@ -76,9 +76,7 @@
 
 public class SegmentMetadataQueryQueryToolChest extends QueryToolChest<SegmentAnalysis, SegmentMetadataQuery>
 {
-  private static final TypeReference<SegmentAnalysis> TYPE_REFERENCE = new TypeReference<>()
-  {
-  };
+  private static final TypeReference<SegmentAnalysis> TYPE_REFERENCE = new TypeReference<>() {};
   private static final byte SEGMENT_METADATA_CACHE_PREFIX = 0x4;
   private static final byte SEGMENT_METADATA_QUERY = 0x16;
   private static final Function<SegmentAnalysis, SegmentAnalysis> MERGE_TRANSFORM_FN =

diff --git a/processing/src/main/java/org/apache/druid/query/scan/ScanQueryQueryToolChest.java b/processing/src/main/java/org/apache/druid/query/scan/ScanQueryQueryToolChest.java
@@ -46,9 +46,7 @@
 
 public class ScanQueryQueryToolChest extends QueryToolChest<ScanResultValue, ScanQuery>
 {
-  private static final TypeReference<ScanResultValue> TYPE_REFERENCE = new TypeReference<>()
-  {
-  };
+  private static final TypeReference<ScanResultValue> TYPE_REFERENCE = new TypeReference<>() {};
 
   private final GenericQueryMetricsFactory queryMetricsFactory;
 

diff --git a/processing/src/main/java/org/apache/druid/query/search/SearchQueryQueryToolChest.java b/processing/src/main/java/org/apache/druid/query/search/SearchQueryQueryToolChest.java
@@ -59,12 +59,8 @@
 public class SearchQueryQueryToolChest extends QueryToolChest<Result<SearchResultValue>, SearchQuery>
 {
   private static final byte SEARCH_QUERY = 0x15;
-  private static final TypeReference<Result<SearchResultValue>> TYPE_REFERENCE = new TypeReference<>()
-  {
-  };
-  private static final TypeReference<Object> OBJECT_TYPE_REFERENCE = new TypeReference<>()
-  {
-  };
+  private static final TypeReference<Result<SearchResultValue>> TYPE_REFERENCE = new TypeReference<>() {};
+  private static final TypeReference<Object> OBJECT_TYPE_REFERENCE = new TypeReference<>() {};
 
   private final SearchQueryConfig config;
   private final SearchQueryMetricsFactory queryMetricsFactory;

diff --git a/...ng/src/main/java/org/apache/druid/query/timeboundary/TimeBoundaryQueryQueryToolChest.java b/...ng/src/main/java/org/apache/druid/query/timeboundary/TimeBoundaryQueryQueryToolChest.java
@@ -62,12 +62,8 @@ public class TimeBoundaryQueryQueryToolChest
 {
   private static final byte TIMEBOUNDARY_QUERY = 0x3;
 
-  private static final TypeReference<Result<TimeBoundaryResultValue>> TYPE_REFERENCE = new TypeReference<>()
-  {
-  };
-  private static final TypeReference<Object> OBJECT_TYPE_REFERENCE = new TypeReference<>()
-  {
-  };
+  private static final TypeReference<Result<TimeBoundaryResultValue>> TYPE_REFERENCE = new TypeReference<>() {};
+  private static final TypeReference<Object> OBJECT_TYPE_REFERENCE = new TypeReference<>() {};
 
   private final GenericQueryMetricsFactory queryMetricsFactory;