Function decodeDataType

src/DataTypes/DataTypesBinaryEncoding.cpp:562–848

}

static DataTypePtr decodeDataType(ReadBuffer & buf, size_t & complexity)
{
    ++complexity;
    size_t max_complexity = getMaxTypeDecodingComplexity();
    if (max_complexity > 0 && complexity > max_complexity)
        throw Exception(ErrorCodes::INCORRECT_DATA, "Binary type decoding complexity limit exceeded: {} > {} (adjust input_format_binary_max_type_complexity)", complexity, max_complexity);
    if (complexity % 128 == 0)
        checkStackSize();

    UInt8 type = 0;
    readBinary(type, buf);
    auto binary_type_index = static_cast<BinaryTypeIndex>(type);

    switch (binary_type_index)
    {
        case BinaryTypeIndex::Nothing:
        case BinaryTypeIndex::UInt8:
        case BinaryTypeIndex::Bool:
        case BinaryTypeIndex::UInt16:
        case BinaryTypeIndex::UInt32:
        case BinaryTypeIndex::UInt64:
        case BinaryTypeIndex::UInt128:
        case BinaryTypeIndex::UInt256:
        case BinaryTypeIndex::Int8:
        case BinaryTypeIndex::Int16:
        case BinaryTypeIndex::Int32:
        case BinaryTypeIndex::Int64:
        case BinaryTypeIndex::Int128:
        case BinaryTypeIndex::Int256:
        case BinaryTypeIndex::BFloat16:
        case BinaryTypeIndex::Float32:
        case BinaryTypeIndex::Float64:
        case BinaryTypeIndex::Date:
        case BinaryTypeIndex::Date32:
        case BinaryTypeIndex::String:
        case BinaryTypeIndex::UUID:
        case BinaryTypeIndex::IPv4:
        case BinaryTypeIndex::IPv6:
            return getSimpleDataTypesCache().getType(binary_type_index);
        case BinaryTypeIndex::DateTimeUTC:
            return std::make_shared<DataTypeDateTime>();
        case BinaryTypeIndex::DateTimeWithTimezone:
        {
            String time_zone;
            readStringBinary(time_zone, buf);
            return std::make_shared<DataTypeDateTime>(time_zone);
        }
        case BinaryTypeIndex::DateTime64UTC:
        {
            UInt8 scale = 0;
            readBinary(scale, buf);
            return std::make_shared<DataTypeDateTime64>(scale);
        }
        case BinaryTypeIndex::DateTime64WithTimezone:
        {
            UInt8 scale = 0;
            readBinary(scale, buf);
            String time_zone;