in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java [515:527]
public Slice getSlice(int field) {
checkFieldType(field, Slice.class);
Object record = getRecord(field);
Type type = getType(field);
if (type == VarcharType.VARCHAR) {
return Slices.utf8Slice(record.toString());
} else if (type == VarbinaryType.VARBINARY) {
return Slices.wrappedBuffer(toBytes(record));
} else {
throw new PrestoException(NOT_SUPPORTED, "Unsupported type " + type);
}
}