diff options
| author | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-09-05 16:10:33 +0300 |
|---|---|---|
| committer | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-09-05 17:26:55 +0300 |
| commit | 668d419cb2c5c0fe9a0827c904e6ae9895635e16 (patch) | |
| tree | 7e6bab8e4a83f77557253296d6359078f41ec2b7 | |
| parent | 4493818feb0ec068c9838cdfe07e026a04dd3a2a (diff) | |
| download | ydb-668d419cb2c5c0fe9a0827c904e6ae9895635e16.tar.gz | |
clean trash
| -rw-r--r-- | ydb/core/formats/arrow/arrow_helpers.cpp | 13 | ||||
| -rw-r--r-- | ydb/core/formats/arrow/arrow_helpers.h | 2 |
2 files changed, 0 insertions, 15 deletions
diff --git a/ydb/core/formats/arrow/arrow_helpers.cpp b/ydb/core/formats/arrow/arrow_helpers.cpp index e0a43ddf773..43af9fb5dc0 100644 --- a/ydb/core/formats/arrow/arrow_helpers.cpp +++ b/ydb/core/formats/arrow/arrow_helpers.cpp @@ -786,19 +786,6 @@ std::partial_ordering ColumnsCompare(const std::vector<std::shared_ptr<arrow::Ar return TRawReplaceKey(&x, xRow).CompareNotNull(TRawReplaceKey(&y, yRow)); } -std::shared_ptr<arrow::RecordBatch> BuildSingleRecordBatch(const std::shared_ptr<arrow::Schema> schema, const std::vector<std::shared_ptr<arrow::Scalar>>& recordData) { - std::vector<std::unique_ptr<arrow::ArrayBuilder>> builders = MakeBuilders(schema, 1); - Y_VERIFY(builders.size() == recordData.size()); - for (ui32 i = 0; i < recordData.size(); ++i) { - Y_VERIFY(recordData[i]); - Y_VERIFY_OK(builders[i]->AppendScalar(*recordData[i])); - } - - auto arrays = NArrow::Finish(std::move(builders)); - Y_VERIFY(arrays.size() == builders.size()); - return arrow::RecordBatch::Make(schema, 1, arrays); -} - NJson::TJsonValue DebugJson(std::shared_ptr<arrow::RecordBatch> array, const ui32 position) { NJson::TJsonValue result = NJson::JSON_ARRAY; for (auto&& i : array->columns()) { diff --git a/ydb/core/formats/arrow/arrow_helpers.h b/ydb/core/formats/arrow/arrow_helpers.h index f71e4742b52..fb012391c40 100644 --- a/ydb/core/formats/arrow/arrow_helpers.h +++ b/ydb/core/formats/arrow/arrow_helpers.h @@ -121,8 +121,6 @@ bool ScalarLess(const std::shared_ptr<arrow::Scalar>& x, const std::shared_ptr<a bool ScalarLess(const arrow::Scalar& x, const arrow::Scalar& y); std::shared_ptr<arrow::RecordBatch> ReallocateBatch(std::shared_ptr<arrow::RecordBatch> original); -std::shared_ptr<arrow::RecordBatch> BuildSingleRecordBatch(const std::shared_ptr<arrow::Schema> schema, const std::vector<std::shared_ptr<arrow::Scalar>>& recordData); - inline bool HasNulls(const std::shared_ptr<arrow::Array>& column) { return column->null_bitmap_data(); } |