in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java [93:127]
private ColumnBuffer(DataType type, byte[] nulls, Object values, int currentSize) {
this.type = type;
this.nulls = nulls;
this.currentSize = currentSize;
switch (type) {
case BOOLEAN:
bools = (boolean[]) values;
break;
case BYTE:
bytes = (byte[]) values;
break;
case SHORT:
shorts = (short[]) values;
break;
case INTEGER:
ints = (int[]) values;
break;
case LONG:
longs = (long[]) values;
break;
case FLOAT:
floats = (float[]) values;
break;
case DOUBLE:
doubles = (double[]) values;
break;
case BINARY:
buffers = (byte[][]) values;
break;
case STRING:
strings = (String[]) values;
break;
}
}