This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 76da8e13e8 chore: Upgrade to `arrow`/`parquet` `54.1.0` and fix
clippy/ci (#14415)
76da8e13e8 is described below
commit 76da8e13e817e81235afcb6b48d0ecd3984c7669
Author: Alex Huang <[email protected]>
AuthorDate: Mon Feb 3 19:39:34 2025 +0800
chore: Upgrade to `arrow`/`parquet` `54.1.0` and fix clippy/ci (#14415)
* chore: Fixed CI
* chore
* chore: Fixed clippy
* chore
---
Cargo.toml | 16 +-
datafusion-cli/Cargo.lock | 176 ++---
datafusion-cli/Cargo.toml | 4 +-
.../src/datasource/physical_plan/arrow_file.rs | 11 +-
datafusion/expr-common/src/interval_arithmetic.rs | 714 +--------------------
.../optimizer/src/unwrap_cast_in_comparison.rs | 7 +-
6 files changed, 121 insertions(+), 807 deletions(-)
diff --git a/Cargo.toml b/Cargo.toml
index c17f4f7aff..55855d09d5 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -77,21 +77,21 @@ version = "45.0.0"
ahash = { version = "0.8", default-features = false, features = [
"runtime-rng",
] }
-arrow = { version = "54.0.0", features = [
+arrow = { version = "54.1.0", features = [
"prettyprint",
] }
-arrow-array = { version = "54.0.0", default-features = false, features = [
+arrow-array = { version = "54.1.0", default-features = false, features = [
"chrono-tz",
] }
-arrow-buffer = { version = "54.0.0", default-features = false }
-arrow-flight = { version = "54.0.0", features = [
+arrow-buffer = { version = "54.1.0", default-features = false }
+arrow-flight = { version = "54.1.0", features = [
"flight-sql-experimental",
] }
-arrow-ipc = { version = "54.0.0", default-features = false, features = [
+arrow-ipc = { version = "54.1.0", default-features = false, features = [
"lz4",
] }
-arrow-ord = { version = "54.0.0", default-features = false }
-arrow-schema = { version = "54.0.0", default-features = false }
+arrow-ord = { version = "54.1.0", default-features = false }
+arrow-schema = { version = "54.1.0", default-features = false }
async-trait = "0.1.73"
bigdecimal = "0.4.7"
bytes = "1.4"
@@ -133,7 +133,7 @@ itertools = "0.14"
log = "^0.4"
object_store = { version = "0.11.0", default-features = false }
parking_lot = "0.12"
-parquet = { version = "54.0.0", default-features = false, features = [
+parquet = { version = "54.1.0", default-features = false, features = [
"arrow",
"async",
"object_store",
diff --git a/datafusion-cli/Cargo.lock b/datafusion-cli/Cargo.lock
index 6982ad86e5..e613e7eb92 100644
--- a/datafusion-cli/Cargo.lock
+++ b/datafusion-cli/Cargo.lock
@@ -31,7 +31,7 @@ checksum =
"e89da841a80418a9b391ebaea17f5c112ffaaa96f621d2c285b5174da76b9011"
dependencies = [
"cfg-if",
"const-random",
- "getrandom",
+ "getrandom 0.2.15",
"once_cell",
"version_check",
"zerocopy",
@@ -175,9 +175,9 @@ checksum =
"7c02d123df017efcdfbd739ef81735b36c5ba83ec3c59c80a9d7ecc718f92e50"
[[package]]
name = "arrow"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "d2ccdcc8fb14508ca20aaec7076032e5c0b0751b906036d4496786e2f227a37a"
+checksum = "6422e12ac345a0678d7a17e316238e3a40547ae7f92052b77bd86d5e0239f3fc"
dependencies = [
"arrow-arith",
"arrow-array",
@@ -196,9 +196,9 @@ dependencies = [
[[package]]
name = "arrow-arith"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "a1aad8e27f32e411a0fc0bf5a625a35f0bf9b9f871cf4542abe31f7cef4beea2"
+checksum = "23cf34bb1f48c41d3475927bcc7be498665b8e80b379b88f62a840337f8b8248"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -210,9 +210,9 @@ dependencies = [
[[package]]
name = "arrow-array"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "bd6ed90c28c6f73a706c55799b8cc3a094e89257238e5b1d65ca7c70bd3ae23f"
+checksum = "fb4a06d507f54b70a277be22a127c8ffe0cec6cd98c0ad8a48e77779bbda8223"
dependencies = [
"ahash",
"arrow-buffer",
@@ -227,9 +227,9 @@ dependencies = [
[[package]]
name = "arrow-buffer"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "fe4a40bdc1552ea10fbdeae4e5a945d8572c32f66bce457b96c13d9c46b80447"
+checksum = "d69d326d5ad1cb82dcefa9ede3fee8fdca98f9982756b16f9cb142f4aa6edc89"
dependencies = [
"bytes",
"half",
@@ -238,9 +238,9 @@ dependencies = [
[[package]]
name = "arrow-cast"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "430c0a21aa7f81bcf0f97c57216d7127795ea755f494d27bae2bd233be43c2cc"
+checksum = "626e65bd42636a84a238bed49d09c8777e3d825bf81f5087a70111c2831d9870"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -259,9 +259,9 @@ dependencies = [
[[package]]
name = "arrow-csv"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "b4444c8f8c57ac00e6a679ede67d1ae8872c170797dc45b46f75702437a77888"
+checksum = "71c8f959f7a1389b1dbd883cdcd37c3ed12475329c111912f7f69dad8195d8c6"
dependencies = [
"arrow-array",
"arrow-cast",
@@ -275,9 +275,9 @@ dependencies = [
[[package]]
name = "arrow-data"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "09af476cfbe9879937e50b1334c73189de6039186e025b1b1ac84b283b87b20e"
+checksum = "1858e7c7d01c44cf71c21a85534fd1a54501e8d60d1195d0d6fbcc00f4b10754"
dependencies = [
"arrow-buffer",
"arrow-schema",
@@ -287,9 +287,9 @@ dependencies = [
[[package]]
name = "arrow-ipc"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "136296e8824333a8a4c4a6e508e4aa65d5678b801246d0408825ae7b2523c628"
+checksum = "a6bb3f727f049884c7603f0364bc9315363f356b59e9f605ea76541847e06a1e"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -301,9 +301,9 @@ dependencies = [
[[package]]
name = "arrow-json"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "e222ad0e419ab8276818c5605a5bb1e35ed86fa8c5e550726433cc63b09c3c78"
+checksum = "35de94f165ed8830aede72c35f238763794f0d49c69d30c44d49c9834267ff8c"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -321,9 +321,9 @@ dependencies = [
[[package]]
name = "arrow-ord"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "eddf14c5f03b679ec8ceac4dfac43f63cdc4ed54dab3cc120a4ef46af38481eb"
+checksum = "8aa06e5f267dc53efbacb933485c79b6fc1685d3ffbe870a16ce4e696fb429da"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -334,9 +334,9 @@ dependencies = [
[[package]]
name = "arrow-row"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "e9acdc58da19f383f4ba381fa0e3583534ae2ceb31269aaf4a03f08ff13e8443"
+checksum = "66f1144bb456a2f9d82677bd3abcea019217e572fc8f07de5a7bac4b2c56eb2c"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -347,15 +347,15 @@ dependencies = [
[[package]]
name = "arrow-schema"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "3a1822a1a952955637e85e8f9d6b0e04dd75d65492b87ec548dd593d3a1f772b"
+checksum = "105f01ec0090259e9a33a9263ec18ff223ab91a0ea9fbc18042f7e38005142f6"
[[package]]
name = "arrow-select"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "5c4172e9a12dfe15303d3926269f9ead471ea93bdd067d113abc65cb6c48e246"
+checksum = "f690752fdbd2dee278b5f1636fefad8f2f7134c85e20fd59c4199e15a39a6807"
dependencies = [
"ahash",
"arrow-array",
@@ -367,9 +367,9 @@ dependencies = [
[[package]]
name = "arrow-string"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "73683040445f4932342781926189901c9521bb1a787c35dbe628a3ce51372d3c"
+checksum = "d0fff9cd745a7039b66c47ecaf5954460f9fa12eed628f65170117ea93e64ee0"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -417,9 +417,9 @@ dependencies = [
[[package]]
name = "async-trait"
-version = "0.1.85"
+version = "0.1.86"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "3f934833b4b7233644e5848f235df3f57ed8c80f1528a26c3dfa13d2147fa056"
+checksum = "644dd749086bf3771a2fbc5f256fdb982d53f011c7d5d560304eafeecebce79d"
dependencies = [
"proc-macro2",
"quote",
@@ -449,9 +449,9 @@ checksum =
"ace50bade8e6234aa140d9a2f552bbee1db4d353f69b8217bc503490fc1a9f26"
[[package]]
name = "aws-config"
-version = "1.5.10"
+version = "1.5.15"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "9b49afaa341e8dd8577e1a2200468f98956d6eda50bcf4a53246cc00174ba924"
+checksum = "dc47e70fc35d054c8fcd296d47a61711f043ac80534a10b4f741904f81e73a90"
dependencies = [
"aws-credential-types",
"aws-runtime",
@@ -460,7 +460,7 @@ dependencies = [
"aws-sdk-sts",
"aws-smithy-async",
"aws-smithy-http",
- "aws-smithy-json 0.60.7",
+ "aws-smithy-json",
"aws-smithy-runtime",
"aws-smithy-runtime-api",
"aws-smithy-types",
@@ -524,7 +524,7 @@ dependencies = [
"aws-runtime",
"aws-smithy-async",
"aws-smithy-http",
- "aws-smithy-json 0.61.2",
+ "aws-smithy-json",
"aws-smithy-runtime",
"aws-smithy-runtime-api",
"aws-smithy-types",
@@ -546,7 +546,7 @@ dependencies = [
"aws-runtime",
"aws-smithy-async",
"aws-smithy-http",
- "aws-smithy-json 0.61.2",
+ "aws-smithy-json",
"aws-smithy-runtime",
"aws-smithy-runtime-api",
"aws-smithy-types",
@@ -568,7 +568,7 @@ dependencies = [
"aws-runtime",
"aws-smithy-async",
"aws-smithy-http",
- "aws-smithy-json 0.61.2",
+ "aws-smithy-json",
"aws-smithy-query",
"aws-smithy-runtime",
"aws-smithy-runtime-api",
@@ -635,15 +635,6 @@ dependencies = [
"tracing",
]
-[[package]]
-name = "aws-smithy-json"
-version = "0.60.7"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "4683df9469ef09468dad3473d129960119a0d3593617542b7d52086c8486f2d6"
-dependencies = [
- "aws-smithy-types",
-]
-
[[package]]
name = "aws-smithy-json"
version = "0.61.2"
@@ -943,9 +934,9 @@ dependencies = [
[[package]]
name = "cc"
-version = "1.2.10"
+version = "1.2.11"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "13208fcbb66eaeffe09b99fffbe1af420f00a7b35aa99ad683dfc1aa76145229"
+checksum = "e4730490333d58093109dc02c23174c3f4d490998c3fed3cc8e82d57afedb9cf"
dependencies = [
"jobserver",
"libc",
@@ -1079,7 +1070,7 @@ version = "0.1.16"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "f9d839f2a20b0aee515dc581a6172f2321f96cab76c1a38a4c584a194955390e"
dependencies = [
- "getrandom",
+ "getrandom 0.2.15",
"once_cell",
"tiny-keccak",
]
@@ -1952,10 +1943,22 @@ dependencies = [
"cfg-if",
"js-sys",
"libc",
- "wasi",
+ "wasi 0.11.0+wasi-snapshot-preview1",
"wasm-bindgen",
]
+[[package]]
+name = "getrandom"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index";
+checksum = "43a49c392881ce6d5c3b8cb70f98717b7c07aabbdff06687b9030dbfbe2725f8"
+dependencies = [
+ "cfg-if",
+ "libc",
+ "wasi 0.13.3+wasi-0.2.2",
+ "windows-targets",
+]
+
[[package]]
name = "gimli"
version = "0.31.1"
@@ -2207,7 +2210,7 @@ dependencies = [
"http 1.2.0",
"hyper 1.6.0",
"hyper-util",
- "rustls 0.23.21",
+ "rustls 0.23.22",
"rustls-native-certs 0.8.1",
"rustls-pki-types",
"tokio",
@@ -2688,7 +2691,7 @@ source =
"registry+https://github.com/rust-lang/crates.io-index";
checksum = "2886843bf800fba2e3377cff24abf6379b4c4d5c6681eaf9ea5b0d15090450bd"
dependencies = [
"libc",
- "wasi",
+ "wasi 0.11.0+wasi-snapshot-preview1",
"windows-sys 0.52.0",
]
@@ -2898,9 +2901,9 @@ dependencies = [
[[package]]
name = "parquet"
-version = "54.0.0"
+version = "54.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "3334c50239d9f4951653d84fa6f636da86f53742e5e5849a30fbe852f3ff4383"
+checksum = "8a01a0efa30bbd601ae85b375c728efdb211ade54390281628a7b16708beb235"
dependencies = [
"ahash",
"arrow-array",
@@ -2924,6 +2927,7 @@ dependencies = [
"object_store",
"paste",
"seq-macro",
+ "simdutf8",
"snap",
"thrift",
"tokio",
@@ -3118,7 +3122,7 @@ dependencies = [
"quinn-proto",
"quinn-udp",
"rustc-hash",
- "rustls 0.23.21",
+ "rustls 0.23.22",
"socket2",
"thiserror 2.0.11",
"tokio",
@@ -3132,11 +3136,11 @@ source =
"registry+https://github.com/rust-lang/crates.io-index";
checksum = "a2fe5ef3495d7d2e377ff17b1a8ce2ee2ec2a18cde8b6ad6619d65d0701c135d"
dependencies = [
"bytes",
- "getrandom",
+ "getrandom 0.2.15",
"rand",
"ring",
"rustc-hash",
- "rustls 0.23.21",
+ "rustls 0.23.22",
"rustls-pki-types",
"slab",
"thiserror 2.0.11",
@@ -3205,7 +3209,7 @@ version = "0.6.4"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "ec0be4795e2f6a28069bec0b5ff3e2ac9bafc99e6a9a7dc3547996c5c816922c"
dependencies = [
- "getrandom",
+ "getrandom 0.2.15",
]
[[package]]
@@ -3243,7 +3247,7 @@ version = "0.5.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "dd6f9d3d47bdd2ad6945c5015a226ec6155d0bcdfd8f7cd29f86b71f8de99d2b"
dependencies = [
- "getrandom",
+ "getrandom 0.2.15",
"libredox",
"thiserror 2.0.11",
]
@@ -3314,7 +3318,7 @@ dependencies = [
"percent-encoding",
"pin-project-lite",
"quinn",
- "rustls 0.23.21",
+ "rustls 0.23.22",
"rustls-native-certs 0.8.1",
"rustls-pemfile 2.2.0",
"rustls-pki-types",
@@ -3343,7 +3347,7 @@ checksum =
"c17fa4cb658e3583423e915b9f3acc01cceaee1860e33d59ebae66adc3a2dc0d"
dependencies = [
"cc",
"cfg-if",
- "getrandom",
+ "getrandom 0.2.15",
"libc",
"spin",
"untrusted",
@@ -3434,9 +3438,9 @@ dependencies = [
[[package]]
name = "rustls"
-version = "0.23.21"
+version = "0.23.22"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "8f287924602bf649d949c63dc8ac8b235fa5387d394020705b80c4eb597ce5b8"
+checksum = "9fb9263ab4eb695e42321db096e3b8fbd715a59b154d5c88d82db2175b681ba7"
dependencies = [
"once_cell",
"ring",
@@ -3713,6 +3717,12 @@ dependencies = [
"libc",
]
+[[package]]
+name = "simdutf8"
+version = "0.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index";
+checksum = "e3a9fe34e3e7a50316060351f37187a3f546bce95496156754b601a5fa71b76e"
+
[[package]]
name = "siphasher"
version = "1.0.1"
@@ -3856,9 +3866,9 @@ checksum =
"13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292"
[[package]]
name = "syn"
-version = "2.0.96"
+version = "2.0.98"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "d5d0adab1ae378d7f53bdebc67a39f1f151407ef230f0ce2883572f5d8985c80"
+checksum = "36147f1a48ae0ec2b5b3bc5b537d267457555a10dc06f3dbc8cb11ba3006d3b1"
dependencies = [
"proc-macro2",
"quote",
@@ -3887,13 +3897,13 @@ dependencies = [
[[package]]
name = "tempfile"
-version = "3.15.0"
+version = "3.16.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "9a8a559c81686f576e8cd0290cd2a24a2a9ad80c98b3478856500fcbd7acd704"
+checksum = "38c246215d7d24f48ae091a2902398798e05d978b24315d6efbc00ede9a8bb91"
dependencies = [
"cfg-if",
"fastrand",
- "getrandom",
+ "getrandom 0.3.1",
"once_cell",
"rustix",
"windows-sys 0.59.0",
@@ -4065,7 +4075,7 @@ version = "0.26.1"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "5f6d0975eaace0cf0fcadee4e4aaa5da15b5c079146f2cffb67c113be122bf37"
dependencies = [
- "rustls 0.23.21",
+ "rustls 0.23.22",
"tokio",
]
@@ -4090,9 +4100,9 @@ checksum =
"0dd7358ecb8fc2f8d014bf86f6f638ce72ba252a2c3a2572f2a795f1d23efb41"
[[package]]
name = "toml_edit"
-version = "0.22.22"
+version = "0.22.23"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "4ae48d6208a266e853d946088ed816055e556cc6028c5e8e2b84d9fa5dd7c7f5"
+checksum = "02a8b472d1a3d7c18e2d61a489aee3453fd9031c33e4f55bd533f4a7adca1bee"
dependencies = [
"indexmap",
"toml_datetime",
@@ -4264,7 +4274,7 @@ version = "1.12.1"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "b3758f5e68192bb96cc8f9b7e2c2cfdabb435499a28499a42f8f984092adad4b"
dependencies = [
- "getrandom",
+ "getrandom 0.2.15",
"serde",
]
@@ -4314,6 +4324,15 @@ version = "0.11.0+wasi-snapshot-preview1"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "9c8d87e72b64a3b4db28d11ce29237c246188f4f51057d65a7eab63b7987e423"
+[[package]]
+name = "wasi"
+version = "0.13.3+wasi-0.2.2"
+source = "registry+https://github.com/rust-lang/crates.io-index";
+checksum = "26816d2e1a4a36a2940b96c5296ce403917633dff8f3440e9b236ed6f6bacad2"
+dependencies = [
+ "wit-bindgen-rt",
+]
+
[[package]]
name = "wasm-bindgen"
version = "0.2.100"
@@ -4550,13 +4569,22 @@ checksum =
"589f6da84c646204747d1270a2a5661ea66ed1cced2631d546fdfb155959f9ec"
[[package]]
name = "winnow"
-version = "0.6.25"
+version = "0.7.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "ad699df48212c6cc6eb4435f35500ac6fd3b9913324f938aea302022ce19d310"
+checksum = "7e49d2d35d3fad69b39b94139037ecfb4f359f08958b9c11e7315ce770462419"
dependencies = [
"memchr",
]
+[[package]]
+name = "wit-bindgen-rt"
+version = "0.33.0"
+source = "registry+https://github.com/rust-lang/crates.io-index";
+checksum = "3268f3d866458b787f390cf61f4bbb563b922d091359f9608842999eaee3943c"
+dependencies = [
+ "bitflags 2.8.0",
+]
+
[[package]]
name = "write16"
version = "1.0.0"
diff --git a/datafusion-cli/Cargo.toml b/datafusion-cli/Cargo.toml
index 6b6b52fce7..7daa325621 100644
--- a/datafusion-cli/Cargo.toml
+++ b/datafusion-cli/Cargo.toml
@@ -29,7 +29,7 @@ rust-version = "1.81.0"
readme = "README.md"
[dependencies]
-arrow = { version = "54.0.0" }
+arrow = { version = "54.1.0" }
async-trait = "0.1.0"
aws-config = "1.5.0"
aws-credential-types = "1.2.0"
@@ -57,7 +57,7 @@ home = "=0.5.11"
mimalloc = { version = "0.1", default-features = false }
object_store = { version = "0.11.0", features = ["aws", "gcp", "http"] }
parking_lot = { version = "0.12" }
-parquet = { version = "54.0.0", default-features = false }
+parquet = { version = "54.1.0", default-features = false }
regex = "1.8"
rustyline = "15.0"
tokio = { version = "1.24", features = ["macros", "rt", "rt-multi-thread",
"sync", "parking_lot", "signal"] }
diff --git a/datafusion/core/src/datasource/physical_plan/arrow_file.rs
b/datafusion/core/src/datasource/physical_plan/arrow_file.rs
index 54344d55bb..82735334c7 100644
--- a/datafusion/core/src/datasource/physical_plan/arrow_file.rs
+++ b/datafusion/core/src/datasource/physical_plan/arrow_file.rs
@@ -309,10 +309,8 @@ impl FileOpener for ArrowOpener {
for (dict_block, dict_result) in
footer.dictionaries().iter().flatten().zip(dict_results)
{
- decoder.read_dictionary(
- dict_block,
- &Buffer::from_bytes(dict_result.into()),
- )?;
+ decoder
+ .read_dictionary(dict_block,
&Buffer::from(dict_result))?;
}
// filter recordbatches according to range
@@ -348,10 +346,7 @@ impl FileOpener for ArrowOpener {
.zip(recordbatch_results)
.filter_map(move |(block, data)| {
decoder
- .read_record_batch(
- &block,
- &Buffer::from_bytes(data.into()),
- )
+ .read_record_batch(&block,
&Buffer::from(data))
.transpose()
}),
)
diff --git a/datafusion/expr-common/src/interval_arithmetic.rs
b/datafusion/expr-common/src/interval_arithmetic.rs
index 549461e0be..7f20020c34 100644
--- a/datafusion/expr-common/src/interval_arithmetic.rs
+++ b/datafusion/expr-common/src/interval_arithmetic.rs
@@ -26,6 +26,8 @@ use std::ops::{AddAssign, SubAssign};
use arrow::compute::{cast_with_options, CastOptions};
use arrow::datatypes::{
DataType, IntervalDayTime, IntervalMonthDayNano, IntervalUnit, TimeUnit,
+ MAX_DECIMAL128_FOR_EACH_PRECISION, MAX_DECIMAL256_FOR_EACH_PRECISION,
+ MIN_DECIMAL128_FOR_EACH_PRECISION, MIN_DECIMAL256_FOR_EACH_PRECISION,
};
use datafusion_common::rounding::{alter_fp_rounding_mode, next_down, next_up};
use datafusion_common::{internal_err, Result, ScalarValue};
@@ -97,718 +99,6 @@ macro_rules! get_extreme_value {
};
}
-/// The maximum `i128` value that can be stored in a `Decimal128` value of
precision `p`.
-///
-/// Remove this once <https://github.com/apache/arrow-rs/pull/6992> is
available
-const MAX_DECIMAL128_FOR_EACH_PRECISION: [i128; 39] = [
- 0, // unused first element
- 9,
- 99,
- 999,
- 9999,
- 99999,
- 999999,
- 9999999,
- 99999999,
- 999999999,
- 9999999999,
- 99999999999,
- 999999999999,
- 9999999999999,
- 99999999999999,
- 999999999999999,
- 9999999999999999,
- 99999999999999999,
- 999999999999999999,
- 9999999999999999999,
- 99999999999999999999,
- 999999999999999999999,
- 9999999999999999999999,
- 99999999999999999999999,
- 999999999999999999999999,
- 9999999999999999999999999,
- 99999999999999999999999999,
- 999999999999999999999999999,
- 9999999999999999999999999999,
- 99999999999999999999999999999,
- 999999999999999999999999999999,
- 9999999999999999999999999999999,
- 99999999999999999999999999999999,
- 999999999999999999999999999999999,
- 9999999999999999999999999999999999,
- 99999999999999999999999999999999999,
- 999999999999999999999999999999999999,
- 9999999999999999999999999999999999999,
- 99999999999999999999999999999999999999,
-];
-
-/// The minimum `i128` value that can be stored in a `Decimal128` value of
precision `p`.
-///
-/// Remove this once <https://github.com/apache/arrow-rs/pull/6992> is
available
-const MIN_DECIMAL128_FOR_EACH_PRECISION: [i128; 39] = [
- 0, // unused first element
- -9,
- -99,
- -999,
- -9999,
- -99999,
- -999999,
- -9999999,
- -99999999,
- -999999999,
- -9999999999,
- -99999999999,
- -999999999999,
- -9999999999999,
- -99999999999999,
- -999999999999999,
- -9999999999999999,
- -99999999999999999,
- -999999999999999999,
- -9999999999999999999,
- -99999999999999999999,
- -999999999999999999999,
- -9999999999999999999999,
- -99999999999999999999999,
- -999999999999999999999999,
- -9999999999999999999999999,
- -99999999999999999999999999,
- -999999999999999999999999999,
- -9999999999999999999999999999,
- -99999999999999999999999999999,
- -999999999999999999999999999999,
- -9999999999999999999999999999999,
- -99999999999999999999999999999999,
- -999999999999999999999999999999999,
- -9999999999999999999999999999999999,
- -99999999999999999999999999999999999,
- -999999999999999999999999999999999999,
- -9999999999999999999999999999999999999,
- -99999999999999999999999999999999999999,
-];
-
-/// The maximum `i256` value that can be stored in a `Decimal256` value of
precision `p`.
-///
-/// Remove this once <https://github.com/apache/arrow-rs/pull/6992> is
available
-const MAX_DECIMAL256_FOR_EACH_PRECISION: [arrow::datatypes::i256; 77] = [
- arrow::datatypes::i256::from_i128(0_i128), // unused first element
- arrow::datatypes::i256::from_le_bytes([
- 9, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 99, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 231, 3, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 15, 39, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 159, 134, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 63, 66, 15, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 127, 150, 152, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 224, 245, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 201, 154, 59, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 227, 11, 84, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 231, 118, 72, 23, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 15, 165, 212, 232, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 159, 114, 78, 24, 9, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 63, 122, 16, 243, 90, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 127, 198, 164, 126, 141, 3, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 192, 111, 242, 134, 35, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 137, 93, 120, 69, 99, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 99, 167, 179, 182, 224, 13, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 231, 137, 4, 35, 199, 138, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 15, 99, 45, 94, 199, 107, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 159, 222, 197, 173, 201, 53, 54, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 63, 178, 186, 201, 224, 25, 30, 2, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 127, 246, 74, 225, 199, 2, 45, 21, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 160, 237, 204, 206, 27, 194, 211, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 73, 72, 1, 20, 22, 149, 69, 8, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 227, 210, 12, 200, 220, 210, 183, 82, 0, 0, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 231, 60, 128, 208, 159, 60, 46, 59, 3, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 15, 97, 2, 37, 62, 94, 206, 79, 32, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 159, 202, 23, 114, 109, 174, 15, 30, 67, 1, 0, 0, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 63, 234, 237, 116, 70, 208, 156, 44, 159, 12, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 127, 38, 75, 145, 192, 34, 32, 190, 55, 126, 0, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 128, 239, 172, 133, 91, 65, 109, 45, 238, 4, 0, 0,
0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 9, 91, 193, 56, 147, 141, 68, 198, 77, 49, 0, 0,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 99, 142, 141, 55, 192, 135, 173, 190, 9, 237, 1,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 231, 143, 135, 43, 130, 77, 199, 114, 97, 66, 19,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 15, 159, 75, 179, 21, 7, 201, 123, 206, 151, 192,
0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 159, 54, 244, 0, 217, 70, 218, 213, 16, 238, 133,
7, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 63, 34, 138, 9, 122, 196, 134, 90, 168, 76, 59,
75, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 127, 86, 101, 95, 196, 172, 67, 137, 147, 254, 80,
240, 2, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 96, 245, 185, 171, 191, 164, 92, 195, 241,
41, 99, 29,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 201, 149, 67, 181, 124, 111, 158, 161, 113,
163, 223,
- 37, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 227, 217, 163, 20, 223, 90, 48, 80, 112, 98,
188, 122,
- 11, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 231, 130, 102, 206, 182, 140, 227, 33, 99,
216, 91, 203,
- 114, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 15, 29, 1, 16, 36, 127, 227, 82, 223, 115,
150, 241,
- 123, 4, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 159, 34, 11, 160, 104, 247, 226, 60, 185,
134, 224, 111,
- 215, 44, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 63, 90, 111, 64, 22, 170, 221, 96, 60, 67,
197, 94, 106,
- 192, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 127, 134, 89, 132, 222, 164, 168, 200, 91,
160, 180,
- 179, 39, 132, 17, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 64, 127, 43, 177, 112, 150, 214, 149,
67, 14, 5,
- 141, 41, 175, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 137, 248, 178, 235, 102, 224, 97, 218,
163, 142,
- 50, 130, 159, 215, 6, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 99, 181, 253, 52, 5, 196, 210, 135, 102,
146, 249,
- 21, 59, 108, 68, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 231, 21, 233, 17, 52, 168, 59, 78, 1,
184, 191,
- 219, 78, 58, 172, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 15, 219, 26, 179, 8, 146, 84, 14, 13,
48, 125, 149,
- 20, 71, 186, 26, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 159, 142, 12, 255, 86, 180, 77, 143,
130, 224, 227,
- 214, 205, 198, 70, 11, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 63, 146, 125, 246, 101, 11, 9, 153, 25,
197, 230,
- 100, 10, 196, 195, 112, 10, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 127, 182, 231, 160, 251, 113, 90, 250,
255, 178, 3,
- 241, 103, 168, 165, 103, 104, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 32, 13, 73, 212, 115, 136, 199,
255, 253, 36,
- 106, 15, 148, 120, 12, 20, 4, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 73, 131, 218, 74, 134, 84, 203,
253, 235, 113,
- 37, 154, 200, 181, 124, 200, 40, 0, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 227, 32, 137, 236, 62, 77, 241,
233, 55, 115,
- 118, 5, 214, 25, 223, 212, 151, 1, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 231, 72, 91, 61, 117, 4, 109, 35,
47, 128,
- 160, 54, 92, 2, 183, 80, 238, 15, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 15, 217, 144, 101, 148, 44, 66, 98,
215, 1,
- 69, 34, 154, 23, 38, 39, 79, 159, 0, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 159, 122, 168, 247, 203, 189, 149,
214, 105,
- 18, 178, 86, 5, 236, 124, 135, 23, 57, 6, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 63, 202, 148, 172, 247, 105, 217,
97, 34, 184,
- 244, 98, 53, 56, 225, 74, 235, 58, 62, 0, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 127, 230, 207, 189, 172, 35, 126,
210, 87, 49,
- 143, 221, 21, 50, 204, 236, 48, 77, 110, 2, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 0, 31, 106, 191, 100, 237, 56,
110, 237,
- 151, 167, 218, 244, 249, 63, 233, 3, 79, 24, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 9, 54, 37, 122, 239, 69, 57,
78, 70, 239,
- 139, 138, 144, 195, 127, 28, 39, 22, 243, 0, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 99, 28, 116, 197, 90, 187, 60,
14, 191,
- 88, 119, 105, 165, 163, 253, 28, 135, 221, 126, 9, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 231, 27, 137, 182, 139, 81,
95, 142, 118,
- 119, 169, 30, 118, 100, 232, 33, 71, 167, 244, 94, 0, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 15, 23, 91, 33, 117, 47, 185,
143, 161,
- 170, 158, 50, 157, 236, 19, 83, 199, 136, 142, 181, 3, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 159, 230, 142, 77, 147, 218,
59, 157, 79,
- 170, 50, 250, 35, 62, 199, 62, 201, 87, 145, 23, 37, 0, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 63, 2, 149, 7, 193, 137, 86,
36, 28, 167,
- 250, 197, 103, 109, 200, 115, 220, 109, 173, 235, 114, 1, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 127, 22, 210, 75, 138, 97, 97,
107, 25,
- 135, 202, 187, 13, 70, 212, 133, 156, 74, 198, 52, 125, 14, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 224, 52, 246, 102, 207,
205, 49,
- 254, 70, 233, 85, 137, 188, 74, 58, 29, 234, 190, 15, 228, 144, 0, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 201, 16, 158, 5, 26, 10,
242, 237,
- 197, 28, 91, 93, 93, 235, 70, 36, 37, 117, 157, 232, 168, 5, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 227, 167, 44, 56, 4, 101,
116, 75,
- 187, 31, 143, 165, 165, 49, 197, 106, 115, 147, 38, 22, 153, 56, 0,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 231, 142, 190, 49, 42,
242, 139,
- 242, 80, 61, 151, 119, 120, 240, 179, 43, 130, 194, 129, 221, 250, 53,
2,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 15, 149, 113, 241, 165,
117, 119,
- 121, 41, 101, 232, 171, 180, 100, 7, 181, 21, 153, 17, 167, 204, 27,
22,
- ]),
-];
-
-/// The minimum `i256` value that can be stored in a `Decimal256` value of
precision `p`.
-///
-/// Remove this once <https://github.com/apache/arrow-rs/pull/6992> is
available
-const MIN_DECIMAL256_FOR_EACH_PRECISION: [arrow::datatypes::i256; 77] = [
- arrow::datatypes::i256::from_i128(0_i128), // unused first element
- arrow::datatypes::i256::from_le_bytes([
- 247, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 157, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 25, 252, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 241, 216, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 97, 121, 254, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 193, 189, 240, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 129, 105, 103, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 31, 10, 250, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 54, 101, 196, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 28, 244, 171, 253, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 24, 137, 183, 232, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 240, 90, 43, 23, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 96, 141, 177, 231, 246, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 192, 133, 239, 12, 165, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 128, 57, 91, 129, 114, 252, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 63, 144, 13, 121, 220, 255, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 118, 162, 135, 186, 156, 254, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 156, 88, 76, 73, 31, 242, 255, 255, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 24, 118, 251, 220, 56, 117, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 240, 156, 210, 161, 56, 148, 250, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 96, 33, 58, 82, 54, 202, 201, 255, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 192, 77, 69, 54, 31, 230, 225, 253, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 128, 9, 181, 30, 56, 253, 210, 234, 255, 255, 255, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 95, 18, 51, 49, 228, 61, 44, 255, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 182, 183, 254, 235, 233, 106, 186, 247, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 28, 45, 243, 55, 35, 45, 72, 173, 255, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 24, 195, 127, 47, 96, 195, 209, 196, 252, 255, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 240, 158, 253, 218, 193, 161, 49, 176, 223, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 96, 53, 232, 141, 146, 81, 240, 225, 188, 254, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 192, 21, 18, 139, 185, 47, 99, 211, 96, 243, 255, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 128, 217, 180, 110, 63, 221, 223, 65, 200, 129, 255, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 127, 16, 83, 122, 164, 190, 146, 210, 17, 251, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 246, 164, 62, 199, 108, 114, 187, 57, 178, 206, 255, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 156, 113, 114, 200, 63, 120, 82, 65, 246, 18, 254, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 24, 112, 120, 212, 125, 178, 56, 141, 158, 189, 236, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 240, 96, 180, 76, 234, 248, 54, 132, 49, 104, 63, 255,
255, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 96, 201, 11, 255, 38, 185, 37, 42, 239, 17, 122, 248, 255,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 192, 221, 117, 246, 133, 59, 121, 165, 87, 179, 196, 180,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 128, 169, 154, 160, 59, 83, 188, 118, 108, 1, 175, 15,
253, 255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 159, 10, 70, 84, 64, 91, 163, 60, 14, 214, 156, 226,
255, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 54, 106, 188, 74, 131, 144, 97, 94, 142, 92, 32, 218,
254, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 28, 38, 92, 235, 32, 165, 207, 175, 143, 157, 67, 133,
244, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 24, 125, 153, 49, 73, 115, 28, 222, 156, 39, 164, 52,
141, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 240, 226, 254, 239, 219, 128, 28, 173, 32, 140, 105,
14, 132, 251,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 96, 221, 244, 95, 151, 8, 29, 195, 70, 121, 31, 144,
40, 211, 255,
- 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 192, 165, 144, 191, 233, 85, 34, 159, 195, 188, 58,
161, 149, 63,
- 254, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 128, 121, 166, 123, 33, 91, 87, 55, 164, 95, 75, 76,
216, 123,
- 238, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 191, 128, 212, 78, 143, 105, 41, 106, 188, 241, 250,
114, 214,
- 80, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 118, 7, 77, 20, 153, 31, 158, 37, 92, 113, 205, 125,
96, 40,
- 249, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 156, 74, 2, 203, 250, 59, 45, 120, 153, 109, 6, 234,
196, 147,
- 187, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 24, 234, 22, 238, 203, 87, 196, 177, 254, 71, 64,
36, 177, 197,
- 83, 253, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 240, 36, 229, 76, 247, 109, 171, 241, 242, 207, 130,
106, 235,
- 184, 69, 229, 255, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 96, 113, 243, 0, 169, 75, 178, 112, 125, 31, 28, 41,
50, 57,
- 185, 244, 254, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 192, 109, 130, 9, 154, 244, 246, 102, 230, 58, 25,
155, 245,
- 59, 60, 143, 245, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 128, 73, 24, 95, 4, 142, 165, 5, 0, 77, 252, 14,
152, 87, 90,
- 152, 151, 255, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 223, 242, 182, 43, 140, 119, 56, 0, 2, 219, 149,
240, 107,
- 135, 243, 235, 251, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 182, 124, 37, 181, 121, 171, 52, 2, 20, 142, 218,
101, 55,
- 74, 131, 55, 215, 255, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 28, 223, 118, 19, 193, 178, 14, 22, 200, 140,
137, 250, 41,
- 230, 32, 43, 104, 254, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 24, 183, 164, 194, 138, 251, 146, 220, 208, 127,
95, 201,
- 163, 253, 72, 175, 17, 240, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 240, 38, 111, 154, 107, 211, 189, 157, 40, 254,
186, 221,
- 101, 232, 217, 216, 176, 96, 255, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 96, 133, 87, 8, 52, 66, 106, 41, 150, 237, 77,
169, 250, 19,
- 131, 120, 232, 198, 249, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 192, 53, 107, 83, 8, 150, 38, 158, 221, 71, 11,
157, 202,
- 199, 30, 181, 20, 197, 193, 255, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 128, 25, 48, 66, 83, 220, 129, 45, 168, 206, 112,
34, 234,
- 205, 51, 19, 207, 178, 145, 253, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 255, 224, 149, 64, 155, 18, 199, 145, 18, 104,
88, 37,
- 11, 6, 192, 22, 252, 176, 231, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 246, 201, 218, 133, 16, 186, 198, 177, 185,
16, 116, 117,
- 111, 60, 128, 227, 216, 233, 12, 255, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 156, 227, 139, 58, 165, 68, 195, 241, 64, 167,
136, 150,
- 90, 92, 2, 227, 120, 34, 129, 246, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 24, 228, 118, 73, 116, 174, 160, 113, 137,
136, 86, 225,
- 137, 155, 23, 222, 184, 88, 11, 161, 255, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 240, 232, 164, 222, 138, 208, 70, 112, 94, 85,
97, 205,
- 98, 19, 236, 172, 56, 119, 113, 74, 252, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 96, 25, 113, 178, 108, 37, 196, 98, 176, 85,
205, 5, 220,
- 193, 56, 193, 54, 168, 110, 232, 218, 255, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 192, 253, 106, 248, 62, 118, 169, 219, 227,
88, 5, 58,
- 152, 146, 55, 140, 35, 146, 82, 20, 141, 254, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 128, 233, 45, 180, 117, 158, 158, 148, 230,
120, 53, 68,
- 242, 185, 43, 122, 99, 181, 57, 203, 130, 241, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 0, 31, 203, 9, 153, 48, 50, 206, 1, 185, 22,
170, 118,
- 67, 181, 197, 226, 21, 65, 240, 27, 111, 255, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 0, 54, 239, 97, 250, 229, 245, 13, 18, 58,
227, 164, 162,
- 162, 20, 185, 219, 218, 138, 98, 23, 87, 250, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 0, 28, 88, 211, 199, 251, 154, 139, 180, 68,
224, 112,
- 90, 90, 206, 58, 149, 140, 108, 217, 233, 102, 199, 255,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 0, 24, 113, 65, 206, 213, 13, 116, 13, 175,
194, 104,
- 136, 135, 15, 76, 212, 125, 61, 126, 34, 5, 202, 253,
- ]),
- arrow::datatypes::i256::from_le_bytes([
- 1, 0, 0, 0, 0, 0, 0, 0, 0, 240, 106, 142, 14, 90, 138, 136, 134, 214,
154, 23,
- 84, 75, 155, 248, 74, 234, 102, 238, 88, 51, 228, 233,
- ]),
-];
-
macro_rules! value_transition {
($bound:ident, $direction:expr, $value:expr) => {
match $value {
diff --git a/datafusion/optimizer/src/unwrap_cast_in_comparison.rs
b/datafusion/optimizer/src/unwrap_cast_in_comparison.rs
index 892d450ba8..e2b8a966cb 100644
--- a/datafusion/optimizer/src/unwrap_cast_in_comparison.rs
+++ b/datafusion/optimizer/src/unwrap_cast_in_comparison.rs
@@ -26,7 +26,8 @@ use crate::{OptimizerConfig, OptimizerRule};
use crate::utils::NamePreserver;
use arrow::datatypes::{
- DataType, TimeUnit, MAX_DECIMAL_FOR_EACH_PRECISION,
MIN_DECIMAL_FOR_EACH_PRECISION,
+ DataType, TimeUnit, MAX_DECIMAL128_FOR_EACH_PRECISION,
+ MIN_DECIMAL128_FOR_EACH_PRECISION,
};
use arrow::temporal_conversions::{MICROSECONDS, MILLISECONDS, NANOSECONDS};
use datafusion_common::tree_node::{Transformed, TreeNode, TreeNodeRewriter};
@@ -369,8 +370,8 @@ fn try_cast_numeric_literal(
// Different precision for decimal128 can store different range of
value.
// For example, the precision is 3, the max of value is `999` and
the min
// value is `-999`
- MIN_DECIMAL_FOR_EACH_PRECISION[*precision as usize - 1],
- MAX_DECIMAL_FOR_EACH_PRECISION[*precision as usize - 1],
+ MIN_DECIMAL128_FOR_EACH_PRECISION[*precision as usize],
+ MAX_DECIMAL128_FOR_EACH_PRECISION[*precision as usize],
),
_ => return None,
};
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
