Lint.

Author: Claude

sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java

@@ -1033,7 +1033,7 @@ private static FieldType toFieldType(TypeWithNullability type) {
     }
     // TODO: Remove once Avro 1.12+ has timestamp-nanos
     if (fieldType == null
-        && TIMESTAMP_NANOS_LOGICAL_TYPE.equals(avroSchema.getProp("logicalType"))) {
+        && avroSchema.getProp("logicalType").equals(TIMESTAMP_NANOS_LOGICAL_TYPE)) {
       fieldType = FieldType.logicalType(Timestamp.NANOS);
     }
 
@@ -1407,7 +1407,7 @@ private static Object convertLogicalType(
     TypeWithNullability type = new TypeWithNullability(avroSchema);
 
     // TODO: Remove this workaround once Avro is upgraded to 1.12+ where timestamp-nanos
-    if (TIMESTAMP_NANOS_LOGICAL_TYPE.equals(type.type.getProp("logicalType"))) {
+    if (type.type.getProp("logicalType").equals(TIMESTAMP_NANOS_LOGICAL_TYPE)) {
       if (type.type.getType() == Type.LONG) {
         Long nanos = (Long) value;
         // Check if Beam expects Timestamp logical type

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

@@ -412,7 +412,7 @@ private static Object convertRequiredField(String name, Schema schema, Object v)
           // ideally Instant but TableRowJsonCoder encodes as String
           return formatTimestamp((Long) v, TimestampPrecision.MICROSECONDS);
           // TODO: Use LogicalTypes.TimestampNanos once avro version is updated.
-        } else if (TIMESTAMP_NANOS_LOGICAL_TYPE.equals(schema.getProp("logicalType"))) {
+        } else if (schema.getProp("logicalType").equals(TIMESTAMP_NANOS_LOGICAL_TYPE)) {
           // SQL type TIMESTAMP
           // ideally Instant but TableRowJsonCoder encodes as String
           return formatTimestamp((Long) v, TimestampPrecision.NANOSECONDS);
@@ -650,7 +650,8 @@ private static TableFieldSchema typedTableFieldSchema(Schema type, Boolean useAv
         }
       case LONG:
         // TODO: Use LogicalTypes.TimestampNanos once avro version is updated.
-        if (useAvroLogicalTypes && (TIMESTAMP_NANOS_LOGICAL_TYPE.equals(type.getProp("logicalType")))) {
+        if (useAvroLogicalTypes
+            && (type.getProp("logicalType").equals(TIMESTAMP_NANOS_LOGICAL_TYPE))) {
           return fieldSchema.setType("TIMESTAMP");
         }
         if (logicalType instanceof LogicalTypes.TimeMicros) {