iscan for column tables

ydb/apps/ydbd/export/export.cpp

@@ -0,0 +1,27 @@
+#include "export.h"
+
+#include <ydb/core/tx/datashard/export_s3.h>
+
+NKikimr::NDataShard::IExport* TDataShardExportFactory::CreateExportToYt(
+        const IExport::TTask& task, const IExport::TTableColumns& columns) const
+{
+    Y_UNUSED(task);
+    Y_UNUSED(columns);
+    return nullptr; // not supported
+}
+
+NKikimr::NDataShard::IExport* TDataShardExportFactory::CreateExportToS3(
+        const IExport::TTask& task, const IExport::TTableColumns& columns) const
+{
+#ifndef KIKIMR_DISABLE_S3_OPS
+    return new NKikimr::NDataShard::TS3Export(task, columns);
+#else
+    Y_UNUSED(task);
+    Y_UNUSED(columns);
+    return nullptr;
+#endif
+}
+
+void TDataShardExportFactory::Shutdown() {
+    // No cleanup required for TDataShardExportFactory.
+}

ydb/apps/ydbd/export/export.h

@@ -0,0 +1,12 @@
+#pragma once
+
+#include <ydb/core/tx/datashard/export_iface.h>
+
+class TDataShardExportFactory : public NKikimr::NDataShard::IExportFactory {
+    using IExport = NKikimr::NDataShard::IExport;
+
+public:
+    IExport* CreateExportToYt(const IExport::TTask& task, const IExport::TTableColumns& columns) const override;
+    IExport* CreateExportToS3(const IExport::TTask& task, const IExport::TTableColumns& columns) const override;
+    void Shutdown() override;
+};

ydb/apps/ydbd/export/ya.make

@@ -0,0 +1,16 @@
+LIBRARY()
+
+SRCS(
+    export.cpp
+)
+
+PEERDIR(
+    yql/essentials/public/types
+    ydb/core/tx/columnshard/engines/scheme/defaults/protos
+    ydb/library/mkql_proto/protos
+    ydb/library/aclib/protos
+    ydb/library/formats/arrow/protos
+    ydb/core/tx/datashard
+)
+
+END()

ydb/apps/ydbd/main.cpp

@@ -1,4 +1,4 @@
-#include "export.h"
+#include "export/export.h"
 #include <ydb/core/driver_lib/run/main.h>
 #include <ydb/core/security/ticket_parser.h>
 #include <ydb/core/security/token_manager/token_manager.h>

ydb/apps/ydbd/ya.make

@@ -33,27 +33,29 @@ ENDIF()
 
 PEERDIR(
     ydb/apps/version
+    ydb/apps/ydbd/export
     ydb/core/driver_lib/run
     ydb/core/protos
     ydb/core/security
     ydb/core/tx/schemeshard
     ydb/core/ymq/actor
     ydb/core/ymq/base
+    ydb/library/breakpad
     ydb/library/folder_service/mock
     ydb/library/keys
     ydb/library/pdisk_io
     ydb/library/security
+    ydb/library/yql/udfs/common/clickhouse/client
+    ydb/library/yql/udfs/common/knn
+    ydb/library/yql/udfs/common/roaring
     yql/essentials/parser/pg_wrapper
     yql/essentials/sql/pg
-    ydb/library/yql/udfs/common/clickhouse/client
     yql/essentials/udfs/common/compress_base
     yql/essentials/udfs/common/datetime2
     yql/essentials/udfs/common/digest
     yql/essentials/udfs/common/histogram
     yql/essentials/udfs/common/hyperloglog
     yql/essentials/udfs/common/ip_base
-    ydb/library/yql/udfs/common/knn
-    ydb/library/yql/udfs/common/roaring
     yql/essentials/udfs/common/json
     yql/essentials/udfs/common/json2
     yql/essentials/udfs/common/math
@@ -68,7 +70,6 @@ PEERDIR(
     yql/essentials/udfs/common/url_base
     yql/essentials/udfs/common/yson2
     yql/essentials/udfs/logs/dsv
-    ydb/library/breakpad
 )
 
 YQL_LAST_ABI_VERSION()