in cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java [138:179]
static List transferListForJson(List clist, DataType eleType) throws TypeNotSupported {
List result = new ArrayList();
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 clist;
case BLOB:
case DATE:
case TIMESTAMP:
case DURATION:
case INET:
case LIST:
case MAP:
case SET:
case TUPLE:
case UDT:
for (Object item : clist) {
Object newItem = transferObjectForJson(item, eleType);
result.add(newItem);
}
break;
default:
throw new TypeNotSupported();
}
return result;
}