in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SqlToCqlTypeConverter.java [308:342]
public BigDecimal convertInternal(Object object)
{
if (object instanceof BigDecimal)
{
return (BigDecimal) object;
}
else if (object instanceof scala.math.BigDecimal)
{
return ((scala.math.BigDecimal) object).bigDecimal();
}
else if (object instanceof String)
{
return new BigDecimal((String) object);
}
else if (object instanceof Double)
{
return BigDecimal.valueOf((Double) object);
}
else if (object instanceof Float)
{
return BigDecimal.valueOf((Float) object);
}
else if (object instanceof Long)
{
return BigDecimal.valueOf((Long) object);
}
else if (object instanceof Integer)
{
return BigDecimal.valueOf((Integer) object);
}
else
{
throw new RuntimeException("Unsupported conversion for DECIMAL from " + object.getClass().getTypeName());
}
}