YQ Connector: move tests from yql to ydb (OSS)

Перенос папки с тестами на Коннектор из папки yql в папку ydb (синхронизируется с github).

1 files changed, 48 insertions, 0 deletions

diff --git a/contrib/clickhouse/src/TableFunctions/TableFunctionHDFS.cpp b/contrib/clickhouse/src/TableFunctions/TableFunctionHDFS.cpp
new file mode 100644
index 00000000000..050559b16ff
--- /dev/null
+++ b/contrib/clickhouse/src/TableFunctions/TableFunctionHDFS.cpp
@@ -0,0 +1,48 @@
+#include "clickhouse_config.h"
+#include "registerTableFunctions.h"
+
+#if USE_HDFS
+#include <Storages/HDFS/StorageHDFS.h>
+#include <Storages/ColumnsDescription.h>
+#include <TableFunctions/TableFunctionFactory.h>
+#error #include <TableFunctions/TableFunctionHDFS.h>
+#include <Interpreters/parseColumnsListForTableFunction.h>
+#include <Interpreters/Context.h>
+#include <Access/Common/AccessFlags.h>
+
+namespace DB
+{
+
+StoragePtr TableFunctionHDFS::getStorage(
+    const String & source, const String & format_, const ColumnsDescription & columns, ContextPtr global_context,
+    const std::string & table_name, const String & compression_method_) const
+{
+    return std::make_shared<StorageHDFS>(
+        source,
+        StorageID(getDatabaseName(), table_name),
+        format_,
+        columns,
+        ConstraintsDescription{},
+        String{},
+        global_context,
+        compression_method_);
+}
+
+ColumnsDescription TableFunctionHDFS::getActualTableStructure(ContextPtr context, bool /*is_insert_query*/) const
+{
+    if (structure == "auto")
+    {
+        context->checkAccess(getSourceAccessType());
+        return StorageHDFS::getTableStructureFromData(format, filename, compression_method, context);
+    }
+
+    return parseColumnsListFromString(structure, context);
+}
+
+void registerTableFunctionHDFS(TableFunctionFactory & factory)
+{
+    factory.registerFunction<TableFunctionHDFS>();
+}
+
+}
+#endif