in java/core/src/main/java/com/aliyun/openservices/tablestore/agent/util/TablestoreHelper.java [371:400]
public static Metadata columnsToMetadata(Column[] columns, Function<Column, Boolean> specialColumnConsumer) {
Metadata metadata = new Metadata();
for (Column column : columns) {
if (Boolean.TRUE.equals(specialColumnConsumer.apply(column))) {
continue;
}
String name = column.getName();
ColumnValue value = column.getValue();
switch (value.getType()) {
case DOUBLE:
metadata.put(name, value.asDouble());
break;
case INTEGER:
metadata.put(name, value.asLong());
break;
case STRING:
metadata.put(name, value.asString());
break;
case BINARY:
metadata.put(name, value.asBinary());
break;
case BOOLEAN:
metadata.put(name, value.asBoolean());
break;
default:
throw Exceptions.illegalArgument("unsupported tablestore column name:%s type:%s", name, value.getType());
}
}
return metadata;
}