in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java [170:210]
public void add(Object value) {
if (value == null) {
setNull(currentSize);
currentSize++;
return;
}
ensureCapacity();
switch (type) {
case BOOLEAN:
bools[currentSize] = (boolean) value;
break;
case BYTE:
bytes[currentSize] = (byte) value;
break;
case SHORT:
shorts[currentSize] = (short) value;
break;
case INTEGER:
ints[currentSize] = (int) value;
break;
case LONG:
longs[currentSize] = (long) value;
break;
case FLOAT:
floats[currentSize] = (float) value;
break;
case DOUBLE:
doubles[currentSize] = (double) value;
break;
case BINARY:
buffers[currentSize] = (byte[]) value;
break;
case STRING:
strings[currentSize] = (String) value;
break;
}
currentSize += 1;
}