diff options
| author | Oleg Doronin <[email protected]> | 2026-07-22 18:09:19 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2026-07-22 18:09:19 +0300 |
| commit | 1e304ce2b784be8fa0060529135cb404f9faaece (patch) | |
| tree | e9d71856e992e04fcc0eb8ffc1397ee4bd0a4de8 | |
| parent | 203250b14d217b6d4f3d0a1a22fb31ff8fcad1dd (diff) | |
fix win build for parquet (#47358)
| -rw-r--r-- | ydb/core/tx/datashard/export_data_format.h | 45 |
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 |
