icebergLocalCluster table function

This commit is contained in:
Anton Ivashkin
2026-01-02 15:29:30 +01:00
parent 48f3d59232
commit 656741ca70
12 changed files with 115 additions and 21 deletions
@@ -70,7 +70,8 @@ StoragePtr TableFunctionObjectStorageCluster<Definition, Configuration, is_data_
columns,
ConstraintsDescription{},
Base::partition_by,
context);
context,
/* is_table_function */true);
}
storage->startup();
@@ -131,6 +132,13 @@ void registerTableFunctionIcebergCluster(TableFunctionFactory & factory)
{
UNUSED(factory);
factory.registerFunction<TableFunctionIcebergLocalCluster>(
{.documentation
= {.description = R"(The table function can be used to read the Iceberg table stored on shared storage in parallel for many nodes in a specified cluster.)",
.examples{{IcebergLocalClusterDefinition::name, "SELECT * FROM icebergLocalCluster(cluster, filename, format, [,compression])", ""}},
.category = FunctionDocumentation::Category::TableFunction},
.allow_readonly = false});
#if USE_AWS_S3
factory.registerFunction<TableFunctionIcebergCluster>(
{.documentation