/
usr
/
local
/
lib64
/
python3.6
/
site-packages
/
pyarrow
/
include
/
arrow
/
util
/
/usr/local/lib64/python3.6/site-packages/pyarrow/include/arrow/util
mkdir
upload
Name
Size
Mode
Actions
algorithm.h
1229
0644
edit
dl
rm
aligned_storage.h
4302
0644
edit
dl
rm
align_util.h
2636
0644
edit
dl
rm
async_generator.h
64088
0644
edit
dl
rm
async_util.h
9633
0644
edit
dl
rm
atomic_shared_ptr.h
3640
0644
edit
dl
rm
base64.h
1098
0644
edit
dl
rm
basic_decimal.h
20334
0644
edit
dl
rm
benchmark_util.h
4584
0644
edit
dl
rm
bitmap.h
17463
0644
edit
dl
rm
bitmap_builders.h
1563
0644
edit
dl
rm
bitmap_generate.h
3563
0644
edit
dl
rm
bitmap_ops.h
9084
0644
edit
dl
rm
bitmap_reader.h
8347
0644
edit
dl
rm
bitmap_visit.h
3460
0644
edit
dl
rm
bitmap_writer.h
9360
0644
edit
dl
rm
bitset_stack.h
2789
0644
edit
dl
rm
bit_block_counter.h
19141
0644
edit
dl
rm
bit_run_reader.h
16599
0644
edit
dl
rm
bit_stream_utils.h
16986
0644
edit
dl
rm
bit_util.h
11568
0644
edit
dl
rm
bpacking.h
1175
0644
edit
dl
rm
bpacking64_default.h
195934
0644
edit
dl
rm
bpacking_avx2.h
1009
0644
edit
dl
rm
bpacking_avx512.h
1011
0644
edit
dl
rm
bpacking_default.h
103232
0644
edit
dl
rm
bpacking_neon.h
1009
0644
edit
dl
rm
bpacking_simd128_generated.h
98529
0644
edit
dl
rm
bpacking_simd256_generated.h
77475
0644
edit
dl
rm
bpacking_simd512_generated.h
67081
0644
edit
dl
rm
byte_stream_split.h
28784
0644
edit
dl
rm
cancel.h
2911
0644
edit
dl
rm
checked_cast.h
2076
0644
edit
dl
rm
compare.h
1981
0644
edit
dl
rm
compression.h
7367
0644
edit
dl
rm
concurrent_map.h
1775
0644
edit
dl
rm
config.h
1659
0644
edit
dl
rm
converter.h
14657
0644
edit
dl
rm
counting_semaphore.h
2251
0644
edit
dl
rm
cpu_info.h
4724
0644
edit
dl
rm
decimal.h
11687
0644
edit
dl
rm
delimiting.h
7335
0644
edit
dl
rm
dispatch.h
3235
0644
edit
dl
rm
double_conversion.h
1195
0644
edit
dl
rm
endian.h
8071
0644
edit
dl
rm
formatting.h
20612
0644
edit
dl
rm
functional.h
5612
0644
edit
dl
rm
future.h
36168
0644
edit
dl
rm
future_iterator.h
2517
0644
edit
dl
rm
hashing.h
30633
0644
edit
dl
rm
hash_util.h
1914
0644
edit
dl
rm
int_util.h
4284
0644
edit
dl
rm
io_util.h
10326
0644
edit
dl
rm
iterator.h
18123
0644
edit
dl
rm
key_value_metadata.h
3579
0644
edit
dl
rm
launder.h
1051
0644
edit
dl
rm
logging.h
9338
0644
edit
dl
rm
macros.h
7349
0644
edit
dl
rm
make_unique.h
1475
0644
edit
dl
rm
map.h
2476
0644
edit
dl
rm
math_constants.h
1106
0644
edit
dl
rm
memory.h
1566
0644
edit
dl
rm
mutex.h
1833
0644
edit
dl
rm
optional.h
1174
0644
edit
dl
rm
parallel.h
3616
0644
edit
dl
rm
pcg_random.h
1146
0644
edit
dl
rm
print.h
1725
0644
edit
dl
rm
queue.h
1017
0644
edit
dl
rm
range.h
4834
0644
edit
dl
rm
rle_encoding.h
31029
0644
edit
dl
rm
simd.h
1333
0644
edit
dl
rm
small_vector.h
14660
0644
edit
dl
rm
sort.h
2466
0644
edit
dl
rm
spaced.h
3567
0644
edit
dl
rm
stopwatch.h
1401
0644
edit
dl
rm
string.h
2570
0644
edit
dl
rm
string_builder.h
2446
0644
edit
dl
rm
string_view.h
1269
0644
edit
dl
rm
task_group.h
4362
0644
edit
dl
rm
tdigest.h
3052
0644
edit
dl
rm
test_common.h
2837
0644
edit
dl
rm
thread_pool.h
15338
0644
edit
dl
rm
time.h
2988
0644
edit
dl
rm
trie.h
7157
0644
edit
dl
rm
type_fwd.h
1409
0644
edit
dl
rm
type_traits.h
2894
0644
edit
dl
rm
ubsan.h
2777
0644
edit
dl
rm
unreachable.h
926
0644
edit
dl
rm
uri.h
3297
0644
edit
dl
rm
utf8.h
18780
0644
edit
dl
rm
value_parsing.h
27056
0644
edit
dl
rm
variant.h
13728
0644
edit
dl
rm
vector.h
5665
0644
edit
dl
rm
visibility.h
1463
0644
edit
dl
rm
windows_compatibility.h
1260
0644
edit
dl
rm
windows_fixup.h
1379
0644
edit
dl
rm
Edit:
/usr/local/lib64/python3.6/site-packages/pyarrow/include/arrow/util/decimal.h
(11687B)
// 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 <cstdint> #include <iosfwd> #include <limits> #include <string> #include <utility> #include "arrow/result.h" #include "arrow/status.h" #include "arrow/type_fwd.h" #include "arrow/util/basic_decimal.h" #include "arrow/util/string_view.h" namespace arrow { /// Represents a signed 128-bit integer in two's complement. /// Calculations wrap around and overflow is ignored. /// The max decimal precision that can be safely represented is /// 38 significant digits. /// /// For a discussion of the algorithms, look at Knuth's volume 2, /// Semi-numerical Algorithms section 4.3.1. /// /// Adapted from the Apache ORC C++ implementation /// /// The implementation is split into two parts : /// /// 1. BasicDecimal128 /// - can be safely compiled to IR without references to libstdc++. /// 2. Decimal128 /// - has additional functionality on top of BasicDecimal128 to deal with /// strings and streams. class ARROW_EXPORT Decimal128 : public BasicDecimal128 { public: /// \cond FALSE // (need to avoid a duplicate definition in Sphinx) using BasicDecimal128::BasicDecimal128; /// \endcond /// \brief constructor creates a Decimal128 from a BasicDecimal128. constexpr Decimal128(const BasicDecimal128& value) noexcept // NOLINT runtime/explicit : BasicDecimal128(value) {} /// \brief Parse the number from a base 10 string representation. explicit Decimal128(const std::string& value); /// \brief Empty constructor creates a Decimal128 with a value of 0. // This is required on some older compilers. constexpr Decimal128() noexcept : BasicDecimal128() {} /// Divide this number by right and return the result. /// /// This operation is not destructive. /// The answer rounds to zero. Signs work like: /// 21 / 5 -> 4, 1 /// -21 / 5 -> -4, -1 /// 21 / -5 -> -4, 1 /// -21 / -5 -> 4, -1 /// \param[in] divisor the number to divide by /// \return the pair of the quotient and the remainder Result<std::pair<Decimal128, Decimal128>> Divide(const Decimal128& divisor) const { std::pair<Decimal128, Decimal128> result; auto dstatus = BasicDecimal128::Divide(divisor, &result.first, &result.second); ARROW_RETURN_NOT_OK(ToArrowStatus(dstatus)); return std::move(result); } /// \brief Convert the Decimal128 value to a base 10 decimal string with the given /// scale. std::string ToString(int32_t scale) const; /// \brief Convert the value to an integer string std::string ToIntegerString() const; /// \brief Cast this value to an int64_t. explicit operator int64_t() const; /// \brief Convert a decimal string to a Decimal128 value, optionally including /// precision and scale if they're passed in and not null. static Status FromString(const util::string_view& s, Decimal128* out, int32_t* precision, int32_t* scale = NULLPTR); static Status FromString(const std::string& s, Decimal128* out, int32_t* precision, int32_t* scale = NULLPTR); static Status FromString(const char* s, Decimal128* out, int32_t* precision, int32_t* scale = NULLPTR); static Result<Decimal128> FromString(const util::string_view& s); static Result<Decimal128> FromString(const std::string& s); static Result<Decimal128> FromString(const char* s); static Result<Decimal128> FromReal(double real, int32_t precision, int32_t scale); static Result<Decimal128> FromReal(float real, int32_t precision, int32_t scale); /// \brief Convert from a big-endian byte representation. The length must be /// between 1 and 16. /// \return error status if the length is an invalid value static Result<Decimal128> FromBigEndian(const uint8_t* data, int32_t length); /// \brief Convert Decimal128 from one scale to another Result<Decimal128> Rescale(int32_t original_scale, int32_t new_scale) const { Decimal128 out; auto dstatus = BasicDecimal128::Rescale(original_scale, new_scale, &out); ARROW_RETURN_NOT_OK(ToArrowStatus(dstatus)); return std::move(out); } /// \brief Convert to a signed integer template <typename T, typename = internal::EnableIfIsOneOf<T, int32_t, int64_t>> Result<T> ToInteger() const { constexpr auto min_value = std::numeric_limits<T>::min(); constexpr auto max_value = std::numeric_limits<T>::max(); const auto& self = *this; if (self < min_value || self > max_value) { return Status::Invalid("Invalid cast from Decimal128 to ", sizeof(T), " byte integer"); } return static_cast<T>(low_bits()); } /// \brief Convert to a signed integer template <typename T, typename = internal::EnableIfIsOneOf<T, int32_t, int64_t>> Status ToInteger(T* out) const { return ToInteger<T>().Value(out); } /// \brief Convert to a floating-point number (scaled) float ToFloat(int32_t scale) const; /// \brief Convert to a floating-point number (scaled) double ToDouble(int32_t scale) const; /// \brief Convert to a floating-point number (scaled) template <typename T> T ToReal(int32_t scale) const { return ToRealConversion<T>::ToReal(*this, scale); } friend ARROW_EXPORT std::ostream& operator<<(std::ostream& os, const Decimal128& decimal); private: /// Converts internal error code to Status Status ToArrowStatus(DecimalStatus dstatus) const; template <typename T> struct ToRealConversion {}; }; template <> struct Decimal128::ToRealConversion<float> { static float ToReal(const Decimal128& dec, int32_t scale) { return dec.ToFloat(scale); } }; template <> struct Decimal128::ToRealConversion<double> { static double ToReal(const Decimal128& dec, int32_t scale) { return dec.ToDouble(scale); } }; /// Represents a signed 256-bit integer in two's complement. /// The max decimal precision that can be safely represented is /// 76 significant digits. /// /// The implementation is split into two parts : /// /// 1. BasicDecimal256 /// - can be safely compiled to IR without references to libstdc++. /// 2. Decimal256 /// - (TODO) has additional functionality on top of BasicDecimal256 to deal with /// strings and streams. class ARROW_EXPORT Decimal256 : public BasicDecimal256 { public: /// \cond FALSE // (need to avoid a duplicate definition in Sphinx) using BasicDecimal256::BasicDecimal256; /// \endcond /// \brief constructor creates a Decimal256 from a BasicDecimal256. constexpr Decimal256(const BasicDecimal256& value) noexcept : BasicDecimal256(value) {} /// \brief Parse the number from a base 10 string representation. explicit Decimal256(const std::string& value); /// \brief Empty constructor creates a Decimal256 with a value of 0. // This is required on some older compilers. constexpr Decimal256() noexcept : BasicDecimal256() {} /// \brief Convert the Decimal256 value to a base 10 decimal string with the given /// scale. std::string ToString(int32_t scale) const; /// \brief Convert the value to an integer string std::string ToIntegerString() const; /// \brief Convert a decimal string to a Decimal256 value, optionally including /// precision and scale if they're passed in and not null. static Status FromString(const util::string_view& s, Decimal256* out, int32_t* precision, int32_t* scale = NULLPTR); static Status FromString(const std::string& s, Decimal256* out, int32_t* precision, int32_t* scale = NULLPTR); static Status FromString(const char* s, Decimal256* out, int32_t* precision, int32_t* scale = NULLPTR); static Result<Decimal256> FromString(const util::string_view& s); static Result<Decimal256> FromString(const std::string& s); static Result<Decimal256> FromString(const char* s); /// \brief Convert Decimal256 from one scale to another Result<Decimal256> Rescale(int32_t original_scale, int32_t new_scale) const { Decimal256 out; auto dstatus = BasicDecimal256::Rescale(original_scale, new_scale, &out); ARROW_RETURN_NOT_OK(ToArrowStatus(dstatus)); return std::move(out); } /// Divide this number by right and return the result. /// /// This operation is not destructive. /// The answer rounds to zero. Signs work like: /// 21 / 5 -> 4, 1 /// -21 / 5 -> -4, -1 /// 21 / -5 -> -4, 1 /// -21 / -5 -> 4, -1 /// \param[in] divisor the number to divide by /// \return the pair of the quotient and the remainder Result<std::pair<Decimal256, Decimal256>> Divide(const Decimal256& divisor) const { std::pair<Decimal256, Decimal256> result; auto dstatus = BasicDecimal256::Divide(divisor, &result.first, &result.second); ARROW_RETURN_NOT_OK(ToArrowStatus(dstatus)); return std::move(result); } /// \brief Convert from a big-endian byte representation. The length must be /// between 1 and 32. /// \return error status if the length is an invalid value static Result<Decimal256> FromBigEndian(const uint8_t* data, int32_t length); static Result<Decimal256> FromReal(double real, int32_t precision, int32_t scale); static Result<Decimal256> FromReal(float real, int32_t precision, int32_t scale); /// \brief Convert to a floating-point number (scaled). /// May return infinity in case of overflow. float ToFloat(int32_t scale) const; /// \brief Convert to a floating-point number (scaled) double ToDouble(int32_t scale) const; /// \brief Convert to a floating-point number (scaled) template <typename T> T ToReal(int32_t scale) const { return ToRealConversion<T>::ToReal(*this, scale); } friend ARROW_EXPORT std::ostream& operator<<(std::ostream& os, const Decimal256& decimal); private: /// Converts internal error code to Status Status ToArrowStatus(DecimalStatus dstatus) const; template <typename T> struct ToRealConversion {}; }; template <> struct Decimal256::ToRealConversion<float> { static float ToReal(const Decimal256& dec, int32_t scale) { return dec.ToFloat(scale); } }; template <> struct Decimal256::ToRealConversion<double> { static double ToReal(const Decimal256& dec, int32_t scale) { return dec.ToDouble(scale); } }; /// For an integer type, return the max number of decimal digits /// (=minimal decimal precision) it can represent. inline Result<int32_t> MaxDecimalDigitsForInteger(Type::type type_id) { switch (type_id) { case Type::INT8: case Type::UINT8: return 3; case Type::INT16: case Type::UINT16: return 5; case Type::INT32: case Type::UINT32: return 10; case Type::INT64: case Type::UINT64: return 19; default: break; } return Status::Invalid("Not an integer type: ", type_id); } } // namespace arrow
Save
cmd:
run