in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java [212:237]
public Object getValues() {
switch (type) {
case BOOLEAN:
return (bools.length != currentSize) ? Arrays.copyOfRange(bools, 0, currentSize) : bools;
case BYTE:
return (bytes.length != currentSize) ? Arrays.copyOfRange(bytes, 0, currentSize) : bytes;
case SHORT:
return (shorts.length != currentSize) ? Arrays.copyOfRange(shorts, 0, currentSize) : shorts;
case INTEGER:
return (ints.length != currentSize) ? Arrays.copyOfRange(ints, 0, currentSize) : ints;
case LONG:
return (longs.length != currentSize) ? Arrays.copyOfRange(longs, 0, currentSize) : longs;
case FLOAT:
return (floats.length != currentSize) ? Arrays.copyOfRange(floats, 0, currentSize) : floats;
case DOUBLE:
return (doubles.length != currentSize) ? Arrays.copyOfRange(doubles, 0, currentSize)
: doubles;
case BINARY:
return toList(Arrays.stream(buffers).map(b -> (b != null) ? ByteBuffer.wrap(b) : null),
EMPTY_BUFFER);
case STRING:
return toList(Arrays.stream(strings), EMPTY_STRING);
}
return null;
}