Skip to content

Commit 047c869

Browse files
trunc windows build fix (#8014)
1 parent b294509 commit 047c869

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

ydb/core/external_sources/object_storage/inference/arrow_fetcher.cpp

+13
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,11 @@
1414
#include <ydb/core/external_sources/object_storage/events.h>
1515
#include <ydb/library/actors/core/actor_bootstrapped.h>
1616
#include <ydb/library/actors/core/hfunc.h>
17+
18+
#if defined(_linux_) || defined(_darwin_)
1719
#include <ydb/library/yql/providers/s3/compressors/factory.h>
1820
#include <ydb/library/yql/udfs/common/clickhouse/client/src/IO/ReadBufferFromString.h>
21+
#endif
1922

2023
namespace NKikimr::NExternalSource::NObjectStorage::NInference {
2124

@@ -168,6 +171,7 @@ class TArrowFileFetcher : public NActors::TActorBootstrapped<TArrowFileFetcher>
168171
// Cutting file
169172

170173
TMaybe<TString> DecompressFile(const TString& data, const TRequest& request, const NActors::TActorContext& ctx) {
174+
#if defined(_linux_) || defined(_darwin_)
171175
try {
172176
NDB::ReadBufferFromString dataBuffer(data);
173177
auto decompressorBuffer = NYql::MakeDecompressor(dataBuffer, *DecompressionFormat_);
@@ -202,6 +206,15 @@ class TArrowFileFetcher : public NActors::TActorBootstrapped<TArrowFileFetcher>
202206
SendError(ctx, errorEv);
203207
return {};
204208
}
209+
#else
210+
auto error = MakeError(
211+
request.Path,
212+
NFq::TIssuesIds::INTERNAL_ERROR,
213+
TStringBuilder{} << "inference with decompression is not supported on windows"
214+
);
215+
SendError(ctx, error);
216+
return {};
217+
#endif
205218
}
206219

207220
std::shared_ptr<arrow::io::RandomAccessFile> CleanupCsvFile(const TString& data, const TRequest& request, const arrow::csv::ParseOptions& options, const NActors::TActorContext& ctx) {

0 commit comments

Comments
 (0)