in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/types/Schema.scala [96:120]
private def toTTypeDesc(name: String, dt: DataType): TTypeDesc = {
val typeId = dt match {
case DataType.BOOLEAN => TTypeId.BOOLEAN_TYPE
case DataType.BYTE => TTypeId.TINYINT_TYPE
case DataType.SHORT => TTypeId.SMALLINT_TYPE
case DataType.INTEGER => TTypeId.INT_TYPE
case DataType.LONG => TTypeId.BIGINT_TYPE
case DataType.FLOAT => TTypeId.FLOAT_TYPE
case DataType.DOUBLE => TTypeId.DOUBLE_TYPE
case DataType.BINARY => TTypeId.BINARY_TYPE
case DataType.DECIMAL => TTypeId.DECIMAL_TYPE
case DataType.TIMESTAMP => TTypeId.TIMESTAMP_TYPE
case DataType.DATE => TTypeId.DATE_TYPE
case _ => TTypeId.STRING_TYPE
}
val primitiveEntry = new TPrimitiveTypeEntry(typeId)
if (dt == DataType.DECIMAL) {
val qualifiers = getDecimalQualifiers(name)
primitiveEntry.setTypeQualifiers(qualifiers)
}
val entry = TTypeEntry.primitiveEntry(primitiveEntry)
val desc = new TTypeDesc
desc.addToTypes(entry)
desc
}