diff options
| -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(); } |
