static Set transferSetForJson()

in cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java [181:222]

• 39 lines of code
• 27 McCabe index (conditional complexity)

  static Set transferSetForJson(Set cset,DataType eleType) throws TypeNotSupported{
    Set result = new HashSet();
    switch (eleType.getName()) {
    case ASCII:
    case TEXT:
    case VARCHAR:
    case BOOLEAN:
    case SMALLINT:
    case TINYINT:
    case INT:
    case BIGINT:
    case VARINT:
    case FLOAT:
    case DOUBLE:
    case DECIMAL:
    case TIME:
    case UUID:
    case TIMEUUID:
      return cset;

    case BLOB:
    case DATE:
    case TIMESTAMP:
    case DURATION:
    case INET:
    case LIST:
    case MAP:
    case SET:
    case TUPLE:
    case UDT:
      for (Object item : cset) {
        Object newItem = transferObjectForJson(item,eleType);
        result.add(newItem);
      }
      break;

    default:
      throw new TypeNotSupported();
    }

    return result;
  }