chore: Support FLOAT32 in Cloud Client Executor (#3056)

1. Add support for FLOAT32 in cloud client executor
2. Also allow integration tests to run FLOAT32 type against prod

Author: arawind

google-cloud-spanner-executor/src/main/java/com/google/cloud/executor/spanner/CloudClientExecutor.java

@@ -2719,6 +2719,9 @@ private com.google.spanner.executor.v1.ValueList buildRow(
           case BOOL:
             value.setBoolValue(result.getBoolean(i));
             break;
+          case FLOAT32:
+            value.setDoubleValue((double) result.getFloat(i));
+            break;
           case FLOAT64:
             value.setDoubleValue(result.getDouble(i));
             break;
@@ -2765,6 +2768,25 @@ private com.google.spanner.executor.v1.ValueList buildRow(
                       com.google.spanner.v1.Type.newBuilder().setCode(TypeCode.BOOL).build());
                 }
                 break;
+              case FLOAT32:
+                {
+                  com.google.spanner.executor.v1.ValueList.Builder builder =
+                      com.google.spanner.executor.v1.ValueList.newBuilder();
+                  List<Float> values = result.getFloatList(i);
+                  for (Float floatValue : values) {
+                    com.google.spanner.executor.v1.Value.Builder valueProto =
+                        com.google.spanner.executor.v1.Value.newBuilder();
+                    if (floatValue == null) {
+                      builder.addValue(valueProto.setIsNull(true).build());
+                    } else {
+                      builder.addValue(valueProto.setDoubleValue((double) floatValue).build());
+                    }
+                  }
+                  value.setArrayValue(builder.build());
+                  value.setArrayType(
+                      com.google.spanner.v1.Type.newBuilder().setCode(TypeCode.FLOAT32).build());
+                }
+                break;
               case FLOAT64:
                 {
                   com.google.spanner.executor.v1.ValueList.Builder builder =
@@ -3086,6 +3108,9 @@ private static com.google.cloud.spanner.Value valueProtoToCloudValue(
     switch (type.getCode()) {
       case INT64:
         return com.google.cloud.spanner.Value.int64(value.hasIsNull() ? null : value.getIntValue());
+      case FLOAT32:
+        return com.google.cloud.spanner.Value.float32(
+            value.hasIsNull() ? null : (float) value.getDoubleValue());
       case FLOAT64:
         return com.google.cloud.spanner.Value.float64(
             value.hasIsNull() ? null : value.getDoubleValue());
@@ -3142,6 +3167,19 @@ private static com.google.cloud.spanner.Value valueProtoToCloudValue(
                           .map(com.google.spanner.executor.v1.Value::getIntValue)
                           .collect(Collectors.toList())));
             }
+          case FLOAT32:
+            if (value.hasIsNull()) {
+              return com.google.cloud.spanner.Value.float32Array((Iterable<Float>) null);
+            } else {
+              return com.google.cloud.spanner.Value.float32Array(
+                  unmarshallValueList(
+                      value.getArrayValue().getValueList().stream()
+                          .map(com.google.spanner.executor.v1.Value::getIsNull)
+                          .collect(Collectors.toList()),
+                      value.getArrayValue().getValueList().stream()
+                          .map(v -> (float) v.getDoubleValue())
+                          .collect(Collectors.toList())));
+            }
           case FLOAT64:
             if (value.hasIsNull()) {
               return com.google.cloud.spanner.Value.float64Array((Iterable<Double>) null);
@@ -3382,6 +3420,8 @@ private static com.google.cloud.spanner.Type typeProtoToCloudType(
         return com.google.cloud.spanner.Type.string();
       case BYTES:
         return com.google.cloud.spanner.Type.bytes();
+      case FLOAT32:
+        return com.google.cloud.spanner.Type.float32();
       case FLOAT64:
         return com.google.cloud.spanner.Type.float64();
       case DATE:
@@ -3430,6 +3470,8 @@ private static com.google.spanner.v1.Type cloudTypeToTypeProto(@Nonnull Type clo
         return com.google.spanner.v1.Type.newBuilder().setCode(TypeCode.BOOL).build();
       case INT64:
         return com.google.spanner.v1.Type.newBuilder().setCode(TypeCode.INT64).build();
+      case FLOAT32:
+        return com.google.spanner.v1.Type.newBuilder().setCode(TypeCode.FLOAT32).build();
       case FLOAT64:
         return com.google.spanner.v1.Type.newBuilder().setCode(TypeCode.FLOAT64).build();
       case STRING:

google-cloud-spanner/src/test/java/com/google/cloud/spanner/it/ITFloat32Test.java

@@ -17,14 +17,12 @@
 package com.google.cloud.spanner.it;
 
 import static com.google.cloud.spanner.testing.EmulatorSpannerHelper.isUsingEmulator;
-import static com.google.common.base.Strings.isNullOrEmpty;
 import static org.junit.Assert.assertArrayEquals;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertThrows;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assume.assumeFalse;
-import static org.junit.Assume.assumeTrue;
 
 import com.google.cloud.Timestamp;
 import com.google.cloud.spanner.Database;
@@ -92,18 +90,9 @@ public static List<DialectTestParameter> data() {
 
   private static DatabaseClient client;
 
-  private static boolean isUsingCloudDevel() {
-    String jobType = System.getenv("JOB_TYPE");
-
-    // Assumes that the jobType contains the string "cloud-devel" to signal that
-    // the environment is cloud-devel.
-    return !isNullOrEmpty(jobType) && jobType.contains("cloud-devel");
-  }
-
   @BeforeClass
   public static void setUpDatabase()
       throws ExecutionException, InterruptedException, TimeoutException {
-    assumeTrue("FLOAT32 is currently only supported in cloud-devel", isUsingCloudDevel());
     assumeFalse("Emulator does not support FLOAT32 yet", isUsingEmulator());
 
     Database googleStandardSQLDatabase =