blob: 1b1417a95a3b01c06db67ad70ce49c470fbc39eb [file]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
#pragma once
#include <nanoarrow/nanoarrow.h>
#include "iceberg/arrow_c_data.h"
#include "iceberg/iceberg_export.h"
namespace iceberg::internal {
class ICEBERG_EXPORT ArrowArrayGuard {
public:
explicit ArrowArrayGuard(ArrowArray* array) : array_(array) {}
~ArrowArrayGuard();
/// \brief Release the guard without calling ArrowArrayRelease.
///
/// Call this when ownership of the underlying ArrowArray has been
/// transferred elsewhere and the guard should not release it.
void Release() { array_ = nullptr; }
private:
ArrowArray* array_;
};
class ICEBERG_EXPORT ArrowSchemaGuard {
public:
explicit ArrowSchemaGuard(ArrowSchema* schema) : schema_(schema) {}
~ArrowSchemaGuard();
/// \brief Release the guard without calling ArrowSchemaRelease.
///
/// Call this when ownership of the underlying ArrowSchema has been
/// transferred elsewhere and the guard should not release it.
void Release() { schema_ = nullptr; }
private:
ArrowSchema* schema_;
};
class ICEBERG_EXPORT ArrowArrayViewGuard {
public:
explicit ArrowArrayViewGuard(ArrowArrayView* view) : view_(view) {}
~ArrowArrayViewGuard();
private:
ArrowArrayView* view_;
};
class ICEBERG_EXPORT ArrowArrayBufferGuard {
public:
explicit ArrowArrayBufferGuard(ArrowBuffer* buffer) : buffer_(buffer) {}
~ArrowArrayBufferGuard();
private:
ArrowBuffer* buffer_;
};
} // namespace iceberg::internal