Function flattenTupleTypeImpl

src/DataTypes/flattenTuple.cpp:15–47

{

void flattenTupleTypeImpl(const DataTypePtr & type, const String & current_path, std::vector<String> & flattened_paths, DataTypes & flattened_types)
{
    if (const auto * type_tuple = typeid_cast<const DataTypeTuple *>(removeNullable(type).get()))
    {
        const auto & tuple_names = type_tuple->getElementNames();
        const auto & tuple_types = type_tuple->getElements();

        for (size_t i = 0; i < tuple_names.size(); ++i)
        {
            String path = current_path.empty() ? tuple_names[i] : current_path + "." + tuple_names[i];
            flattenTupleTypeImpl(tuple_types[i], path, flattened_paths, flattened_types);
        }
    }
    else if (const auto * type_array = typeid_cast<const DataTypeArray *>(type.get()))
    {
        std::vector<String> flattened_element_paths;
        DataTypes flattened_element_types;

        flattenTupleTypeImpl(type_array->getNestedType(), current_path, flattened_element_paths, flattened_element_types);
        chassert(flattened_element_paths.size() == flattened_element_types.size());

        for (size_t i = 0; i < flattened_element_paths.size(); ++i)
        {
            flattened_paths.push_back(flattened_element_paths[i]);
            flattened_types.push_back(std::make_shared<DataTypeArray>(flattened_element_types[i]));
        }
    }
    else
    {
        flattened_paths.push_back(current_path);
        flattened_types.push_back(type);
    }
}

void flattenTupleColumnImpl(const ColumnPtr & column, Columns & flattened_columns, Columns & offsets_columns)
{