private long toInt64()

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

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

    private long toInt64(Object fieldValue, Schema fieldSchema) {
        if (fieldValue instanceof Long) {
            return (Long) fieldValue;
        }
        else if (fieldValue instanceof Date) {
            // convert based on logical type
            LogicalType logicalType = LogicalType.getTypeByName(fieldSchema.name());
            if (logicalType == TIMESTAMP_MS || logicalType == LOCAL_TIMESTAMP_MS)
                return ((Date) fieldValue).getTime();
        }
        throw new RuntimeException("Unexpected INT64 field value type: " + fieldValue.getClass().getName() + " for logical type: " + fieldSchema.name());
    }