diff options
author | aozeritsky <aozeritsky@ydb.tech> | 2023-11-14 21:02:59 +0300 |
---|---|---|
committer | aozeritsky <aozeritsky@ydb.tech> | 2023-11-14 21:28:39 +0300 |
commit | 3156e444f4cd107df59f9cc1bb85f213fc4c32ee (patch) | |
tree | 3d07229d91ea14cae5540e788ee122432b043e23 | |
parent | e7bda0b7896a51b8bf0d29fd663417a752f3547e (diff) | |
download | ydb-3156e444f4cd107df59f9cc1bb85f213fc4c32ee.tar.gz |
Remove dead code
-rw-r--r-- | ydb/library/yql/providers/dq/api/protos/task_command_executor.proto | 2 | ||||
-rw-r--r-- | ydb/library/yql/providers/dq/runtime/task_command_executor.cpp | 33 |
2 files changed, 4 insertions, 31 deletions
diff --git a/ydb/library/yql/providers/dq/api/protos/task_command_executor.proto b/ydb/library/yql/providers/dq/api/protos/task_command_executor.proto index f1bac98b9b..90d56fa932 100644 --- a/ydb/library/yql/providers/dq/api/protos/task_command_executor.proto +++ b/ydb/library/yql/providers/dq/api/protos/task_command_executor.proto @@ -141,8 +141,6 @@ message TPrepareRequest { message TSourcePushRequest { TData Data = 1; int64 Space = 2; - repeated bytes String = 3; - int32 Chunks = 4; } message TSourcePushChunk { diff --git a/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp b/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp index 6a9f2eb8ab..1851cfbec0 100644 --- a/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp +++ b/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp @@ -355,36 +355,11 @@ public: auto guard = Runner->BindAllocator(0); // Explicitly reset memory limit NDq::TDqDataSerializer dataSerializer(Runner->GetTypeEnv(), Runner->GetHolderFactory(), - NDqProto::EDataTransportVersion::DATA_TRANSPORT_VERSION_UNSPECIFIED); + NDqProto::EDataTransportVersion::DATA_TRANSPORT_UV_PICKLE_1_0); NKikimr::NMiniKQL::TUnboxedValueBatch buffer(source->GetInputType()); - if (request.GetString().empty() && request.GetChunks() == 0) { - NDq::TDqSerializedBatch batch; - batch.Proto = std::move(*request.MutableData()); - dataSerializer.Deserialize(std::move(batch), source->GetInputType(), buffer); - } else if (!request.GetString().empty()) { - for (auto& row : request.GetString()) { - buffer.emplace_back(NKikimr::NMiniKQL::MakeString(row)); - } - } else { - i64 chunks = request.GetChunks(); - for (i64 i = 0; i < chunks; i++) { - NDqProto::TSourcePushChunk chunk; - chunk.Load(&input); - i64 parts = chunk.GetParts(); - - if (parts == 1) { - buffer.emplace_back(NKikimr::NMiniKQL::MakeString(chunk.GetString())); - } else { - TString str; - for (i64 j = 0; j < parts; j++) { - NDqProto::TSourcePushPart part; - part.Load(&input); - str += part.GetString(); - } - buffer.emplace_back(NKikimr::NMiniKQL::MakeString(str)); - } - } - } + NDq::TDqSerializedBatch batch; + batch.Proto = std::move(*request.MutableData()); + dataSerializer.Deserialize(std::move(batch), source->GetInputType(), buffer); source->Push(std::move(buffer), request.GetSpace()); UpdateSourceStats(source); |