Fix LongDoubleConversion warnings

Author: stankiewicz

it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOLT.java

@@ -341,7 +341,7 @@ private void testRead() throws IOException {
             region,
             launchInfo.jobId(),
             getBeamMetricsName(PipelineMetricsType.COUNTER, READ_ELEMENT_METRIC_NAME));
-    assertEquals(configuration.numRecords, numRecords, 0.5);
+    assertEquals((double) configuration.numRecords, numRecords, 0.5);
 
     // export metrics
     MetricsConfiguration metricsConfig =

it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOLT.java

@@ -156,7 +156,7 @@ public void testSpannerWriteAndRead() throws IOException {
             region,
             readInfo.jobId(),
             getBeamMetricsName(PipelineMetricsType.COUNTER, READ_ELEMENT_METRIC_NAME));
-    assertEquals(configuration.numRecords, numRecords, 0.5);
+    assertEquals((double) configuration.numRecords, numRecords, 0.5);
 
     // export metrics
     MetricsConfiguration metricsConfig =

it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/FileBasedIOLT.java

@@ -221,7 +221,7 @@ public void testTextIOWriteThenRead() throws IOException {
             readInfo.jobId(),
             getBeamMetricsName(PipelineMetricsType.COUNTER, READ_ELEMENT_METRIC_NAME));
 
-    assertEquals(configuration.numRecords, numRecords, 0.5);
+    assertEquals((double) configuration.numRecords, numRecords, 0.5);
 
     // export metrics
     MetricsConfiguration metricsConfig =

runners/direct-java/src/main/java/org/apache/beam/runners/direct/WriteWithShardingFactory.java

@@ -138,7 +138,7 @@ private int calculateShards(long totalRecords) {
         return (int) totalRecords;
       }
       // 100mil records before >7 output files
-      int floorLogRecs = (int) Math.log10(totalRecords);
+      int floorLogRecs = (int) Math.log10((double) totalRecords);
       return Math.max(floorLogRecs, MIN_SHARDS_FOR_LOG) + extraShards;
     }
   }

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java

@@ -661,7 +661,7 @@ public void close() throws IOException {
     @VisibleForTesting
     static @Nullable ReportedParallelism longToParallelism(long value) {
       if (value >= 0) {
-        return new ReportedParallelism().setValue(Double.valueOf(value));
+        return new ReportedParallelism().setValue(Double.valueOf((double) value));
       } else {
         return null;
       }

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterFactory.java

@@ -226,7 +226,7 @@ public final CounterDistribution addValue(long value) {
       long count = this.getCount() + 1;
       long sum = this.getSum() + value;
       // TODO: Replace sum-of-squares with statistics for a better stddev algorithm.
-      double sumOfSquares = this.getSumOfSquares() + Math.pow(value, 2);
+      double sumOfSquares = this.getSumOfSquares() + Math.pow((double) value, 2);
 
       int bucketIndex = calculateBucket(value);
       List<Long> buckets = incrementBucket(bucketIndex);

sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/LatencyRecordingHttpRequestInitializer.java

@@ -63,7 +63,7 @@ public LoggingInterceptor(Histogram requestLatencies) {
     @Override
     public void interceptResponse(HttpResponse response) throws IOException {
       long timeToResponse = System.currentTimeMillis() - startTime;
-      requestLatencies.update(timeToResponse);
+      requestLatencies.update((double) timeToResponse);
     }
 
     @Override

sdks/java/extensions/sql/perf-tests/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryIOPushDownIT.java

@@ -199,7 +199,7 @@ private Set<Function<MetricsReader, NamedTestResult>> getReadSuppliers(
     suppliers.add(
         reader -> {
           long fieldsRead = reader.getCounterMetric(FIELDS_READ_METRIC);
-          return NamedTestResult.create(uuid, timestamp, FIELDS_READ_METRIC, fieldsRead);
+          return NamedTestResult.create(uuid, timestamp, FIELDS_READ_METRIC, (double) fieldsRead);
         });
     return suppliers;
   }

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java

@@ -1003,7 +1003,8 @@ public void processElement(
 
       private long getDesiredChunkSize(
           PipelineOptions options, BigQueryStorageTableSource<T> output) throws Exception {
-        return Math.max(1 << 20, (long) (1000 * Math.sqrt(output.getEstimatedSizeBytes(options))));
+        return Math.max(
+            1 << 20, (long) (1000 * Math.sqrt((double) output.getEstimatedSizeBytes(options))));
       }
     }
 
@@ -1755,7 +1756,8 @@ private PCollection<T> expandForDirectRead(
               desiredChunkSize = 64 << 20; // 64mb
             } else {
               // 1mb --> 1 shard; 1gb --> 32 shards; 1tb --> 1000 shards, 1pb --> 32k shards
-              desiredChunkSize = Math.max(1 << 20, (long) (1000 * Math.sqrt(estimatedSize)));
+              desiredChunkSize =
+                  Math.max(1 << 20, (long) (1000 * Math.sqrt((double) estimatedSize)));
             }
             sources = source.split(desiredChunkSize, bqOptions);
           } catch (Exception e) {

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySinkMetrics.java

@@ -139,7 +139,7 @@ private static void updateRpcLatencyMetric(@Nonnull Context<?> c, RpcMethod meth
     }
     long timeElapsed = java.time.Duration.between(operationStartTime, operationEndTime).toMillis();
     if (timeElapsed > 0) {
-      BigQuerySinkMetrics.createRPCLatencyHistogram(method).update(timeElapsed);
+      BigQuerySinkMetrics.createRPCLatencyHistogram(method).update((double) timeElapsed);
     }
   }