private int toInt32()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java [271:286]

• 15 lines of code
• 5 McCabe index (conditional complexity)

    private int toInt32(Object fieldValue, Schema fieldSchema) {
        if (fieldValue instanceof Integer) {
            return (Integer) fieldValue;
        }
        else if (fieldValue instanceof Date) {
            LogicalType logicalType = LogicalType.getTypeByName(fieldSchema.name());
            if (logicalType == DATE) {
                // convert logicalType date to number of days
                return (int) (((Date) fieldValue).getTime() / TimeUnit.DAYS.toMillis(1));
            }
            else if (logicalType == TIME_MS) {
                return Time.fromLogical(fieldSchema, (Date) fieldValue);
            }
        }
        throw new RuntimeException("Unexpected INT32 field value type: " + fieldValue.getClass().getName());
    }