in core/src/main/java/org/apache/calcite/avatica/remote/AbstractService.java [64:101]
ColumnMetaData finagle(ColumnMetaData column) {
switch (column.type.rep) {
case BYTE:
case PRIMITIVE_BYTE:
case DOUBLE:
case PRIMITIVE_DOUBLE:
case FLOAT:
case PRIMITIVE_FLOAT:
case INTEGER:
case PRIMITIVE_INT:
case SHORT:
case PRIMITIVE_SHORT:
case LONG:
case PRIMITIVE_LONG:
return column.setRep(ColumnMetaData.Rep.NUMBER);
default:
// continue
break;
}
switch (column.type.id) {
case Types.VARBINARY:
case Types.BINARY:
switch (getSerializationType()) {
case JSON:
return column.setRep(ColumnMetaData.Rep.STRING);
case PROTOBUF:
return column;
default:
throw new IllegalStateException("Unhandled case statement with serializationType: "
+ getSerializationType());
}
case Types.DECIMAL:
case Types.NUMERIC:
return column.setRep(ColumnMetaData.Rep.NUMBER);
default:
return column;
}
}