private static String stringRep()

in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java [118:139]

• 22 lines of code
• 13 McCabe index (conditional complexity)

  private static String stringRep(@Nullable Schema schema, Object object) {
    switch (safeSchemaType(schema)) {
      case INT8:
      case INT16:
      case INT32:
      case INT64:
        return Long.toString(((Number) object).longValue());
      case FLOAT32:
      case FLOAT64:
        return Double.toString(((Number) object).doubleValue());
      case BOOLEAN:
      case STRING:
        return object.toString();
      case BYTES:
        return Base64.getEncoder().encodeToString(extractBytes(object).toByteArray());
      case ARRAY:
      case MAP:
      case STRUCT:
        throw new DataException("Cannot convert ARRAY, MAP, or STRUCT to String.");
    }
    throw new DataException("Invalid schema type.");
  }