summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorOleg Doronin <[email protected]>2026-07-22 18:09:19 +0300
committerGitHub <[email protected]>2026-07-22 18:09:19 +0300
commit1e304ce2b784be8fa0060529135cb404f9faaece (patch)
treee9d71856e992e04fcc0eb8ffc1397ee4bd0a4de8
parent203250b14d217b6d4f3d0a1a22fb31ff8fcad1dd (diff)
fix win build for parquet (#47358)
-rw-r--r--ydb/core/tx/datashard/export_data_format.h45
1 files changed, 25 insertions, 20 deletions
diff --git a/ydb/core/tx/datashard/export_data_format.h b/ydb/core/tx/datashard/export_data_format.h
index 98bee919e89..1981a469105 100644
--- a/ydb/core/tx/datashard/export_data_format.h
+++ b/ydb/core/tx/datashard/export_data_format.h
@@ -1,38 +1,26 @@
#pragma once
-#ifndef KIKIMR_DISABLE_S3_OPS
-
#include "export_iface.h"
+#include <util/generic/maybe.h>
+
+#ifndef KIKIMR_DISABLE_S3_OPS
+
#include <ydb/core/tablet_flat/flat_scan_iface.h>
#include <util/generic/buffer.h>
#include <util/generic/string.h>
#include <util/generic/vector.h>
-#include <util/generic/maybe.h>
#include <memory>
class IOutputStream;
+#endif // KIKIMR_DISABLE_S3_OPS
+
namespace NKikimr {
namespace NDataShard {
-class IExportDataFormat {
-public:
- virtual bool ColumnsOrder(const TVector<ui32>& tags) = 0;
- virtual bool Collect(const NTable::IScan::TRow& row, IOutputStream& out) = 0;
- virtual TMaybe<TBuffer> Flush(bool last) = 0;
- virtual void Clear() = 0;
- // Number of encoded output bytes the format is currently holding internally
- // (data produced but not yet returned via Flush). Formats that write row
- // output directly into the Collect out stream return 0.
- virtual size_t GetReadyOutputBytes() const = 0;
- virtual TString GetError() const = 0;
-
- virtual ~IExportDataFormat() = default;
-};
-
struct TYdbDumpExportSettings {
TYdbDumpExportSettings& WithColumns(IExport::TTableColumns columns) {
Columns = std::move(columns);
@@ -82,10 +70,27 @@ struct TParquetExportSettings {
TMaybe<TCompressionSettings> CompressionSettings;
};
+#ifndef KIKIMR_DISABLE_S3_OPS
+
+class IExportDataFormat {
+public:
+ virtual bool ColumnsOrder(const TVector<ui32>& tags) = 0;
+ virtual bool Collect(const NTable::IScan::TRow& row, IOutputStream& out) = 0;
+ virtual TMaybe<TBuffer> Flush(bool last) = 0;
+ virtual void Clear() = 0;
+ // Number of encoded output bytes the format is currently holding internally
+ // (data produced but not yet returned via Flush). Formats that write row
+ // output directly into the Collect out stream return 0.
+ virtual size_t GetReadyOutputBytes() const = 0;
+ virtual TString GetError() const = 0;
+
+ virtual ~IExportDataFormat() = default;
+};
+
std::unique_ptr<IExportDataFormat> CreateExportDataFormat(TYdbDumpExportSettings&& settings);
std::unique_ptr<IExportDataFormat> CreateExportDataFormat(TParquetExportSettings&& settings);
+#endif // KIKIMR_DISABLE_S3_OPS
+
} // namespace NDataShard
} // namespace NKikimr
-
-#endif // KIKIMR_DISABLE_S3_OPS